NServiceBus Handler重复执行问题求助（附配置与处理器代码）

核心原因分析 #

结合你的配置与代码，重复消费的主要诱因集中在以下几点：

1. 事务配置缺失
   你注释掉了transport.Transactions(TransportTransactionMode.TransactionScope)，Azure Service Bus默认采用PeekLock模式获取消息：若未在锁超时前完成处理并确认，服务总线会自动释放锁，将消息重新放回队列，触发重复消费。

2. 空catch块吞掉异常
   处理器中的空catch(Exception exception){}会掩盖所有错误，NServiceBus无法感知处理失败，既不会主动确认消息（从队列移除），也不会将消息移至错误队列。一旦处理出现延迟或异常，锁过期后消息会被重新分发。

3. 锁时长未适配长耗时操作
   DoSomeAction包含API调用与数据库存储，若执行时间超过Azure Service Bus默认的60秒锁时长，锁会自动释放，消息会被重新投入队列。

分步解决方案 #

1. 启用合适的事务模式 #

针对Azure Service Bus，推荐启用ReceiveOnly事务模式（无需分布式事务场景），确保消息仅在处理成功后才从队列移除：

var transport = endpointConfiguration.UseTransport<AzureServiceBusTransport>();
transport.ConnectionString(GetTransportConnectionString(configuration));
// 启用接收级事务，保证消息处理成功后再确认
transport.Transactions(TransportTransactionMode.ReceiveOnly);

2. 修复异常处理逻辑 #

移除空catch块，让NServiceBus处理失败场景，或手动控制错误行为：

public async Task Handle(SomeCommand message, IMessageHandlerContext context)
{
    try
    {   
        await DoSomeAction(message, context);
    }
    catch(Exception exception)
    {
        // 可选：添加错误日志记录
        // _logger.LogError(exception, "处理SomeCommand失败");
        // 重新抛出异常，让NServiceBus将消息移至错误队列
        throw;
        // 或手动标记失败：await context.Fail(exception);
    }
}

3. 调整锁时长与自动续锁 #

针对长耗时的DoSomeAction，延长锁时长并启用自动续锁，避免锁过期：

var transport = endpointConfiguration.UseTransport<AzureServiceBusTransport>();
// 根据实际处理时间设置锁时长，示例为5分钟
transport.LockDuration(TimeSpan.FromMinutes(5));
// 启用自动续锁，续锁超时设置为略短于锁时长
transport.AutoRenewTimeout(TimeSpan.FromMinutes(4));

4. 优化并发设置（可选） #

若为多实例部署，合理限制并发消费数，避免资源竞争导致处理延迟：

// 根据系统资源调整最大并发消费者数量
endpointConfiguration.LimitMessageProcessingConcurrencyTo(5);

额外建议 #

• 为业务逻辑添加幂等性校验：通过消息ID或业务唯一标识判断是否已处理，即使重复消费发生也能保证最终一致性。
• 监控Azure Service Bus的死信队列与错误队列，及时排查重复消费的深层根源。

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