Azure Function App重复处理Service Bus Topic消息问题排查求助

针对你遇到的[FunctionName("RequestToBizTa...")]函数在QC环境重复处理同一条消息的问题，结合你给出的信息（单次执行9-10秒、锁时长5分钟、最大重试1次、两次调用间隔仅2秒），我来梳理下可能的原因和排查方向：

可能的原因分析 #

首先可以明确锁过期不是触发重复的原因——5分钟的锁时长远大于你的函数执行时间，而且锁过期后Service Bus的重新投递间隔也不会短到2秒。下面是更可能的几个方向：

• 代码中主动提前释放了消息锁：如果你的函数代码里在处理完成前就调用了AbandonAsync()，或者错误地调用了CompleteAsync()后又出现异常，Service Bus会立即将消息重新投入队列，导致短时间内重复触发。
• 函数宿主意外重启：如果QC环境的Function App宿主在执行过程中突然重启（比如资源限制导致的回收、配置更新触发的重启），未完成的消息锁会被Service Bus自动释放，进而快速重新投递。
• Service Bus订阅的并发配置问题：如果host.json中extensions.serviceBus.maxConcurrentCalls设置大于1，虽然PeekLock模式理论上不会让同一个消息被多个实例拾取，但极端情况下（比如锁续期延迟）可能出现异常并发拾取的情况。
• 未捕获的异常导致锁未正确维持：如果函数执行中出现未捕获的致命异常，宿主进程可能直接终止，导致锁无法正常续期或释放，Service Bus会判定客户端离线，快速重新投递消息。
• QC环境网络波动：短暂的网络中断会让Service Bus认为你的Function客户端离线，进而释放消息锁并重新投递，这种情况在测试环境中偶尔会出现。

具体排查步骤 #

1. 检查函数代码逻辑
   仔细排查代码中对Service Bus消息的处理：

   • 有没有提前调用AbandonAsync()的逻辑？比如某些分支条件下直接放弃消息。
   • 确认只有在业务逻辑完全处理完成后才调用CompleteAsync()，避免中途完成后又出现异常导致消息被重新投递。

2. 查看宿主和函数日志

   • 检查Function App的宿主日志，看两次调用之间是否有Host started或Host shutdown的记录，确认是否存在宿主重启的情况。
   • 查看函数的执行日志，确认两次调用处理的是否是同一条消息（通过消息的MessageId或CorrelationId判断），以及第一次调用是否出现了未捕获的异常。

3. 验证Service Bus和Function配置

   • 检查host.json中的Service Bus配置：

     {
       "extensions": {
         "serviceBus": {
           "maxConcurrentCalls": 1,
           "autoRenewTimeout": "00:04:30" // 默认是锁时长的90%，对应5分钟锁时长的续期设置
         }
       }
     }
     

     尝试将maxConcurrentCalls设为1，排除并发拾取的可能。
   • 确认Service Bus订阅的最大重试次数配置是否生效，查看重复消息的DeliveryCount属性，第二次调用时这个值应该是2（如果是Service Bus重新投递）。

4. 开启Service Bus诊断日志
   在Azure Portal中开启Service Bus的诊断日志，查看消息的投递记录，确认是Service Bus主动发起的重新投递，还是Function被重复触发，这能帮你定位问题出在服务端还是客户端。

临时解决建议 #

• 先将maxConcurrentCalls设为1，观察是否还会出现重复处理的情况。
• 在函数中添加对MessageId的日志记录，方便快速确认是否是同一条消息被重复处理。
• 完善异常处理逻辑，确保所有异常都被捕获并正确处理，避免宿主进程意外终止。

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