如何在MassTransit消费者作用域中使用BusOutbox？

问题背景 #

初始配置的问题 #

使用RabbitMQ配置Bus时，初始配置如下：

busConfigurator.AddEntityFrameworkOutbox<MyDbContext>(o =>
{
    o.UsePostgres();
    o.UseBusOutbox();
});

该配置在控制器中表现正常：调用_dbContext.SaveChangesAsync()后，消息会通过Outbox发送。但在消费者或其依赖服务中，消息会直接发送至消息Broker，即使抛出异常也无法回滚。

添加消费者Outbox配置后的问题 #

添加消费者Outbox配置后：

busConfigurator.AddConfigureEndpointsCallback((context, name, cfg) =>
{
    cfg.UseEntityFrameworkOutbox<MyDbContext>(context);
});

异常时消息不再发送，但Consume方法被自动包裹在事务中——即使未调用_dbContext.SaveChangesAsync()，消息仍会通过Outbox发送，不符合预期。

需求 #

在消费者中实现BusOutbox的行为：仅在**显式调用_dbContext.SaveChangesAsync()**时原子发送消息，且不希望Consume方法被事务包裹，使用MassTransit 8.2.0版本。

解决方案 #

调整消费者的Outbox配置，禁用自动事务并保留BusOutbox的显式提交逻辑：

busConfigurator.AddConfigureEndpointsCallback((context, name, cfg) =>
{
    cfg.UseEntityFrameworkOutbox<MyDbContext>(context, o =>
    {
        // 禁用Consume方法的自动事务包裹
        o.DisableTransaction();
        // 启用BusOutbox，确保消息仅在SaveChangesAsync时发送
        o.UseBusOutbox();
    });
});

配置说明 #

• DisableTransaction()：关闭MassTransit自动为Consume方法创建的事务，避免未调用SaveChanges时自动提交Outbox消息。
• UseBusOutbox()：保留BusOutbox核心机制，发送的消息会暂存到Outbox表中，只有当显式调用_dbContext.SaveChangesAsync()时，才会和数据库变更原子性提交并发送消息。若SaveChanges前抛出异常，Outbox消息不会被提交，也不会发送至Broker。

注意事项 #

确保消费者中注入的MyDbContext实例为Scoped生命周期，保证Outbox与当前上下文关联。

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