架构师小白

Posted on Mar 26

Saga模式：分布式事务的协调艺术

#architecture #saga #microservices

什么是Saga模式？

Saga模式是一种分布式事务管理模式，最早由1987年的一篇学术论文提出。它通过将一个长时间运行的事务拆分成多个本地事务，每个本地事务都有对应的补偿操作，以此来保证数据一致性。

与传统的两阶段提交（2PC）不同，Saga采用异步补偿的方式，避免了分布式锁带来的性能瓶颈。

Saga的工作原理

Saga模式的核心思想是将大事务拆成小事务，每个小事务都有对应的补偿操作。当某个步骤失败时，之前已执行的操作需要被逐一撤销。

Order Service -> Payment Service -> Inventory Service -> Shipping Service
     |               |                |                 |
     v               v                v                 v
  Create          Charge           Reserve          Schedule
  Order           Payment           Stock             Delivery
     |               |                |                 |
     v               v                v                 v
  Cancel (补偿)  Refund (补偿)    Release (补偿)   Cancel (补偿)

编排 vs 编舞

编舞式（Choreography）：

各服务通过事件相互调用
优点：简单，去中心化
缺点：难以追踪，测试困难

编排式（Orchestration）：

由一个中央协调器管理整个流程
优点：易于监控和调试
缺点：协调器可能成为单点故障

代码实现示例

# 编排式Saga协调器
class OrderSagaOrchestrator:
    def __init__(self):
        self.steps = [
            SagaStep(CreateOrderStep(), compensate_order),
            SagaStep(ChargePaymentStep(), refund_payment),
            SagaStep(ReserveInventoryStep(), release_inventory),
            SagaStep(ScheduleShippingStep(), cancel_shipping),
        ]

    async def execute(self, order_data):
        completed_steps = []
        try:
            for step in self.steps:
                result = await step.execute(order_data)
                completed_steps.append((step, result))
        except Exception as e:
            # 执行补偿操作
            for step, result in reversed(completed_steps):
                await step.compensate(result)
            raise SagaFailedException(str(e))

Saga模式的优缺点

优点

高可用：无长期锁定资源
高性能：避免分布式锁
易于扩展：新增步骤不影响现有逻辑

缺点

数据一致性较弱：只能保证最终一致性
补偿逻辑复杂：需要仔细设计
调试困难：分布式调用难以追踪

适用场景

Saga模式特别适合以下场景：

业务流程长，涉及多个服务
对一致性要求不是极度严格（可接受最终一致）
需要高并发、高性能的系统
订单处理、支付系统、旅行预订等

实践建议

幂等性设计：确保每个操作可以安全重试
超时机制：设置合理的超时时间，避免无限等待
监控告警：实时监控Saga执行状态
补偿日志：记录补偿操作，便于问题排查

总结

Saga模式是处理分布式事务的一种有效方式，通过拆分事务 + 补偿机制，在保证最终一致性的同时，获得更好的性能和可用性。理解并合理运用Saga模式，是架构师必备的技能之一。

推荐阅读：

《Domain-Driven Design》- Eric Evans
《Building Microservices》- Sam Newman
Saga Pattern 论文

DEV Community