如何让ServiceBus纳入Transaction Scope事务范围？

核心思路：用本地消息表（Outbox模式）替代内存暂存 #

这种方式不需要依赖复杂的分布式事务组件，只用本地数据库事务+定时任务就能解决问题，是.NET Framework环境下最容易落地的方案。

具体实现步骤 #

1. 新增消息记录表
   在你的数据库里加一张OutboxMessages表，字段至少包含：

• MessageId（唯一主键，用GUID）
• MessageContent（JSON格式的事件内容）
• MessageType（标记是EventA还是EventB）
• Status（枚举：待发送/已发送/失败）
• CreatedTime（创建时间）
• 可选：RetryCount（重试次数）、ErrorMessage（失败信息）

2. 修改事务内的操作逻辑
   把原来直接发布ServiceBus事件的代码，改成向OutboxMessages表插入记录，和其他数据库写操作放在同一个TransactionScope里：

using (var scope = new TransactionScope(TransactionScopeOption.Required))
{
    // 第一个数据库写操作
    dbContext.Table1.Add(new Table1Entity());
    dbContext.SaveChanges();

    // 把EventA存入消息表，代替直接发布
    dbContext.OutboxMessages.Add(new OutboxMessage
    {
        MessageId = Guid.NewGuid().ToString(),
        MessageContent = JsonConvert.SerializeObject(eventA),
        MessageType = "EventA",
        Status = OutboxMessageStatus.Pending,
        CreatedTime = DateTime.UtcNow
    });
    dbContext.SaveChanges();

    // 第二个数据库写操作
    dbContext.Table2.Add(new Table2Entity());
    dbContext.SaveChanges();

    // 把EventB存入消息表，代替直接发布
    dbContext.OutboxMessages.Add(new OutboxMessage
    {
        MessageId = Guid.NewGuid().ToString(),
        MessageContent = JsonConvert.SerializeObject(eventB),
        MessageType = "EventB",
        Status = OutboxMessageStatus.Pending,
        CreatedTime = DateTime.UtcNow
    });
    dbContext.SaveChanges();

    // 提交事务：只有所有数据库操作成功，消息记录才会保留
    scope.Complete();
}

3. 实现后台定时任务处理消息
   写一个独立的后台任务（可以用Windows服务、控制台程序的Timer，甚至SqlServer作业），定期拉取OutboxMessages里的待发送消息，调用ServiceBus发布接口：

// 示例：每30秒执行一次的消息处理逻辑
public void ProcessPendingMessages()
{
    using (var dbContext = new MyDbContext())
    {
        // 批量拉取待发送消息，加READPAST避免锁竞争（SqlServer适用）
        var pendingMsgs = dbContext.OutboxMessages
            .Where(m => m.Status == OutboxMessageStatus.Pending)
            .Take(100)
            .ToList();

        foreach (var msg in pendingMsgs)
        {
            try
            {
                // 根据消息类型反序列化并发布
                if (msg.MessageType == "EventA")
                {
                    var eventA = JsonConvert.DeserializeObject<EventA>(msg.MessageContent);
                    _serviceBusClient.Publish(eventA, msg.MessageId); // 把MessageId传给ServiceBus做幂等
                }
                else if (msg.MessageType == "EventB")
                {
                    var eventB = JsonConvert.DeserializeObject<EventB>(msg.MessageContent);
                    _serviceBusClient.Publish(eventB, msg.MessageId);
                }

                // 发布成功，标记为已发送
                msg.Status = OutboxMessageStatus.Sent;
                msg.SentTime = DateTime.UtcNow;
            }
            catch (Exception ex)
            {
                // 发布失败，标记状态并记录错误
                msg.Status = OutboxMessageStatus.Failed;
                msg.ErrorMessage = ex.Message;
                // 可选：如果重试次数没超限，改回待发送状态，后续任务自动重试
                if (msg.RetryCount < 3)
                {
                    msg.Status = OutboxMessageStatus.Pending;
                    msg.RetryCount++;
                }
            }
        }

        dbContext.SaveChanges();
    }
}

4. 消费端做幂等处理
   在ServiceBus的消费代码里，根据MessageId判断是否已经处理过这条消息，避免因为重试导致重复消费。

为什么这是最简方案？ #

• 完全基于现有技术栈（.NET Framework+本地数据库），不需要引入新组件
• 彻底解决了内存暂存的部分发送问题：只有事务提交成功，消息才会进入待发送列表
• 天然支持重试：发布失败的消息可以通过后台任务自动重试，不需要额外的重试框架

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