咨询NServiceBus中跨Saga实现补偿事务的最佳实践

云原生阿岚

2026-5-28

NServiceBus Saga补偿事务最佳实践（BookHotel场景）

作为有多年NServiceBus Saga实战经验的开发者，我来分享下针对你这个BookHotel场景的补偿事务建模思路，以及为什么不推荐拆分单独的Unbook Saga~

核心原则：让原Saga负责全生命周期的正向执行与反向补偿

你的初始思路是调用另一个UnbookHotelSaga来处理补偿，这种方式并非完全不可行，但会引入状态同步、消息协调等额外复杂度。更优的方案是让BookHotelSaga自己跟踪整个流程的状态，同时处理正向预订和反向补偿——毕竟Saga的核心价值就是跟踪长流程的状态变迁，补偿本身就是这个流程的一部分。

具体实现步骤

1. 定义包含完整状态的Saga数据

首先要给BookHotelSaga定义足够的状态字段，用来记录每个环节的执行结果，这样Saga才能清楚知道哪些资源需要补偿：

public class BookHotelSagaData : ContainSagaData
{
    // 核心业务状态
    public bool IsHotelBooked { get; set; }
    public bool IsFlightBooked { get; set; }
    public bool IsRentalBooked { get; set; }
    
    // 各环节的业务ID，用于补偿
    public string HotelBookingId { get; set; }
    public string FlightBookingId { get; set; }
    public string RentalBookingId { get; set; }
    
    // 发起方标识，用于最终回复
    public string InitiatorId { get; set; }
}

2. 正向流程的处理（原流程优化）

先修正下原流程的逻辑顺序（正常应该先完成酒店预订，再触发航班/租车）：

收到BookHotelCommand后，BookHotelSaga先完成酒店预订，记录HotelBookingId并标记IsHotelBooked = true
发送BookFlightCommand，等待IFlightBookedMessage回复
收到航班预订确认后，记录FlightBookingId并标记IsFlightBooked = true，再发送BookRentalCommand
收到租车预订确认后，标记IsRentalBooked = true，最终回复HotelBookedMessage给发起方

3. 补偿流程的触发与执行

当租车环节触发补偿条件（比如预订失败、业务规则不满足），BookHotelSaga收到对应的失败信号（比如IRentalBookingFailedMessage），就开始按逆序执行补偿：

检查IsFlightBooked：如果为true，发送UnbookFlightCommand（携带FlightBookingId），等待IUnbookFlightMessage
收到航班取消确认后，检查IsHotelBooked：如果为true，发送UnbookHotelCommand（携带HotelBookingId），等待IUnbookHotelMessage
所有补偿步骤完成后，回复HotelBookingCancelledMessage给发起方

4. 关键细节优化

幂等性设计：所有命令（包括补偿命令）必须实现幂等。比如UnbookFlightCommand带上唯一的FlightBookingId，即使重复执行，航班服务也只会处理一次取消请求。
重试与告警：给补偿命令配置合理的重试策略（比如3次重试），如果最终失败，发送告警消息到运维系统，触发人工介入——毕竟补偿操作也可能遇到异常（比如航班已无法取消）。
Outbox模式：开启NServiceBus的Outbox功能，确保Saga的状态更新和消息发送是原子操作，避免出现"状态已标记为取消，但补偿命令没发出去"的部分成功情况。

为什么不推荐拆分单独的Unbook Saga？

状态分散风险：原Saga和补偿Saga需要同步流程状态，容易出现信息不一致（比如原Saga认为航班已取消，但补偿Saga没记录）。
上下文传递成本：补偿需要用到的HotelBookingId、FlightBookingId等上下文，需要额外通过消息传递给补偿Saga，增加了消息体积和出错概率。
流程复杂度提升：两个Saga之间的协调需要额外的消息交互，排查问题时需要跨Saga追踪流程，增加了维护成本。

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