添加UseEntityFrameworkOutbox后MassTransit UseScheduledRedelivery失效

1. 为何添加Outbox后重发失效？ #

核心原因是中间件层级与异常传播路径冲突：

• 当在EndpointConfigurator上添加UseEntityFrameworkOutbox时，Outbox会成为管道的外层中间件，包裹所有消费者逻辑。
• 原本在ConsumerConfigurator上配置的UseScheduledRedelivery属于内层中间件，消费者抛出的异常会先被外层的Outbox捕获：Outbox会回滚事务，并直接将消息标记为处理失败转入Fault队列，内层的重发中间件根本没机会拦截异常触发重发。

另外，原重发策略仅按异常类型匹配，未精准定位PostgreSQL并发更新的特定异常（SqlState=40001），可能导致部分符合条件的异常被遗漏。

2. 中间件的正确配置顺序 #

是的，必须严格遵循外层包裹内层的顺序：

• 先在EndpointConfigurator上配置UseScheduledRedelivery（让重发逻辑处于管道最外层）
• 再配置UseEntityFrameworkOutbox（让Outbox处于重发逻辑的内层）

这样异常从消费者抛出后，会先被外层的重发中间件捕获，触发定时重发流程，而非直接被Outbox拦截。

3. Outbox与定时重发的已知交互问题 #

MassTransit官方明确指出两者的交互核心是事务边界：

• 若Outbox处于重发逻辑外层，异常会被Outbox的事务回滚逻辑拦截，导致重发失效
• Inbox的幂等性机制可配合重发逻辑：事务回滚后Inbox记录不会留存，因此每次重发都会重新处理消息，不会出现幂等冲突

修正后的配置代码 #

消费者定义（调整中间件顺序与层级）

public class BatchHoldConsumerDefinition : ConsumerDefinition<BatchHoldConsumer>
{
    protected override void ConfigureConsumer
    (
        IReceiveEndpointConfigurator endpointConfigurator,
        IConsumerConfigurator<BatchHoldConsumer> consumerConfigurator,
        IRegistrationContext context
    )
    {
        // 先配置重发（外层），再配置Outbox（内层）
        endpointConfigurator.UseScheduledRedelivery(r => r.ApplyRedeliveryDefaultStrategy());
        endpointConfigurator.UseEntityFrameworkOutbox<WalletDbContext>(context);
    }
}

重发策略（精准匹配PostgreSQL并发异常）

public static void ApplyRedeliveryDefaultStrategy(this IRetryConfigurator r, TimeSpan[]? intervals = null)
{
    var redeliveryIntervals = intervals ?? [TimeSpan.FromSeconds(3), TimeSpan.FromSeconds(3), TimeSpan.FromSeconds(3)];
    r.Ignore<MyException>();
    
    // 精准匹配PostgreSQL并发更新异常（SqlState=40001）
    r.Handle<InvalidOperationException>(ex => 
        ex.InnerException is DbUpdateException dbEx && 
        dbEx.InnerException is Npgsql.PostgresException pgEx && 
        pgEx.SqlState == "40001");
    
    r.Handle<DbUpdateException>(ex => 
        ex.InnerException is Npgsql.PostgresException pgEx && 
        pgEx.SqlState == "40001");
    
    r.Intervals(redeliveryIntervals);
}

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