使用WebJobs SDK时，如何避免重复接收ServiceBus Queue消息？

从你贴的代码来看，你已经尝试用[Singleton("{MessageId}")]来做单实例处理，但要彻底解决重复接收的问题，得从ServiceBus本身特性、WebJobs配置和业务逻辑兜底三个层面入手，给你梳理几个关键方案：

• 开启ServiceBus队列的重复检测功能
  这是最基础的防护层。ServiceBus原生支持重复消息检测，你只需要在创建队列时开启DuplicateDetection，并设置DuplicateDetectionHistoryTimeWindow（比如设为5分钟）。这样只要消息的MessageId是唯一的，在这个时间窗口内，ServiceBus会自动过滤掉重复发送的消息，根本不会推送到你的WebJob。

  注意：MessageId必须由发送端保证唯一性，比如用GUID生成，这是这个功能生效的前提。

• 确保Singleton特性正确生效
  你用的[Singleton("{MessageId}")]是WebJobs SDK提供的进程内单实例锁，能防止同一个WebJob进程内重复处理同一个MessageId的消息。但要注意：

  • 如果你的WebJob是多实例部署的，这个锁只在单个进程内有效，跨实例的重复处理还得靠上面说的ServiceBus重复检测。
  • 如果你用的是WebJobs SDK v3及以上版本，Singleton的配置略有不同，要确保你用的特性是Microsoft.Azure.WebJobs.SingletonAttribute，而不是旧版本的。

• 让消息处理逻辑实现幂等性
  这是最后的兜底方案，毕竟再完善的机制也可能有意外。你可以在处理消息前，先通过MessageId检查业务系统里是否已经处理过这条消息：

  // 伪代码示例
  var messageId = message.MessageId;
  if (await scope.Resolve<IRepository>().HasMessageBeenProcessed(messageId))
  {
      logger.WriteLine($"Message {messageId} already processed, skipping.");
      await message.CompleteAsync();
      return;
  }
  // 执行正常的消息处理逻辑
  

  这样就算消息被重复推送到WebJob，也不会重复执行业务操作，保证最终结果一致。

• 正确处理消息的生命周期
  WebJobs SDK默认会在你的处理方法成功执行完后自动调用Complete()标记消息为已处理；如果方法抛出异常，会触发重试（次数可配置）。你要避免：

  • 在处理过程中手动调用Abandon()或者DeadLetter()除非你明确知道要这么做。
  • 不要让未捕获的异常导致消息重新回到队列，尽量用try-catch包裹核心逻辑，处理异常后手动完成消息或者移入死信队列。

内容的提问来源于stack exchange，提问作者D. Siemer