领域战略建模：解密 Saga 模式与多上下文分布式事务协同

在微服务与领域驱动设计（DDD）设计中，限界上下文（Bounded Context）的物理隔离切断了传统的数据库强一致性本地事务。当一个业务工作流跨越了“订单域”、“仓储域”与“支付域”时，使用强一致性的 2PC（两阶段提交）会导致系统可用性极度恶化、长事务锁死数据库资源。

为了在大规模分布式架构下保障业务的**最终一致性（Eventual Consistency）**，DDD 推荐使用 **Saga 模式（Saga Pattern）**。Saga 将跨上下文的长事务（Long-Running Process）拆分为一系列局部的本地事务，并通过**正向补偿**与**反向撤销（补偿事务）**来应对中途失败。

本文将系统拆解协同式（Choreography）与编排式（Orchestration）Saga 模式的技术权衡、Saga 状态流转拓扑、以及基于 Java 的编排式 Saga 引擎落地实战。

一、 核心对比：协同式 Saga vs. 编排式 Saga

两种 Saga 拓扑结构在微服务耦合度、状态追踪复杂度以及逻辑清晰度上存在根本差异：

二、 编排式 Saga 分布式事务补偿流转拓扑

在一个包含“扣减库存”与“账户扣款”的订单交易流中，当“账户扣款”失败时，编排式 Saga 触发反向补偿的拓扑如下：

      [ 订单已创建：开启 Saga 工作流 ]
                     │
                     ▼ 1. 发起正向指令 1: DeductStockCommand
      ┌──────────────┴──────────────┐
      ▼ (扣减成功)                  ▼ (扣减失败) ──> 异常中断，流控终止
    [ 仓储上下文 (Stock Context) ]
      │
      ▼ 2. 汇报成功，发起正向指令 2: DeductMoneyCommand
      ┌──────────────┴──────────────┐
      ▼ (余额不足，扣款失败！)          ▼ (扣款成功) ──> 正常结束，最终一致
    [ 支付上下文 (Payment Context) ]
      │
      ▼ 3. 编排器感知失败，启动反向补偿链路
    【 4. 触发补偿指令 1: CancelStockDeductionCommand (加回库存) 】
      │
      ▼ 5. 仓储接收，库存回滚
    [ 仓储上下文 (执行反向对冲 SQL) ] ──> 6. 回滚成功，Saga 事务标记为 FAILED_COMPENSATED

三、 代码实战：在 Java 中基于命令模式构建 Saga 编排器

以下代码展示了如何利用命令与补偿契约，开发一个轻量级的编排式 Saga 事务协调器：

1. 领域层：声明 Saga 活动节点契约（Domain Layer）

package com.company.sales.saga;

/**
 * Saga 事务活动节点接口
 */
public interface SagaStep {
    /**
     * 执行正向本地事务
     */
    boolean execute();

    /**
     * 执行反向补偿对冲事务
     */
    void compensate();
}

2. 领域层/应用层：编写库存扣减与退款的物理步骤

package com.company.sales.saga.steps;

import com.company.sales.saga.SagaStep;

public class StockDeductStep implements SagaStep {
    private final String orderId;
    private final int skuQty;

    public StockDeductStep(String orderId, int qty) {
        this.orderId = orderId;
        this.skuQty = qty;
    }

    @Override
    public boolean execute() {
        System.out.println("[Saga Step] 正在为订单 " + orderId + " 预扣物理库存 " + skuQty + " 件。");
        // 调用仓储上下文 SDK，模拟预扣成功
        return true;
    }

    @Override
    public void compensate() {
        System.out.println("[Saga Compensate] 触发补偿：正在为订单 " + orderId + " 回滚库存 " + skuQty + " 件。");
        // 执行对冲 SQL，库存加回
    }
}

package com.company.sales.saga.steps;

import com.company.sales.saga.SagaStep;

public class PaymentDeductStep implements SagaStep {
    private final String orderId;
    private final double amount;

    public PaymentDeductStep(String orderId, double amount) {
        this.orderId = orderId;
        this.amount = amount;
    }

    @Override
    public boolean execute() {
        System.err.println("[Saga Step] 正在扣减账户余额: " + amount + " 元。");
        if (amount > 1000.0) {
            System.err.println("[Saga Error] 余额不足，账户扣款失败！");
            return false; // 模拟扣款失败，触发回滚
        }
        return true;
    }

    @Override
    public void compensate() {
        System.out.println("[Saga Compensate] 触发补偿：执行退款，返还金额: " + amount);
    }
}
```

3. 基础设施层/应用服务层：Saga 编排器主流程控制（Orchestrator）

package com.company.sales.saga;

import java.util.*;

public class OrderSagaOrchestrator {

    private final List<SagaStep> steps = new ArrayList<>();

    public void addStep(SagaStep step) {
        this.steps.add(step);
    }

    /**
     * 运行长事务工作流
     */
    public boolean runSaga() {
        int lastSuccessStepIndex = -1;

        for (int i = 0; i < steps.size(); i++) {
            SagaStep step = steps.get(i);
            boolean success = step.execute();
            if (success) {
                lastSuccessStepIndex = i;
            } else {
                // 正向事务步骤失败，立刻开启反向对冲回滚
                System.err.println("[Saga Orchestrator] 检测到事务断点，立即开启反向对冲回滚...");
                rollback(lastSuccessStepIndex);
                return false;
            }
        }
        System.out.println("[Saga Orchestrator] Saga 事务链圆满结束，数据达成最终一致！");
        return true;
    }

    private void rollback(int lastSuccessStepIndex) {
        // 从最后一个成功执行的步骤开始，倒序依次调用 compensate() 进行反向数据抵消
        for (int i = lastSuccessStepIndex; i >= 0; i--) {
            steps.get(i).compensate();
        }
        System.err.println("[Saga Orchestrator] 反向补偿链执行完毕，数据回滚自愈完成。");
    }
}