Azure Service Bus并发句柄超限问题及并发管理咨询

发送端优化 #

• 复用Service Bus客户端/发送者实例：Node.js SDK中，避免在每次定时函数触发时创建新的ServiceBusClient或ServiceBusSender。将客户端实例放在模块级别（函数外部），利用Function App的实例复用机制，减少连接句柄消耗。示例：

// 模块级别初始化，仅在实例启动时创建一次
const { ServiceBusClient } = require("@azure/service-bus");
const connectionString = process.env.SERVICE_BUS_CONNECTION_STRING;
const topicName = "exemple";
const sbClient = new ServiceBusClient(connectionString);
const sender = sbClient.createSender(topicName);

module.exports = async function (context, myTimer) {
  // 复用已创建的sender发送消息
  const messages = [...]; // 构造批量消息
  await sender.sendMessages(messages);
};

• 批量发送消息：使用sendMessages方法批量发送多条消息，替代单条发送，减少API调用次数与连接开销。
• 控制发送速率：对定时函数的发送量做限流，比如拆分大批次为多个小批次，或添加延迟，避免短时间内产生大量连接请求。

接收端并发调整 #

• 配置Service Bus触发器参数：在host.json中调整触发器的并发控制参数，提升接收吞吐量：

{
  "version": "2.0",
  "extensions": {
    "serviceBus": {
      "maxConcurrentCalls": 32, // 每个实例的并发消息处理数，默认16
      "prefetchCount": 100, // 预取消息数，根据消息大小调整
      "maxAutoLockRenewalDuration": "00:05:00"
    }
  }
}

• 开启弹性缩放：在Function App的缩放设置中，设置合理的最大实例数（比如20），让平台根据消息队列长度自动扩容，分散接收压力。
• 手动接收（可选）：若触发器绑定的并发控制不够灵活，可改用手动创建ServiceBusReceiver，通过Promise.all限制同时处理的消息数，实现更精细的并发控制。

句柄数管控 #

• 排查连接泄漏：确保所有客户端实例在不再使用时正确关闭（但单例复用场景下无需每次关闭），避免无效连接占用句柄。
• 监控指标：在Azure Portal中监控Service Bus的Active Connections、Active Handles指标，以及Function App的进程句柄数，设置阈值警报提前预警。

其他最佳实践 #

• 使用分区主题：将exemple主题设置为分区主题，提升消息处理的吞吐量与负载均衡能力。
• 优化消息处理逻辑：简化接收端函数的处理逻辑，缩短消息处理耗时，避免长时间占用连接句柄；设置合理的重试次数与死信策略，防止消息反复重试消耗资源。
• 资源隔离：将发送端与接收端Function App分开部署，避免资源竞争导致的并发受限问题。

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