同进程多Web应用运行MassTransit事务性Outbox异常排查

核心原因是同一进程内多个MassTransit总线实例共享了Outbox的静态配置缓存，导致所有应用都读取第一个初始化的SUBSCRIPTIONS应用的outbox_state表Schema，而非自身DbContext指定的Schema。

1. 显式为每个应用的Outbox指定Schema #

在AddEntityFrameworkOutbox配置中，显式设置Schema属性，强制MassTransit使用当前应用DbContext对应的Schema：

busConfigurator.AddEntityFrameworkOutbox<DatabaseContext>(o =>
{
    o.UsePostgres();
    o.UseBusOutbox();
    // 绑定当前应用的专属Schema
    o.Schema = InfrastructureConstants.Schema;
});

2. 为每个总线实例设置唯一名称 #

同一进程内的多个MassTransit总线需要通过唯一名称隔离，避免静态缓存冲突：

busConfigurator.UsingRabbitMq((context, rabbitCfg) =>
{
    rabbitCfg.ConfigureJsonSerializerOptions(jsonSerializerOptions =>
    {
        jsonSerializerOptions.ConfigureForNodaTime(new NodaJsonSettings());
        return jsonSerializerOptions;
    });

    rabbitCfg.Host(connectionUri);
    // 设置与应用Schema对应的唯一总线名称
    rabbitCfg.BusInstanceName = $"{InfrastructureConstants.Schema}_bus";
    rabbitCfg.ConfigureEndpoints(context);
});

3. 确认DbContext的Schema配置有效性 #

确保每个应用的DatabaseContext在OnModelCreating中优先设置默认Schema，让Outbox实体继承该Schema：

protected override void OnModelCreating(ModelBuilder builder)
{
    // 必须优先设置默认Schema，确保所有实体（包括Outbox）绑定到当前应用Schema
    builder.HasDefaultSchema(InfrastructureConstants.Schema);
    
    builder.ApplyConfigurationsFromAssembly(Assembly.GetExecutingAssembly());
    
    builder.AddTransactionalOutboxEntities();
    
    base.OnModelCreating(builder);
}

4. 调整启动时的消息发布逻辑 #

确保发布消息时，Outbox操作与当前DbContext的事务强绑定，避免跨Schema的缓存干扰：

app.Lifetime.ApplicationStarted.Register(async () =>
{
    using var scope = app.Services.CreateScope();
    var publishEndpoint = scope.ServiceProvider.GetRequiredService<IPublishEndpoint>();
    var dbContext = scope.ServiceProvider.GetRequiredService<DatabaseContext>();
    
    using var transaction = await dbContext.Database.BeginTransactionAsync();
    try
    {
        await publishEndpoint.Publish(new RefreshPlans());
        await dbContext.SaveChangesAsync();
        await transaction.CommitAsync();
    }
    catch
    {
        await transaction.RollbackAsync();
        throw;
    }
});

1. 启动所有应用后，检查日志确认Outbox查询使用的是自身Schema下的outbox_state表
2. 触发IDENTITY应用的消息发布，验证消息存入identity.outbox_state后可被正确读取并投递到RabbitMQ
3. 确认SUBSCRIPTIONS应用的消息仍正常从subscriptions.outbox_state读取和投递

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