使用IServiceScopeFactory创建IPublishEndpoint结合Bus Outbox无法发消息

核心原因 #

当启用UseBusOutbox()时，MassTransit会为当前请求/作用域绑定专属的Outbox上下文。你手动创建新的AsyncScope后，该作用域内的IPublishEndpoint并未关联到当前DbContext的Outbox，导致消息既不会写入Outbox表，也不会被发布。

可行解决方案 #

1. 在DbContext中直接使用当前作用域的IServiceProvider

不要手动创建新作用域，DbContext本身处于请求作用域内，注入IServiceProvider后直接获取关联Outbox的IPublishEndpoint：

public class SetupDbContext : DbContext
{
    private readonly IServiceProvider _serviceProvider;

    public SetupDbContext(DbContextOptions<SetupDbContext> options, IServiceProvider serviceProvider)
        : base(options)
    {
        _serviceProvider = serviceProvider;
    }

    public override async Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
    {
        // 这里插入你的审计信息捕获逻辑
        var auditInfo = CaptureAuditData();

        // 从当前作用域获取关联Outbox的IPublishEndpoint
        var publishEndpoint = _serviceProvider.GetRequiredService<IPublishEndpoint>();
        await publishEndpoint.Publish(auditInfo, cancellationToken);

        return await base.SaveChangesAsync(cancellationToken);
    }

    private AuditContract CaptureAuditData()
    {
        // 实现你的审计数据捕获逻辑
        return new AuditContract
        {
            // 填充字段
        };
    }
}

2. 控制器中避免手动创建作用域

测试时直接使用当前请求作用域的IPublishEndpoint，无需手动创建新作用域：

[Authorize]
[HttpPost()]
public async Task<IActionResult> Create(SupplierDto model)
{
    // 直接使用注入的IPublishEndpoint，或通过DbContext的SaveChanges触发审计消息
    var pe = _serviceProvider.GetRequiredService<IPublishEndpoint>();
    await pe.Publish(new AuditContract
    {
        Action = "test",
        ChangedColumns = "test",
        Changes = "test",
        EntityName = "test",
        NewValues = "test",
        OldValues = "test",
        PrimaryKey = "test",
        TimeStamp = DateTime.Now
    });
    
    await _context.SaveChangesAsync();
    return Ok();
}

3. 确保Outbox表已生成

执行数据库迁移，确认MassTransit自动创建的OutboxMessages和OutboxState表存在，这是Outbox功能正常运行的前提。

关键注意事项 #

• 必须保证IPublishEndpoint与DbContext处于同一个作用域，跨作用域会导致Outbox关联失效。
• Web请求场景下默认使用请求作用域，无需手动创建；后台任务场景需显式创建作用域并确保Outbox配置正确。
• 保留UseBusOutbox()配置，它会自动处理消息的原子性（与DbContext事务绑定）和重试逻辑。

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