分布式事务终极指南：从2PC到Seata AT模式的理论与实践

分布式事务的挑战

当单体应用拆分为微服务后，一个业务操作可能涉及多个服务和多个数据库。传统的本地事务（ACID）无法跨越服务边界，分布式事务成为必须面对的核心难题。BASE理论告诉我们，在分布式系统中，我们需要在一致性（Consistency）和可用性（Availability）之间做出权衡。

常见解决方案全景对比

主要的分布式事务方案包括：2PC/XA（强一致但性能低）、TCC（最终一致，适用于跨服务的业务补偿）、Saga（最终一致，适合长事务和业务流程编排）、消息队列+最终一致（高一致性容忍异步延迟的场景）以及Seata AT（最终一致且侵入性低，支持自动补偿）。

两阶段提交（2PC/XA）

2PC是最经典的分布式事务协议，分为投票阶段和提交阶段。由事务协调者（Transaction Coordinator）统一管理所有参与者（Resource Manager）。

阶段1 - Prepare:
  Coordinator → 所有参与者: "准备提交"
  参与者执行事务但不提交，记录undo/redo日志
  参与者回复: Yes / No

阶段2 - Commit/Rollback:
  如果全部Yes → Commit
  如有任何No  → Rollback

缺陷：同步阻塞（所有参与者锁定资源等待协调者决策）、单点故障（协调者宕机导致参与者无限等待）、数据不一致（第二阶段部分参与者收不到指令）。

TCC模式（Try-Confirm-Cancel）

TCC是一种业务层面的分布式事务方案，将每个业务操作拆分为三个阶段：

• Try：资源预留与冻结（如预扣库存、预授权金额）
• Confirm：确认执行，真正扣减资源（幂等操作）
• Cancel：回滚释放资源（幂等操作，支持空回滚）

@LocalTCC
public interface AccountService {
    
    @TwoPhaseBusinessAction(name = "deduct", commitMethod = "confirm", rollbackMethod = "cancel")
    boolean tryDeduct(@BusinessActionContextParameter(paramName = "userId") String userId,
                      @BusinessActionContextParameter(paramName = "amount") BigDecimal amount);
    
    boolean confirm(BusinessActionContext ctx);
    
    boolean cancel(BusinessActionContext ctx);
}

// 实现
@Service
public class AccountServiceImpl implements AccountService {
    @Override
    public boolean tryDeduct(String userId, BigDecimal amount) {
        // 检查余额是否充足，冻结对应金额
        BigDecimal balance = accountMapper.getBalance(userId);
        if (balance.compareTo(amount) < 0 xss=removed xss=removed xss=removed xss=removed>

编排模式：
  Service A --事件--> Service B --事件--> Service C
  失败：Service C --补偿事件--> Service B --补偿事件--> Service A

协调模式：
  Saga Orchestrator
    → 调用Service A
    → 调用Service B
    → 调用Service C（失败）
    → 调用Service B的补偿
    → 调用Service A的补偿

// 使用示例 - 只需一个注解
@GlobalTransactional(name = "create-order", rollbackFor = Exception.class)
public void createOrder(Order order) {
    // 1. 本地事务：创建订单
    orderService.create(order);
    // 2. 远程调用：扣减库存
    storageService.deduct(order.getProductId(), order.getCount());
    // 3. 远程调用：扣减余额
    accountService.debit(order.getUserId(), order.getMoney());
}