当前位置：首页 > article >正文

Seata：分布式事务的终极解决方案

article 2025/3/19 11:28:41

在微服务架构中，事务一致性是开发者面临的核心挑战之一。当一个业务操作需要跨多个服务完成时（如电商系统的下单、扣库存、扣积分），如何保证所有服务要么全部成功，要么全部回滚？Seata（Simple Extensible Autonomous Transaction Architecture） 作为阿里巴巴开源的分布式事务解决方案，提供了优雅的解决思路。本文将深入剖析其核心原理、事务模式及实战应用。

一、Seata 核心架构

Seata 的核心架构由三部分组成：

TC（Transaction Coordinator）：事务协调器，全局事务的大脑，负责事务的提交和回滚。
TM（Transaction Manager）：事务管理器，定义全局事务的边界（如 @GlobalTransactional）。
RM（Resource Manager）：资源管理器，管理分支事务（如数据库连接）。

交互流程：

TM 向 TC 发起全局事务，生成全局唯一 XID。
RM 向 TC 注册分支事务，绑定 XID。
TC 根据所有分支事务的状态，决定全局事务提交或回滚。

Seata 架构图

二、Seata 的三种事务模式

1. AT 模式（自动补偿型事务）

原理：通过代理数据源，自动生成反向 SQL 实现回滚。
适用场景：对业务代码侵入性低，适合大多数业务场景。
工作流程：

一阶段：执行业务 SQL，保存数据快照（undo_log）。
二阶段：
- 提交：异步删除 undo_log。
- 回滚：根据 undo_log 生成反向 SQL 恢复数据。


-- undo_log 表结构
CREATE TABLE undo_log (
  id BIGINT PRIMARY KEY,
  branch_id BIGINT,
  xid VARCHAR(100),
  context VARCHAR(128),
  rollback_info LONGBLOB,
  log_status INT,
  log_created TIMESTAMP,
  log_modified TIMESTAMP
);

优势：零代码侵入，性能高（无全局锁）。
限制：仅支持支持本地事务的数据库（如 MySQL）。

2. TCC 模式（Try-Confirm-Cancel）

原理：通过手动编写补偿逻辑实现事务控制。
适用场景：需要强一致性的金融交易场景。
三个阶段：

Try：预留资源（如冻结库存）。
Confirm：确认操作（实际扣减库存）。
Cancel：补偿操作（释放冻结的库存）。

@LocalTCC
public interface InventoryService {
    @TwoPhaseBusinessAction(name = "deductInventory", commitMethod = "confirm", rollbackMethod = "cancel")
    boolean tryDeduct(@BusinessActionContextParameter(paramName = "productId") String productId, 
                     @BusinessActionContextParameter(paramName = "count") int count);

    boolean confirm(BusinessActionContext context);
    boolean cancel(BusinessActionContext context);
}

优势：支持跨数据库、跨服务的复杂事务。
挑战：需手动编写补偿逻辑，代码复杂度高。

3. Saga 模式

原理：通过状态机编排多个本地事务，失败时执行反向补偿。
适用场景：长流程业务（如物流系统订单状态流转）。
实现方式：

正向服务：提交订单、生成运单。
反向服务：取消订单、删除运单。

优势：天然支持异步和长事务。
缺点：需保证补偿操作的幂等性。

三、Seata 实战：电商下单场景

业务需求：用户下单时，需同步扣减库存、生成订单、增加积分。

1. 配置 Seata Server（TC）

# registry.conf
registry {
  type = "nacos"
  nacos {
    serverAddr = "localhost:8848"
    namespace = ""
    cluster = "default"
  }
}

config {
  type = "nacos"
  nacos {
    serverAddr = "localhost:8848"
    namespace = ""
    group = "SEATA_GROUP"
  }
}

2. 服务端代码示例


// 订单服务
@RestController
public class OrderController {
    @Autowired
    private OrderService orderService;

    @GlobalTransactional
    @PostMapping("/create")
    public String createOrder(@RequestBody OrderRequest request) {
        orderService.create(request);
        return "success";
    }
}

// 库存服务
@Service
public class InventoryServiceImpl implements InventoryService {
    @Override
    @Transactional
    public void deduct(String productId, int count) {
        // 扣减库存 SQL
    }
}