MassTransit 8.3.0：SQL Server Transport与EF Outbox配合异常咨询

使用MassTransit 8.3.0版本，尝试将总线Outbox与SQL Server Transport配合使用时遇到问题：消息被直接发布到SQL Transport，而非先存入配置的EF Outbox。原本期望在单个事务中保存聚合根和Outbox（保证原子性），之后由Outbox基础设施提取消息并发布到SQL Transport，但实际并未按此流程执行。

此前在Azure Service Bus传输中使用相同配置运行正常，请问Outbox功能是否不支持SQL Transport？

以下是代码配置（采用ISecondBus模式，已注释默认Azure Service Bus总线，仅针对SQL Transport配置）：

//Add SQL Transport Bus
services.AddMassTransit<ISqlTransportBus>(x =>
{
    x.AddEntityFrameworkOutbox<AdminDbContext>(o =>
    {
        o.DuplicateDetectionWindow = TimeSpan.FromSeconds(30);
        o.QueryDelay = TimeSpan.FromSeconds(2);
        o.UseSqlServer();

        o.UseBusOutbox(config =>
        {
            //config.DisableDeliveryService();
        });
    });
    x.AddSqlMessageScheduler();

    //Add Consumers
    x.AddConsumer<MyConsumer1>();

    //setup sql db transport for domain events
    x.UsingSqlServer((context, cfg) =>
    {
        cfg.UseSqlMessageScheduler();
        cfg.AutoStart = true;
        cfg.UseMessageRetry(r => r.Intervals(100, 500, 1000, 5000, 10000));
        cfg.MessageTopology.SetEntityNameFormatter(new PrefixEntityNameFormatter(
            cfg.MessageTopology.EntityNameFormatter,
            string.IsNullOrWhiteSpace(prefix) ? string.Empty : $"{prefix}"));

        cfg.Send<MyDomainEvent1>(x => { });
        cfg.ConfigureEndpoints(context, a =>
        {
            a.Include<MyConsumer1>();
        });

        
    });

});

Outbox功能完全支持SQL Server Transport，问题出在配置遗漏了关键步骤。

使用总线Outbox时，必须在传输配置中显式启用它，否则消息会直接发送到SQL Transport，不会经过Outbox。你需要在x.UsingSqlServer的配置委托中添加cfg.UseBusOutbox();，让传输层与Outbox集成。

修改后的核心配置片段：

x.UsingSqlServer((context, cfg) =>
{
    cfg.UseSqlMessageScheduler();
    cfg.AutoStart = true;
    cfg.UseMessageRetry(r => r.Intervals(100, 500, 1000, 5000, 10000));
    // 启用总线Outbox，这是关键遗漏项
    cfg.UseBusOutbox();
    cfg.MessageTopology.SetEntityNameFormatter(new PrefixEntityNameFormatter(
        cfg.MessageTopology.EntityNameFormatter,
        string.IsNullOrWhiteSpace(prefix) ? string.Empty : $"{prefix}"));

    cfg.Send<MyDomainEvent1>(x => { });
    cfg.ConfigureEndpoints(context, a =>
    {
        a.Include<MyConsumer1>();
    });
});

额外检查点：

• 确认AdminDbContext已通过EF迁移生成Outbox所需的数据库表
• 确保保存聚合根和发送消息的逻辑在同一个事务中执行（比如使用事务范围或DbContext事务）

修改后，消息会先存入Outbox，事务提交后由Outbox投递服务提取并发送到SQL Transport，保证操作原子性。

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