服务总线 - 单例连接类？

Question

我正在尝试找出从 Web-API 使用服务总线的最佳实践。

我了解到重新创建 QueueClient、SubscriptionClient 等对象是错误的方法，因此我需要重用工厂和客户端。

服务总线客户端对象，例如 Microsoft.ServiceBus.Messaging.QueueClient 或 Microsoft.ServiceBus.Messaging.MessageSender，是通过 MessagingFactory 对象创建的，该对象还提供连接的内部管理。您不应在发送消息后关闭消息传递工厂或队列、主题和订阅客户端，然后在发送下一条消息时重新创建它们。关闭消息传递工厂会删除与服务总线服务的连接，并在重新创建工厂时建立新的连接。建立连接是一项代价高昂的操作，可以通过为多个操作重用相同的工厂和客户端对象来避免。

reference

我需要实现一个特殊的类来保持与服务总线的连接，我正在考虑一个将保持特定操作的单例类（函数如EnqueueJobToArchiveQueue(Job job) 和构造函数将初始化 QueueClient、MessageFactory 等'将被“具体操作函数”使用。

我的问题是我需要关闭对象（QueueClient.Close()），我什么时候需要关闭对象？

到目前为止，这是我的课程：

 public class ServiceBusHelper
{
    private static readonly ServiceBusHelper instance = new ServiceBusHelper();

    private static MessagingFactory msgFactory;

    private static NamespaceManager namespaceManager;

    private const string jobQueueName = "job";

    private const string responseTopicName = "jobResult";

    private const string archiveQueueName = "jobArchive";

    private static QueueClient archiveQueue;

    private static QueueClient jobQueue;

    private static TopicClient responseTopic;

    private ServiceBusHelper()
    {

    }

     static ServiceBusHelper()
    {

          msgFactory = MessagingFactory.CreateFromConnectionString(ConfigurationManager.AppSettings["ServiceBusCS"]);
          namespaceManager = NamespaceManager.CreateFromConnectionString(ConfigurationManager.AppSettings["ServiceBusCS"]);

          if (!namespaceManager.QueueExists(jobQueueName))
          {
              namespaceManager.CreateQueue(jobQueueName);
          }

          filteringQueue = QueueClient.CreateFromConnectionString(ConfigurationManager.AppSettings["ServiceBusCS"], jobQueueName);

          if (!namespaceManager.QueueExists(archiveQueueName))
          {
              namespaceManager.CreateQueue(archiveQueueName);
          }

          archiveQueue = QueueClient.CreateFromConnectionString(ConfigurationManager.AppSettings["ServiceBusCS"], archiveQueueName);

          if (!namespaceManager.TopicExists(responseTopicName))
          {
              namespaceManager.TopicExists(responseTopicName);
          }

          responseTopic = TopicClient.CreateFromConnectionString(ConfigurationManager.AppSettings["ServiceBusCS"],responseTopicName);


    }

    public static ServiceBusHelper Instance
    {         
        get
        {
            return instance;
        }
    }


    public void EnququeJobToDo(Job job, string corrId)
    {

        // Compose the message
        BrokeredMessage msg = new BrokeredMessage(job);

        msg.CorrelationId = corrId;

        // Send the message
        filteringQueue.Send(msg);
    }
 }

如您所见，我没有关闭连接 (QueueClient.Close())，我应该在哪里关闭连接？使用 Dispose() 实现 IDisposable ？

如果有更好的方法，请与我分享。

此代码来自具有良好工作负载的 Web-API（Azure 云服务）。

更新

我已经用Dispose() 更新了我的班级，如下所示：

     public void Dispose()
     {
         if (msgFactory != null)
         {
             msgFactory.Close();
         }

     } 

Answer 1

服务总线 SDK 使用的默认底层协议是专有的 SBMP（服务总线消息传递协议），它在关闭工厂时关闭的 TCP/IP 连接之上工作。 如果您选择使用 TransportType=Amqp（在连接字符串中），您可以切换到 AMQP 协议。在这种情况下，工厂处理与总线和 QueueClient 的唯一 TCP 连接，TopicClient 类（从工厂创建）在上述 TCP 连接内实例化会话和链接。会话和链接是用于在单个 TCP 连接上多路复用的两个 AMQP 概念。 如果只关闭 QueueClient 和 TopicClient，则关闭操作只关闭相关会话和链接，而不关闭工厂对象时关闭的 TCP 连接。 当然，我不知道 SBMP 在内部是如何工作的，因为它是一个专有协议。 但是，在处置中，您可以关闭工厂和相关的队列/主题对象。 你有什么问题？