同一Outbox Publishing代码在不同控制器表现异常问题排查

执行以下代码时，一个控制器能正常向InboxState/OutboxState/OutboxMessage插入数据，另一个控制器完全无反应，SQL探查器未捕获到任何查询：

await _publishEndpoint.Publish(myMessage);

查看MassTransit相关源码后，发现Outbox实体仅被添加到集合，未调用SaveChanges：

var outboxMessage = new OutboxMessage
{
    MessageId = context.MessageId.Value,
    ConversationId = context.ConversationId,
    CorrelationId = context.CorrelationId,
    InitiatorId = context.InitiatorId,
    RequestId = context.RequestId,
    SourceAddress = context.SourceAddress,
    DestinationAddress = context.DestinationAddress,
    ResponseAddress = context.ResponseAddress,
    FaultAddress = context.FaultAddress,
    SentTime = context.SentTime ?? now,
    ContentType = context.ContentType?.ToString() ?? context.Serialization.DefaultContentType.ToString(),
    Body = body.GetString(),
    InboxMessageId = inboxMessageId,
    InboxConsumerId = inboxConsumerId,
    OutboxId = outboxId
};

if (context.TimeToLive.HasValue)
    outboxMessage.ExpirationTime = now + context.TimeToLive;

if (context.Delay.HasValue)
    outboxMessage.EnqueueTime = now + context.Delay;

outboxMessage.Headers = deserializer.SerializeDictionary(context.Headers.GetAll());

if (context is TransportSendContext<T> transportSendContext)
{
    var properties = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);

    transportSendContext.WritePropertiesTo(properties);
    outboxMessage.Properties = deserializer.SerializeDictionary(properties);
}

await collection.AddAsync(outboxMessage, context.CancellationToken).ConfigureAwait(false);

核心原因：事务上下文差异 #

MassTransit的EF Core Outbox机制依赖数据库事务触发SaveChanges：

• 正常工作的控制器：处于已有的事务范围内（比如ASP.NET Core自动事务、手动开启的事务），MassTransit复用该事务，事务提交时自动持久化Outbox数据。
• 失效的控制器：无事务上下文，Outbox实体仅被添加到DbContext跟踪集合，但MassTransit不会主动调用SaveChanges（避免单独提交引发一致性问题）。

解决办法 #

1. 显式开启事务 #

在控制器方法中手动创建事务，确保Outbox数据被提交：

using var transaction = await _dbContext.Database.BeginTransactionAsync();
try
{
    await _publishEndpoint.Publish(myMessage);
    await _dbContext.SaveChangesAsync();
    await transaction.CommitAsync();
}
catch
{
    await transaction.RollbackAsync();
    throw;
}

2. 配置MassTransit自动事务集成 #

注册服务时绑定Outbox与DbContext，让框架自动处理事务：

services.AddMassTransit(x =>
{
    x.AddEntityFrameworkOutbox<YourDbContext>(o =>
    {
        o.QueryDelay = TimeSpan.FromSeconds(10);
        o.UseSqlServer();
        o.UseBusOutbox();
    });

    // 其他Bus配置...
});

3. 检查DbContext生命周期 #

确认两个控制器注入的DbContext为同一Scoped实例，避免因实例隔离导致数据未被跟踪提交。

内容的提问来源于stack exchange，提问作者Imran Qadir Baksh - Baloch