使用MassTransit+Azure ServiceBus遭遇MessageLockExpiredException问题

核心问题1：接收端点配置未生效 #

你代码中的if (cfg is IServiceBusReceiveEndpointConfigurator sb)逻辑完全错误——cfg是总线工厂配置器（IServiceBusBusFactoryConfigurator），永远不可能转换为接收端点配置器（IServiceBusReceiveEndpointConfigurator），导致你设置的LockDuration、MaxDeliveryCount等关键参数根本没有应用到实际的接收端点上，消息锁还是使用Azure Service Bus的默认值（通常为60秒），自然容易过期。

核心问题2：并发参数设置过大 #

你设置的PrefetchCount = 20000和ConcurrentMessageLimit = 10000远远超出了合理范围：

• 预取2万条消息后，大量消息会在本地排队等待处理，Azure Service Bus的消息锁会在等待期间过期
• 即使开启了自动续期，Azure Service Bus对锁续期的总时长有上限（MaxAutoRenewDuration最大为5分钟），排队过久的消息依然会锁过期

修正后的配置示例 #

场景1：使用自动端点配置（配合消费者）

serviceCollection.AddMassTransit<IIntegrationEventsBus>(x =>
{
    // 添加你的消费者（如果有的话）
    x.AddConsumer<YourIntegrationEventConsumer>();

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host(fullyQualifiedNamespace);

        // 为所有自动创建的接收端点统一配置参数
        cfg.ConfigureEndpoints(context, endpointCfg =>
        {
            if (endpointCfg is IServiceBusReceiveEndpointConfigurator sbEndpoint)
            {
                sbEndpoint.MaxDeliveryCount = 3;
                sbEndpoint.LockDuration = TimeSpan.FromMinutes(5);
                sbEndpoint.MaxAutoRenewDuration = TimeSpan.FromMinutes(5);
                sbEndpoint.AutoDeleteOnIdle = TimeSpan.MaxValue;
                sbEndpoint.MaxSizeInMegabytes = 5120;
            }
        });

        // 合理调整并发参数，根据实际处理能力调整
        cfg.PrefetchCount = 200;
        cfg.ConcurrentMessageLimit = 100;

        cfg.UseMessageRetry(r => r.Immediate(2));
    });
});

场景2：手动定义接收端点

serviceCollection.AddMassTransit<IIntegrationEventsBus>(x =>
{
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host(fullyQualifiedNamespace);

        // 手动指定接收端点名称并配置参数
        cfg.ReceiveEndpoint("your-topic-subscription-name", e =>
        {
            e.MaxDeliveryCount = 3;
            e.LockDuration = TimeSpan.FromMinutes(5);
            e.MaxAutoRenewDuration = TimeSpan.FromMinutes(5);
            e.AutoDeleteOnIdle = TimeSpan.MaxValue;
            e.MaxSizeInMegabytes = 5120;

            // 绑定消费者到该端点（如果需要）
            e.Consumer<YourIntegrationEventConsumer>(context);
        });

        cfg.PrefetchCount = 200;
        cfg.ConcurrentMessageLimit = 100;

        cfg.UseMessageRetry(r => r.Immediate(2));
    });
});

额外注意事项 #

1. 如果未配置消费者但仍出现异常，检查Azure Service Bus中是否存在之前创建的残留接收端点，这些端点可能在无消费者处理的情况下持续接收消息导致锁过期
2. 若单条消息处理时间确实超过5分钟，建议拆分任务，或使用Azure Service Bus的会话（Session）机制配合更长的锁续期（需注意会话的并发限制）

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