Service Bus队列触发器异常：消息偶发未触发处理端点

系统配置 #

消息发送实现 #

using Azure.Messaging.ServiceBus;

public class AzureServiceBusMessageSender : IMessageSender
{
    private readonly ServiceBusSender serviceBusSender;

    public AzureServiceBusMessageSender(string connectionString, string queueName)
    {
        var queueClient = new ServiceBusClient(connectionString);
        serviceBusSender = queueClient.CreateSender(queueName);
    }

    public async Task<Response<SendReceipt>> SendAsync<TRunParameters>(TRunParameters message)
    {
        await serviceBusSender.SendMessageAsync(message.ToServiceBusMessage());
        return null;
    }
}

消息接收逻辑（Azure Functions） #

[ServiceBusTrigger(nameof(DataAcquisitionJob), Connection = "ServiceBusConnectionString", IsSessionsEnabled = true)]
public void ProcessMessage([ServiceBusMessage] string message, ILogger logger)
{
    // Endpoint processing logic
    // ...
}

local.settings.json配置 #

{
    "IsEncrypted": false,
    "Values": {
        "AzureWebJobsStorage": "UseDevelopmentStorage=true",
        "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
        "ServiceBusConnectionString": "bus.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=###"
    }
}

Service Bus队列配置 #

问题描述 #

消息发送至队列后，间歇性出现未触发处理端点的情况，且无相关日志记录；已检查死信队列，未发现此类消息。

排查与解决建议 #

1. 会话消息缺失SessionId（核心问题） #

接收端触发器启用了IsSessionsEnabled=true，但发送的消息未指定SessionId时，消息会被存入队列但无法被会话感知的消费者拾取，导致消息"静默滞留"。

• 修复方式：在ToServiceBusMessage()方法中为消息添加SessionId，确保每个消息（或同一会话组的消息）拥有合法的SessionId：

  // 示例：在消息转换时设置SessionId
  public static ServiceBusMessage ToServiceBusMessage(this TRunParameters message)
  {
      var sbMessage = new ServiceBusMessage(JsonSerializer.Serialize(message));
      // 可根据业务逻辑生成固定或动态的SessionId
      sbMessage.SessionId = "fixed-session-id" /* 或 message.SessionKey */;
      return sbMessage;
  }
  

2. 修复ServiceBusClient生命周期问题 #

当前发送端每次实例化AzureServiceBusMessageSender时都会创建新的ServiceBusClient，而ServiceBusClient是线程安全的单例对象，频繁创建会导致连接池耗尽，引发间歇性发送/消费异常。

• 修复方式：将ServiceBusClient注册为单例（如在DI容器中），复用同一个实例：

  // 示例：在Startup/Program.cs中注册单例
  builder.Services.AddSingleton<ServiceBusClient>(sp => 
      new ServiceBusClient(Configuration["ServiceBusConnectionString"]));
  
  // 修改AzureServiceBusMessageSender的构造函数
  public AzureServiceBusMessageSender(ServiceBusClient serviceBusClient, string queueName)
  {
      serviceBusSender = serviceBusClient.CreateSender(queueName);
  }
  

3. 确认消息发送成功 #

当前SendAsync方法直接返回null，无法确认消息是否成功发送到Service Bus。建议捕获发送结果并返回，便于排查发送阶段的隐性失败：

public async Task<Response<SendReceipt>> SendAsync<TRunParameters>(TRunParameters message)
{
    var sbMessage = message.ToServiceBusMessage();
    var receipt = await serviceBusSender.SendMessageAsync(sbMessage);
    return receipt;
}

4. 检查Azure Functions会话处理配置 #

在.NET隔离模式下，Service Bus会话触发器需要确保：

• 函数的并发配置未限制会话处理（默认单会话单并发）
• 触发器的AutoCompleteMessages默认开启，若手动完成需确保逻辑正确

5. 排查队列会话状态 #

在Azure Portal的Service Bus队列页面，查看会话标签页，确认是否有活跃会话未被关闭，导致新消息无法被分配到可用的会话消费者。

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