如何实现同一应用下多后台Worker使用不同Azure Service Bus订阅

原有实现的核心问题是全局注册了单一的ISubscriptionClient单例，所有Worker注入拿到的都是同一个绑定固定订阅的客户端，自然无法切换到不同订阅开展工作。调整不需要复杂架构改动，按以下步骤操作即可实现目标：

• 先调整配置结构，预留多订阅的配置位，替换原来单组Topic/Subscription的硬编码配置
  配置示例：

  "ServiceBus": {
    "ConnectionString": "你的服务总线连接字符串",
    "TopicName": "公共Topic名称",
    "Subscriptions": {
      "OrderProcess": "订单变更专属订阅名",
      "NotificationDispatch": "用户告警专属订阅名"
    }
  }
  

• 移除Program.cs里全局注册ISubscriptionClient单例的代码，不要把订阅客户端作为全局DI服务暴露

• 改造每个后台Worker类：不再依赖注入全局共享的ISubscriptionClient，改为在Worker内部初始化专属的订阅客户端，绑定对应Worker自己要连接的订阅名
  以两个独立Worker为例的实现参考：

  // 订单处理专属Worker
  public class OrderProcessWorker : BackgroundService
  {
      private readonly SubscriptionClient _client;
      // 仅注入IConfiguration和需要的公共业务依赖
      public OrderProcessWorker(IConfiguration config, ILogger<OrderProcessWorker> logger)
      {
          // 读取当前Worker专属的订阅配置，独立生成客户端实例
          _client = new SubscriptionClient(
              config["ServiceBus:ConnectionString"],
              config["ServiceBus:TopicName"],
              config["ServiceBus:Subscriptions:OrderProcess"]);
      }
  
      protected override async Task ExecuteAsync(CancellationToken stoppingToken)
      {
          // 注册当前Worker专属的消息处理逻辑，完全独立于其他Worker
          _client.RegisterMessageHandler(async (message, token) =>
          {
              // 订单处理专属业务逻辑
          }, new MessageHandlerOptions(ex => 
          {
              // 专属错误处理逻辑
              return Task.CompletedTask;
          }));
  
          // 停止信号触发时正确释放客户端连接
          stoppingToken.Register(async () => await _client.CloseAsync());
          await Task.Delay(Timeout.Infinite, stoppingToken);
      }
  }
  

  // 通知派发专属Worker
  public class NotificationDispatchWorker : BackgroundService
  {
      private readonly SubscriptionClient _client;
      public NotificationDispatchWorker(IConfiguration config, ILogger<NotificationDispatchWorker> logger)
      {
          // 读取当前Worker要连接的另一个订阅，生成独立的客户端实例
          _client = new SubscriptionClient(
              config["ServiceBus:ConnectionString"],
              config["ServiceBus:TopicName"],
              config["ServiceBus:Subscriptions:NotificationDispatch"]);
      }
  
      protected override async Task ExecuteAsync(CancellationToken stoppingToken)
      {
          // 注册通知派发专属的消息处理逻辑
          _client.RegisterMessageHandler(async (message, token) =>
          {
              // 通知派发专属业务逻辑
          }, new MessageHandlerOptions(ex => 
          {
              // 专属错误处理逻辑
              return Task.CompletedTask;
          }));
  
          stoppingToken.Register(async () => await _client.CloseAsync());
          await Task.Delay(Timeout.Infinite, stoppingToken);
      }
  }
  

• 在Program.cs里直接注册所有改造后的Worker为托管服务即可：

  // 删掉原来的全局ISubscriptionClient注册代码
  builder.Services.AddHostedService<OrderProcessWorker>();
  builder.Services.AddHostedService<NotificationDispatchWorker>();
  

注意事项 #

• 订阅客户端的生命周期完全和绑定的Worker一致，应用停止时随Worker一起释放连接，不会出现连接泄漏
• 每个Worker可以独立配置消息处理的最大并发数、消息签收模式、错误重试策略，搭配各自专属的处理逻辑，完全满足差异化业务需求
• 如果使用新版Azure.Messaging.ServiceBus SDK，逻辑完全通用：每个Worker从DI注入的ServiceBusClient工厂里，创建对应订阅的ServiceBusProcessor实例即可，不需要做全局单例改造
• 所有公共依赖（日志、业务服务、缓存等）正常通过DI注入到Worker即可，和订阅客户端的初始化逻辑互不干扰

内容的提问来源于stack exchange，提问作者zawisza