saga-orchestration

Saga Orchestration - 分布式事务协调模式

技能概述

Saga Orchestration 是一种用于管理分布式事务和长时间运行业务流程的设计模式，通过补偿事务机制实现跨服务的数据一致性，适用于微服务架构中的多步骤业务流程协调。

适用场景

1. 订单履行与支付流程

当订单创建需要协调库存服务、支付服务、物流服务和通知服务时，Saga 模式可以确保任一步骤失败时能够自动回滚已完成的操作。例如：支付成功但物流创建失败时，自动触发退款并释放库存预留。

2. 跨服务数据同步

在微服务架构中，当需要同时更新多个服务的数据但无法使用传统数据库事务时，Saga 模式通过一系列本地事务和补偿操作实现最终一致性。适用于用户注册、权限分配、资源初始化等跨聚合操作。

3. 长时间运行的业务工作流

对于需要人工介入或外部系统响应的审批流程、供应商协作等场景，Saga 模式支持长时间运行的事务，提供超时处理、状态持久化和断点恢复能力。

核心功能

1. 灵活的编排与协作模式

支持两种 Saga 实现方式：编排模式 使用中央协调器管理流程，逻辑集中便于维护；协作模式 通过事件总线让服务间直接通信，去中心化更易扩展。可根据业务复杂度和团队技术栈选择合适方案。

2. 自动补偿与故障恢复

每个业务步骤都定义对应的补偿操作，当任何步骤失败时自动按逆序执行补偿，确保系统状态可恢复。支持幂等操作设计，允许安全重试；内置超时机制防止流程永久阻塞；完整的状态跟踪便于故障诊断。

3. 企业级事务管理能力

提供 Saga 生命周期管理（Started → Pending → Compensating → Completed/Failed），支持持久化存储防止状态丢失，可集成调度器实现超时处理。包含完整的 Python 实现模板，涵盖基础编排器、订单履行示例、协作式实现和超时处理等常见需求。

常见问题

Saga 模式和传统两阶段提交(2PC)有什么区别？

Saga 模式采用补偿机制而非锁定资源，各步骤使用本地事务提交，不长时间锁定数据库资源，更适合互联网高并发场景。但 Saga 只保证最终一致性而非强一致性，存在短暂的数据不一致窗口。2PC 协调者单点故障风险高，而 Saga 中每个服务独立运行，容错性更好。

补偿事务如果也失败了怎么办？

补偿事务设计为幂等操作，支持多次重试。如果补偿最终无法成功，需要引入人工介入流程或记录到死信队列等待后续处理。最佳实践是：每个业务步骤的补偿操作都要经过充分测试，这是 Saga 模式最关键的部分。建议在实施前建立完善的监控和告警机制。

什么时候应该用编排模式，什么时候用协作模式？

编排模式适合业务逻辑复杂、需要集中控制流程的场景，如订单履行、支付流程等，代码集中便于理解和调试。协作模式适合服务边界清晰、希望降低服务间耦合的场景，如简单的数据同步流程。实践中可以从协作模式开始，当流程复杂度增加时再迁移到编排模式。