彻底解决长事务难题：Seata Saga模式实战指南

2026-02-05 05:46:19作者：范垣楠Rhoda

你是否还在为分布式系统中的长事务问题头疼？订单创建后需要调用库存、支付、物流等多个服务，任何一个环节失败都可能导致数据不一致。传统事务方案要么性能低下，要么难以适应跨服务场景。本文将带你掌握Seata Saga模式，通过状态机+补偿机制，轻松应对电商下单、金融转账等复杂业务场景。读完本文你将获得：Saga模式核心原理、可视化状态机构建方法、完整配置步骤及避坑指南。

Saga模式核心概念

Saga模式（Saga Pattern）是一种面向长事务的分布式事务解决方案，将整个事务拆分为多个本地事务（称为"状态"），每个状态对应一个业务操作及对应的补偿操作。当事务执行失败时，通过反向执行补偿操作恢复数据一致性。

核心组件：

状态机（StateMachine）：定义事务流程的有向图，包含状态（State）和转换（Transition）
补偿事务（Compensation Transaction）：每个业务操作对应的撤销操作
状态日志（State Log）：记录事务执行过程，用于故障恢复

Seata Saga模块提供完整实现，核心代码位于saga/目录，主要包括：

状态机引擎：seata-saga-engine/
状态机设计器：seata-saga-statemachine-designer/
持久化存储：seata-saga-engine-store/

工作流程可视化

Saga模式通过状态机描述事务流程，以下是电商下单场景的状态机流程图：

graph TD
    Start[开始] --> CreateOrder[创建订单]
    CreateOrder --> CheckStock[检查库存]
    CheckStock --> Pay[支付处理]
    Pay --> Ship[物流发货]
    Ship --> Success[完成]
    
    CreateOrder -->|失败| CancelOrder[取消订单]
    CheckStock -->|失败| RestoreStock[恢复库存]
    Pay -->|失败| Refund[退款处理]
    Ship -->|失败| RecallShipment[召回商品]
    
    CancelOrder --> End[结束]
    RestoreStock --> CancelOrder
    Refund --> RestoreStock
    RecallShipment --> Refund

Seata提供可视化状态机设计器，支持拖拽式创建状态流转图。设计器界面包含左侧工具栏、中间画布和右侧属性面板：

左侧工具栏（Palette）提供状态节点类型：

选中状态节点时显示上下文菜单（ContextPad）：

环境配置步骤

1. 数据库准备

Saga模式需要三个核心表存储状态机定义和执行日志，SQL脚本位于script/client/saga/db/mysql.sql：

CREATE TABLE IF NOT EXISTS `seata_state_machine_def` (
  `id`               VARCHAR(32)  NOT NULL COMMENT '状态机定义ID',
  `name`             VARCHAR(128) NOT NULL COMMENT '名称',
  `content`          TEXT COMMENT '状态机内容',
  `ver`              VARCHAR(16)  NOT NULL COMMENT '版本',
  -- 更多字段...
  PRIMARY KEY (`id`)
);

CREATE TABLE IF NOT EXISTS `seata_state_machine_inst` (
  `id`               VARCHAR(128) NOT NULL COMMENT '状态机实例ID',
  `machine_id`       VARCHAR(32)  NOT NULL COMMENT '状态机定义ID',
  `business_key`     VARCHAR(48) COMMENT '业务标识',
  `status`           VARCHAR(2)   NOT NULL COMMENT '状态(SU:成功|FA:失败|RU:运行中)',
  -- 更多字段...
  PRIMARY KEY (`id`)
);

CREATE TABLE IF NOT EXISTS `seata_state_inst` (
  `id`               VARCHAR(48)  NOT NULL COMMENT '状态实例ID',
  `machine_inst_id`  VARCHAR(128) NOT NULL COMMENT '状态机实例ID',
  `name`             VARCHAR(128) NOT NULL COMMENT '状态名称',
  `status`           VARCHAR(2)   NOT NULL COMMENT '状态',
  -- 更多字段...
  PRIMARY KEY (`id`, `machine_inst_id`)
);

2. 配置文件设置

客户端配置文件位于script/client/conf/file.conf，需配置Saga相关参数：

# Saga事务配置
saga {
  # 状态机序列化方式
  serializer = "json"
  # 恢复策略：compensate(补偿)|retry(重试)
  recoverStrategy = "compensate"
  # 日志存储类型
  logStore = "db"
}

# 数据库配置
store {
  db {
    driverClassName = "com.mysql.cj.jdbc.Driver"
    url = "jdbc:mysql://localhost:3306/seata"
    user = "root"
    password = "password"
  }
}

3. 状态机定义

使用设计器创建状态机后导出JSON定义，示例如下：

{
  "id": "order_transaction",
  "name": "订单处理流程",
  "version": "1.0",
  "states": [
    {
      "name": "CreateOrder",
      "type": "ServiceTask",
      "serviceName": "orderService",
      "serviceMethod": "create",
      "compensateState": "CancelOrder"
    },
    // 其他状态定义...
  ],
  "transitions": [
    {
      "source": "CreateOrder",
      "target": "CheckStock",
      "on": "success"
    }
    // 其他转换定义...
  ]
}

代码集成示例

1. 添加依赖

在pom.xml中添加Saga相关依赖：

<dependency>
  <groupId>io.seata</groupId>
  <artifactId>seata-saga-engine</artifactId>
  <version>2.1.0</version>
</dependency>
<dependency>
  <groupId>io.seata</groupId>
  <artifactId>seata-saga-spring</artifactId>
  <version>2.1.0</version>
</dependency>

2. 定义业务服务

@Service
public class OrderService {
    // 业务方法
    public OrderDTO create(OrderParam param) {
        // 创建订单逻辑
    }
    
    // 补偿方法
    public void cancel(OrderParam param) {
        // 取消订单逻辑
    }
}

3. 启动状态机

@Autowired
private StateMachineEngine stateMachineEngine;

public void processOrder(OrderParam param) {
    // 构建状态机参数
    Map<String, Object> context = new HashMap<>();
    context.put("orderParam", param);
    
    // 启动状态机
    StateMachineInstance instance = stateMachineEngine.start(
        "order_transaction",  // 状态机ID
        "1.0",                // 版本
        context               // 参数
    );
    
    // 检查执行结果
    if ("SU".equals(instance.getStatus())) {
        System.out.println("事务执行成功");
    } else {
        System.out.println("事务执行失败: " + instance.getExcep());
    }
}

故障恢复机制

Seata Saga提供完善的故障恢复机制，通过状态日志表记录执行过程。当系统重启后，引擎会自动扫描未完成的事务实例并根据恢复策略处理：

补偿策略（compensate）：自动执行已完成状态的补偿操作
重试策略（retry）：重新执行失败的状态

恢复逻辑实现位于seata-saga-engine-store/src/main/java/org/apache/seata/saga/engine/store/StateLogStore.java，核心方法：

// 记录状态机启动
void recordStateMachineStarted(StateMachineInstance machineInstance, ProcessContext context);

// 记录状态机完成
void recordStateMachineFinished(StateMachineInstance machineInstance, ProcessContext context);

// 获取未完成的状态机实例
List<StateMachineInstance> getUnfinishedStateMachineInstances();