SAGA 分布式事务模式

一次下单 = 多个本地事务串联：

  创建订单 → 扣减库存 → 扣减余额 → 发送短信

  若"扣减余额"失败：
  倒序执行补偿：
    恢复余额 ← 恢复库存 ← 取消订单

订单服务 ──[订单已创建]──→ 库存服务
库存服务 ──[库存已扣减]──→ 账户服务
账户服务 ──[余额已扣减]──→ 通知服务
账户服务 ──[余额扣减失败]──→ 订单服务（触发补偿链）

// 订单服务监听失败事件，启动补偿
@EventListener
public void onBalanceDeductionFailed(BalanceDeductionFailedEvent e) {
    compensationService.cancelOrder(e.getOrderId());   // 取消订单
    compensationService.restoreStock(e.getOrderId());  // 恢复库存
}

              Saga 协调器
               │  1. 创建订单（调订单服务）
               │  2. 扣减库存（调库存服务）
               │  3. 扣减余额（调账户服务） ← 失败
               │  4. 补偿：恢复库存（调库存服务）
               │  5. 补偿：取消订单（调订单服务）
               ▼
            状态表：每步记录 SUCCESS/FAILED

状态：INIT → STEP_1_OK → STEP_2_OK → COMPLETED
                    ↘ STEP_3_FAIL → COMPENSATING → COMPENSATED

// Orchestration：协调器显式驱动，失败走补偿分支
public void runSaga(String orderId) {
    Order o = orderService.createOrder(orderId);      // 步骤1
    try {
        stockService.reserveStock(o);                 // 步骤2
        accountService.deductBalance(o);              // 步骤3
        sagaState.markComplete(orderId);              // 全部成功
    } catch (BalanceDeductFailedException e) {
        // 倒序补偿
        compensationService.restoreStock(o);
        compensationService.cancelOrder(o);
        sagaState.markCompensated(orderId);
    }
}

// 正向：扣减库存（预占）
public void reserveStock(String orderId, String sku, int qty) {
    int updated = jdbc.update(
        "UPDATE stock SET reserved = reserved + ? " +
        "WHERE sku = ? AND available >= ?", qty, sku, qty);
    if (updated == 0) throw new InsufficientStockException();
    publish(new StockReserved(orderId, sku, qty));
}

// 补偿：释放库存（幂等，reserved 不能为负）
public void releaseStock(String orderId, String sku, int qty) {
    jdbc.update(
        "UPDATE stock SET reserved = reserved - ? " +
        "WHERE sku = ? AND reserved >= ?", qty, sku, qty);
}

本地事务：写业务数据 + 写 outbox 消息表（同一数据库事务）
后台任务：扫描 outbox → 发布消息 → 标记已发送

// 消费端幂等
public void onStockReserved(StockReservedEvent e) {
    if (idempotencyStore.exists(e.getEventId())) return; // 已处理
    process(e);
    idempotencyStore.mark(e.getEventId());
}

协调器崩溃 → 重启后读状态表
  若停在 STEP_2_OK：从 STEP_3 继续正向
  若停在 COMPENSATING：继续执行未完成的补偿
  超时的步骤：按重试策略重试，超过阈值转人工