如何在Azure App Service中正确注册并启动Azure Service Bus处理器

• 你的核心思路完全正确：只需注册ServiceBusClient作为单例依赖，再通过后台服务创建并启动多个ServiceBusProcessor实例，这是官方推荐的标准实践方式。
• 具体实现步骤：
  1. 注册ServiceBusClient：在Program.cs中通过依赖注入注册单例的ServiceBusClient，它是线程安全的，可复用底层连接资源：

     builder.Services.AddSingleton<ServiceBusClient>(sp => 
     {
         var connectionString = builder.Configuration.GetConnectionString("AzureServiceBus");
         return new ServiceBusClient(connectionString);
     });
     

  2. 创建后台服务类：新建继承自BackgroundService的类（比如SubscriptionProcessorHostedService），构造函数注入ServiceBusClient。
  3. 在后台服务的ExecuteAsync方法中，为每个主题订阅创建处理器并启动：

     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
         // 处理器1：对应第一个主题订阅
         var processor1 = _serviceBusClient.CreateProcessor("TopicName1", "SubscriptionName1");
         processor1.ProcessMessageAsync += HandleSubscription1Message;
         processor1.ProcessErrorAsync += HandleProcessorError;
         await processor1.StartProcessingAsync(stoppingToken);
     
         // 处理器2：对应第二个主题订阅
         var processor2 = _serviceBusClient.CreateProcessor("TopicName2", "SubscriptionName2");
         processor2.ProcessMessageAsync += HandleSubscription2Message;
         processor2.ProcessErrorAsync += HandleProcessorError;
         await processor2.StartProcessingAsync(stoppingToken);
     
         // 同理创建剩下的两个处理器...
     
         await Task.Delay(Timeout.Infinite, stoppingToken);
     }
     
     private Task HandleProcessorError(ProcessErrorEventArgs args)
     {
         // 统一错误处理逻辑，比如日志记录
         return Task.CompletedTask;
     }
     
     private async Task HandleSubscription1Message(ProcessMessageEventArgs args)
     {
         // 订阅1的消息处理逻辑
         await args.CompleteMessageAsync(args.Message);
     }
     

  4. 注册后台服务：在Program.cs中添加后台服务的注册：

     builder.Services.AddHostedService<SubscriptionProcessorHostedService>();
     

• 关键注意点：
  • ServiceBusProcessor是轻量级对象，无需注册为单例，每次通过ServiceBusClient创建即可，客户端会自动管理底层连接池。
  • 应用关闭时，BackgroundService的stoppingToken会触发处理器自动停止，也可手动调用StopProcessingAsync确保资源释放。
  • 可通过ServiceBusProcessorOptions为每个处理器配置个性化参数，比如预取数量、锁自动续期时长等。

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