求助：Azure Service Bus Topic触发器（IsSessionEnabled=false）无法持续监听消息

在.NET 8隔离运行环境下使用Azure Service Bus Topic触发器，当设置IsSessionEnabled=false、IsBatched=true和AutoCompleteMessages=false后，触发器能正常处理现有消息，但处理完所有消息进入空闲状态后，无法自动接收后续新发送到Topic的消息。

问题代码示例 #

public async Task Run(
    [ServiceBusTrigger("topic", "subscription", Connection = "TopicConnectionString",AutoCompleteMessages =false,IsBatched =true,IsSessionEnabled=false)]
    ServiceBusReceivedMessage[] messages,
    ServiceBusMessageActions messageActions)
{  
    // message processing

    // 将消息拼接写入Blob存储的CSV文件
}

解决办法 #

• 确保手动完成消息的逻辑正确：由于设置了AutoCompleteMessages=false，必须在处理完每条消息后调用messageActions.CompleteMessageAsync。如果遗漏这一步，Service Bus会认为消息仍在处理中，导致后续接收逻辑无法正常触发。
• 检查批量处理的完成逻辑：Service Bus SDK不支持批量完成消息，需要遍历批量中的每条消息逐一完成，示例代码如下：

  foreach (var message in messages)
  {
      // 执行单条消息的处理逻辑
      await messageActions.CompleteMessageAsync(message);
  }
  

• 验证宿主配置（host.json）：在隔离运行时中，检查host.json的Service Bus扩展配置，确保参数设置合理，避免限制接收循环：

  {
    "extensions": {
      "serviceBus": {
        "prefetchCount": 100,
        "maxAutoRenewDuration": "00:05:00",
        "messageHandlerOptions": {
          "autoCompleteMessages": false
        }
      }
    }
  }
  

• 确认Service Bus订阅状态：检查Topic订阅的MaxDeliveryCount是否设置过低，避免消息因多次重试被死信；同时确认订阅未启用不合理的死信规则，导致新消息无法进入订阅。
• 检查触发器注册逻辑：在Program.cs中确保正确注册Service Bus客户端和触发器，示例如下：

  var host = new HostBuilder()
      .ConfigureFunctionsWorkerDefaults()
      .ConfigureServices(services =>
      {
          services.AddAzureClients(clientBuilder =>
          {
              clientBuilder.AddServiceBusClient(Environment.GetEnvironmentVariable("TopicConnectionString"));
          });
      })
      .Build();
  
  host.Run();
  

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