azure 服务总线处理对象

xmakbtuz  于 2023-05-29  发布在  其他
关注(0)|答案(1)|浏览(251)

我正在通过服务总线在Azure上使用消息队列架构。偶尔当我尝试向队列发送消息时,它会失败。以下是我得到的错误:
有时候我会收到这样的信息

Message:Can't create session when the connection is closing.

其他时候我收到这个信息

Message:Cannot access a disposed object.
Object name: 'FaultTolerantAmqpObject`1'.

请记住,它并不总是发生。有时我为服务总线创建数千条消息。我正在为发送到队列的每条消息分派一个异步任务
这是我的代码

Task.Run(() => new ServiceBusService().SendQueueMessage(busMessageObject));

服务总线类

public class ServiceBusService
{ 
    static string ServiceBusConnectionString = AzureUtils.SERVICE_BUS_CONNECTIONSTRING;
    const string QueueName = "eventqueue";
    static IQueueClient queueClient;

    public async Task SendQueueMessage(JObject jObject, DateTime? scheduledEnqueueTimeUtc = null)
    {
        string jsonObject = "";
        string scheduledTime = "";

        if(scheduledEnqueueTimeUtc.HasValue)
        {
            scheduledTime = scheduledEnqueueTimeUtc.Value.ToLongTimeString();
        }

        try
        {
            queueClient = new QueueClient(ServiceBusConnectionString, QueueName);
            var message = new Message(Encoding.UTF8.GetBytes(jObject.ToString()));

            if(scheduledEnqueueTimeUtc.HasValue)
                message.ScheduledEnqueueTimeUtc = scheduledEnqueueTimeUtc.Value;

            await queueClient.SendAsync(message);
            await queueClient.CloseAsync();
        }
        catch (Exception e)
        {
            Trace.TraceError($"{Tag()} " + e.InnerException + " " + e.Message);
        }
    }
}
c3frrgcw

c3frrgcw1#

这是因为我的QueueClient是静态的,多个线程正在使用它,并释放它。让它不是静态的解决了我的问题。

相关问题