Azure Service Bus Peek模式下同条消息多次触发handler问题咨询

核心首要排查点 #

• 异步确认方法未等待执行完成
  你代码中的completeMessage是异步方法，当前没有加await关键字等待调用，导致消息处理函数提前返回时，确认请求还未成功发送到ASB服务端，ASB认为消息未被确认，锁超时后就会重新投递，这是高概率触发该问题的原因。

其他可能原因 #

• 确认调用执行失败未捕获
  completeMessage调用过程中可能出现网络波动、当前账号没有消息确认权限、消息锁已过期等问题，导致确认请求没有被ASB成功接收，服务端会认为消息处理失败触发重投。建议给确认逻辑增加异常捕获，排查是否有隐藏的报错。
• 消息锁超时
  ASB PeekLock模式下消息默认锁时长为30秒，如果completeMessage执行之前锁已经到期，此时确认操作会直接失效，ASB已经将消息重新标记为可投递状态，会被消费者再次拉取。可以检查订阅配置的锁时长，以及业务处理逻辑是否存在耗时过长阻塞确认执行的情况。
• 同订阅存在多个消费者实例
  如果同一个ASB订阅下部署了多个消费者实例，某一个实例处理消息过慢导致锁超时，消息会被其他实例拉取处理，也会出现同一条消息被多次处理的情况。
• 订阅规则配置问题
  检查订阅是否配置了自动转发、死信回流等规则，可能导致消息被重复投递到当前订阅。
• 处理逻辑未捕获异常触发SDK重试
  如果completeMessage执行完成后，后续业务逻辑抛出未捕获的异常，JS SDK的subscribe机制会自动重试处理当前消息，也会出现重复触发处理函数的情况。

修正后代码示例 #

const myMessageHandler = async (messageReceived) => {
  try {
    // 增加await等待确认请求执行完成
    await this.receiver.completeMessage(messageReceived);
    // 后续业务处理逻辑
    // .....
  } catch (err) {
    console.error('消息处理或确认失败：', err);
    // 异常场景可根据业务需要选择放弃消息/送入死信
    // await this.receiver.abandonMessage(messageReceived);
  }
} 
this.receiver.subscribe({
    processMessage: myMessageHandler,
    processError: myErrorHandler
});

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