MassTransit+Azure Service Bus延迟重投递遇TTL过期错误排查

问题描述 #

使用MassTransit 8.3.6搭配Azure Service Bus时，启用延迟重投递功能遇到以下问题：

• 队列未提前创建时，消息一入队就触发TTL过期错误：

  MassTransit.MessageTimeToLiveExpiredException: sb://providerappapiv2.servicebus.windows.net/note => The message expired: ac5a0000da2bb05c4b6f08dd5518d768

• 队列提前创建时，消息能正常执行即时重试，但延迟重投递功能完全失效
• 移除e.UseDelayedRedelivery(r => r.Intervals(...))配置后，所有功能恢复正常

相关配置代码：

services.AddMassTransit(x =>
{
    x.SetKebabCaseEndpointNameFormatter();

    x.AddConsumer<NoteConsumer>();

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host(config.GetConnectionString("AzureServiceBus"));

        cfg.UseServiceBusMessageScheduler();

        cfg.ReceiveEndpoint("note", e =>
        {
            e.DefaultMessageTimeToLive = TimeSpan.FromDays(14);
            e.EnableDeadLetteringOnMessageExpiration = true;
            e.MaxDeliveryCount = 15;
            e.DuplicateDetectionHistoryTimeWindow = TimeSpan.FromMinutes(10);
            e.MaxSizeInMegabytes = 5120;
            e.RequiresDuplicateDetection = true;

            e.UseDelayedRedelivery(r => r.Intervals(TimeSpan.FromMinutes(1), TimeSpan.FromMinutes(15), TimeSpan.FromMinutes(30)));
            e.UseMessageRetry(r => r.Intervals(TimeSpan.FromSeconds(2), TimeSpan.FromSeconds(8)));

            if (e is IServiceBusReceiveEndpointConfigurator sb)
            {
                sb.ConfigureDeadLetterQueueDeadLetterTransport();
                sb.ConfigureDeadLetterQueueErrorTransport();
            }

            e.ConfigureConsumer<NoteConsumer>(context);
        });

        cfg.ConfigureEndpoints(context);
    });

    x.AddMediator(cfg =>
    {
        //...
    });
});

问题原因 #

1. 中间件顺序错误：延迟重投递中间件被放在了即时重试中间件之前，导致逻辑执行顺序颠倒——本该先做快速即时重试，失败后再触发延迟重投递，现在变成先进入延迟流程，再执行即时重试，直接打乱了MassTransit的重试逻辑，不仅导致延迟重投递失效，还可能在队列自动创建时引发TTL异常。
2. 队列自动创建时锁时长不足：Azure Service Bus队列默认LockDuration为60秒，而设置的第一个延迟间隔刚好是1分钟，消息在计划延迟重投递的过程中，锁会提前过期，被Service Bus判定为消息过期。
3. 死信队列配置冲突：自定义死信队列的路由配置，在队列自动创建时可能干扰了延迟重投递的消息流转逻辑，导致消息被错误标记为过期。

解决办法 #

1. 调整中间件顺序 #

将即时重试放在延迟重投递之前，恢复正确的逻辑执行顺序：

// 先配置即时快速重试
e.UseMessageRetry(r => r.Intervals(TimeSpan.FromSeconds(2), TimeSpan.FromSeconds(8)));
// 再配置延迟重投递
e.UseDelayedRedelivery(r => r.Intervals(TimeSpan.FromMinutes(1), TimeSpan.FromMinutes(15), TimeSpan.FromMinutes(30)));

2. 延长队列锁时长 #

显式设置LockDuration为大于最大延迟间隔的值，避免锁过期问题：

e.LockDuration = TimeSpan.FromMinutes(35); // 比最大延迟间隔30分钟多5分钟

3. 调整死信队列配置（可选） #

如果不需要自定义死信路由，直接移除以下代码，避免冲突：

// if (e is IServiceBusReceiveEndpointConfigurator sb)
// {
//     sb.ConfigureDeadLetterQueueDeadLetterTransport();
//     sb.ConfigureDeadLetterQueueErrorTransport();
// }

如果必须保留死信配置，确保死信队列的DefaultMessageTimeToLive设置足够长，至少覆盖延迟重投递的总时长。

4. 手动创建队列（可选） #

若提前手动创建队列，需确保队列配置包含：

• LockDuration ≥ 最大延迟间隔
• DefaultMessageTimeToLive ≥ 所有延迟间隔之和 + 处理时长
• 启用计划消息（默认启用）
  然后在MassTransit配置中禁用自动创建队列：

e.CreateQueue = false;

验证步骤 #

1. 按照上述调整配置后，删除已存在的note队列
2. 重启服务，让MassTransit自动创建队列
3. 触发消息处理失败，检查是否按预期执行即时重试，之后进入延迟重投递
4. 查看日志，确认TTL过期异常不再出现

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