MassTransit配置延迟重投递失效：重试后立即无限重发

我在基于MassTransit和RabbitMQ的应用中做了如下配置，期望消息先重试2次，之后延迟30秒再重投递：

builder.Services.AddMassTransit(busCfg =>
{
    busCfg.AddConsumers(assemblies: Assembly.GetEntryAssembly());

    busCfg.AddConfigureEndpointsCallback((context, name, cfg) =>
    {
        cfg.UseDelayedRedelivery(r => r.Intervals(TimeSpan.FromSeconds(30)));
        cfg.UseMessageRetry(r => r.Immediate(2));
    });

    busCfg.UsingRabbitMq((context, cfg) =>
    {
        cfg.ConfigureEndpoints(context);
    });
});

消费者代码会抛出异常：

public class MyMessageConsumerConsumer : IConsumer<MyMessage>
{
    private readonly ILogger<MyMessageConsumerConsumer> _logger;

    public MyMessageConsumerConsumer(ILogger<MyMessageConsumerConsumer> logger) => _logger = logger;

    public Task Consume(ConsumeContext<MyMessage> context)
    {
        _logger.LogInformation("Consumed by MyMessageConsumerConsumer!");

        throw new NotImplementedException();
    }
}

发送消息的代码：

var msg = new MyMessage() { MyProperty = "Test" };

await _publishEndpoint.Publish(msg);

原本期望消息在30秒后进行重投递，但完成首次3次（含初始消费）尝试后，消费者被立即且无限次调用！请问问题出在哪里？

核心问题：中间件注册顺序错误 #

MassTransit的中间件是按注册顺序执行的，你当前先注册了UseDelayedRedelivery，再注册UseMessageRetry，这会导致：

1. 本地重试逻辑（UseMessageRetry）不会生效，因为延迟重投递逻辑先捕获了异常
2. 延迟重投递执行后，若消息再次消费失败，由于没有配置错误队列，消息会被重新放回原队列，触发无限循环消费

修正后的配置 #

调整中间件顺序，先注册本地重试，再注册延迟重投递，同时添加消息调度器支持延迟功能，以及配置错误队列避免无限循环：

builder.Services.AddMassTransit(busCfg =>
{
    busCfg.AddConsumers(assemblies: Assembly.GetEntryAssembly());

    // 添加消息调度器，支持延迟重投递
    busCfg.AddMessageScheduler(new Uri("queue:scheduler"));

    busCfg.AddConfigureEndpointsCallback((context, name, cfg) =>
    {
        // 先注册本地立即重试2次
        cfg.UseMessageRetry(r => r.Immediate(2));
        // 再注册延迟重投递，间隔30秒
        cfg.UseDelayedRedelivery(r => r.Intervals(TimeSpan.FromSeconds(30)));
        // 配置错误队列，最终失败的消息进入死信队列
        cfg.UseDeadLetterQueue();
    });

    busCfg.UsingRabbitMq((context, cfg) =>
    {
        // 配置消息调度器端点
        cfg.ConfigureMessageScheduler(new Uri("queue:scheduler"));
        cfg.ConfigureEndpoints(context);
    });
});

配置说明 #

• UseMessageRetry 在前：先执行本地2次立即重试，加上初始消费共3次尝试
• UseDelayedRedelivery 在后：本地重试全部失败后，将消息延迟30秒重新投递
• UseDeadLetterQueue：若延迟重投递后仍然失败，消息会进入死信队列，避免无限循环
• 消息调度器：RabbitMQ需要消息调度器来支持延迟消息功能，必须添加对应的配置

验证效果 #

修正配置后，消息的消费流程变为：

1. 初始消费抛出异常
2. 立即重试2次（共3次尝试）
3. 3次尝试失败后，消息被延迟30秒重新投递
4. 若延迟投递后消费仍失败，消息进入死信队列，停止重复消费

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