Mass Transit集成EF Core Outbox时消息无法持久化及发布问题

核心问题1：拦截器触发时机错误 #

你使用的SaveChangesCompletedEventData拦截器，是在EF Core保存完成、事务提交后才执行的逻辑。而MassTransit的EF Outbox需要在事务提交前将消息写入Outbox表，才能保证和业务数据的原子性，这直接导致消息无法被关联到事务，自然不会写入Outbox表。

修复：改用SaveChangesStartingEventData #

修改拦截器的重写方法：

public override async ValueTask<int> SavedChangesAsync(SaveChangesStartingEventData eventData, CancellationToken cancellationToken = default)
{
    var context = eventData.Context;
    if (context is null)
        return await base.SavedChangesAsync(eventData, cancellationToken);

    var events = context.ChangeTracker
        .Entries<AggregateRoot>()
        .Select(a => a.Entity)
        .Where(e => e.GetDomainEvents() is not null)
        .SelectMany(e =>
        {
            var domainEvents = e.GetDomainEvents();
            e.ClearDomainEvents();
            return domainEvents;
        });

    // 使用当前DbContext关联的Outbox发布端点
    var outboxPublishEndpoint = context.GetOutboxPublishEndpoint();
    foreach(var domainEvent in events)
        await outboxPublishEndpoint.Publish(domainEvent, cancellationToken);

    return await base.SavedChangesAsync(eventData, cancellationToken);
}

核心问题2：未使用Outbox关联的发布端点 #

你之前直接注入全局的IPublishEndpoint发布消息，这个端点不会自动将消息纳入当前DbContext的Outbox事务。必须使用从当前DbContext获取的IOutboxPublishEndpoint，它会自动把消息写入Outbox表并绑定到当前事务。

额外检查项 #

• 数据库迁移：执行Add-Migration AddOutboxTables和Update-Database，确保AddTransactionalOutboxEntities()生成的OutboxMessage、OutboxState等表已在数据库中创建。
• DbContext生命周期：确认SomeDbContext是Scoped模式注册，和MassTransit Outbox的依赖生命周期保持一致。
• 消费者端Outbox可暂时移除：你在AddConfigureEndpointsCallback中给接收端点配置的Outbox是消费端去重用的，和当前发布端问题无关，可先注释以简化排查。

验证方式 #

修改后执行业务操作，查看数据库OutboxMessage表是否有新增记录，MassTransit会在事务提交后自动异步发布这些消息。

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