MassTransit长耗时消息完成时触发MessageLockExpiredException问题

问题分析 #

核心问题出在两点：

1. Azure Service Bus锁时长限制：标准层队列/订阅的LockDuration最大仅支持5分钟，高级层最大15分钟，你设置的30分钟会被服务端自动截断，实际锁时长远低于预期。
2. 配置继承问题：全局配置的MaxAutoRenewDuration和LockDuration未被ConfigureEndpoints创建的端点正确继承，续期逻辑未按预期生效。

解决方案 #

1. 修正符合Azure限制的锁配置 #

根据你的Service Bus层级设置合法的锁时长，同时确保MaxAutoRenewDuration大于最长消息处理时长。

2. 确保配置应用到每个端点 #

在ConfigureEndpoints中显式为每个端点指定锁参数，避免全局配置被覆盖。

修改后的配置代码：

x.UsingAzureServiceBus((context, cfg) =>
{
    cfg.Host(hostContext.Configuration["AzureServiceBus_ConnectionString"]);
    cfg.UseConsumeFilter(typeof(ConsumeContextFilter<>), context);

    // 全局默认续期时长，需覆盖最长消息处理时间
    cfg.MaxAutoRenewDuration = TimeSpan.FromMinutes(30);

    // 为每个端点配置锁参数（标准层用5分钟，高级层可改为15分钟）
    cfg.ConfigureEndpoints(context, (endpointName, epConfig) =>
    {
        epConfig.LockDuration = TimeSpan.FromMinutes(5);
        epConfig.MaxAutoRenewDuration = TimeSpan.FromMinutes(30);
    });
});

额外检查项 #

• 消息处理逻辑必须使用异步模式（async/await），避免主线程长时间阻塞导致续期任务无法执行。
• 检查网络连接稳定性，续期操作需要与Azure Service Bus保持通信，短暂断网可能导致续期失败。

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