c# Saga模式和两阶段提交在c#中的实现-C#.Net教程

masstransit saga 是 c# 微服务中实现分布式事务补偿的成熟方案，通过状态机定义流转与 compensate 方法声明补偿动作，需配合持久化、幂等性及 correlationid 使用。

Saga 模式在 C# 中用 MassTransit 实现补偿逻辑

Saga 是处理长时间运行、跨服务事务的主流方案，C# 生态里最成熟的选择是 MassTransit —— 它原生支持基于状态机（StateMachineSaga）的 Saga 管理，自动持久化、幂等性、重试和补偿都内置了。

关键不是“手写事务日志”，而是定义状态流转和对应命令。比如订单创建后扣库存失败，必须触发“取消预留库存”操作，这个补偿动作由 Compensate 方法声明，不是靠 try-catch 手动调。

• 必须实现 ISagaRepository<t></t>，推荐用 EntityFrameworkSagaRepository 存到 SQL Server 或 PostgreSQL
• 每个 Saga 实体需有唯一 CorrelationId（通常用 Guid），所有消息必须携带它，否则状态无法关联
• 超时控制用 RequestTimeout + When(Timeout)，别依赖外部定时器轮询
• 不要在 When() 里直接调用 HTTP API；应发新命令（如 ReserveInventoryCommand），让下游消费者处理，保证解耦

public class OrderSaga : MassTransitStateMachine<OrderState>
{
    public State Submitted { get; private set; }
    public State InventoryReserved { get; private set; }
    public Event<SubmitOrder> SubmitOrder { get; private set; }
    public Event<InventoryReserved> InventoryReserved { get; private set; }
    public Event<InventoryReservationFailed> InventoryReservationFailed { get; private set; }
<pre class='brush:php;toolbar:false;'>public OrderSaga()
{
    InstanceState(x => x.CurrentState);

    Event(() => SubmitOrder);
    Event(() => InventoryReserved);
    Event(() => InventoryReservationFailed);

    Initially(
        When(SubmitOrder)
            .Then(ctx => ctx.Instance.OrderId = ctx.Data.OrderId)
            .TransitionTo(Submitted)
            .Send(context => new ReserveInventoryCommand(context.Instance.OrderId)));

    During(Submitted,
        When(InventoryReserved)
            .TransitionTo(InventoryReserved),
        When(InventoryReservationFailed)
            .Call(ctx => Console.WriteLine($"Rollback for {ctx.Instance.OrderId}"))
            .Compensate(ctx => new CancelInventoryReservationCommand(ctx.Instance.OrderId)));
}

}

两阶段提交（2PC）在 C# 中不推荐直接实现

.NET 原生没有跨服务 2PC 支持，System.Transactions.TransactionScope 只适用于同进程内多个 SqlConnection 或支持 MSDTC 的资源，一旦涉及 HTTP、RabbitMQ、第三方 API，它就完全失效——不是功能限制，是协议层面不兼容。

常见误用：用 TransactionScope 包住 EF Core SaveChanges 和 HttpClient.PostAsync，以为能原子提交。实际结果是数据库改了，HTTP 请求失败，没人回滚数据库。