Azure Service Bus Trigger函数报错无法分配句柄，求排查方案

使用MassTransit开发Azure Service Bus Trigger函数，当5分钟内向总线注入约1万条消息时，触发以下错误：

Cannot allocate more handles. The maximum number of handles is 4999. (QuotaExceeded).
Exception type: Azure.Messaging.ServiceBus.ServiceBusException
Failed method: Azure.Messaging.ServiceBus.Amqp.AmqpConnectionScope+<CreateSendingLinkAsync>d__85.MoveNext

函数逻辑为：读取总线消息，转换后将消息排入另一个主题。相关代码及配置如下：

函数代码 #

[FunctionName(nameof(HubspotWebhookCommandReceiver))]
public async Task Run([ServiceBusTrigger("%HubspotWebhook:CommandQueueName%", Connection = "ServiceBusConnection")]
ServiceBusReceivedMessage[] messages, CancellationToken cancellationToken)
{
    _logger.LogInformation("Handling {count} Hubspot Webhook Commands", messages.Count());

    var handles = new List<Task>();

    foreach (var message in messages)
    {           
        handles.Add(_messageReceiver.HandleConsumer<HubspotWebhookCommandConsumer>(_configuration.CommandQueueName, message, cancellationToken));
    }

    await Task.WhenAll(handles);
}

host.json配置 #

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "default": "Information"
    },
    "applicationInsights": {
      "samplingSettings": {
        "isEnabled": true,
        "excludedTypes": "Request"
      }
    }
  },
  "extensions": {
    "http": {
      "routePrefix": ""
    },
    "serviceBus": {
      "prefetchCount": 100,
      "messageHandlerOptions": {
        "autoComplete": true,
        "maxConcurrentCalls": 16,
        "maxAutoRenewDuration": "00:05:00"
      },
      "batchOptions": {
        "maxMessageCount": 1000,
        "operationTimeout": "00:01:00"
      }
    }
  }
}

解决建议 #

• 复用发送客户端/端点：检查_messageReceiver.HandleConsumer内部实现，确保不会为每条消息创建新的ServiceBusClient或MassTransit发送端点。ServiceBusClient是线程安全的，应全局单例复用，频繁创建会快速耗尽句柄配额。
• 降低并发与批量处理规模：调整host.json中的参数：
  • 降低maxConcurrentCalls（比如从16改为8），减少同时处理的消息批次数量
  • 减小batchOptions.maxMessageCount（比如从1000改为200），降低单次处理的消息量，避免同时发起大量发送请求
• 启用批量发送：将转换后的消息收集为批次，使用MassTransit或Azure Service Bus的批量发送API一次性发送，减少发送链接的创建次数
• 优化MassTransit配置：确保MassTransit使用的ServiceBus客户端是单例，配置合理的连接池设置，避免不必要的链接创建

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