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

Seata的AT、TCC、Saga模式的区别及适用场景？

ds 2025/8/18 11:29:44

一、Seata 三种模式核心概念

1. AT 模式（Auto Transaction）

技术本质：基于两阶段提交的自动补偿型事务
特点：通过全局锁实现数据隔离，业务代码零侵入

实现原理：

// 业务方法示例
@GlobalTransactional // 全局事务注解
public void purchase() {// 1. 扣减库存（自动生成反向SQL）inventoryService.reduce();// 2. 创建订单（自动生成反向SQL）orderService.create();
}

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

技术本质：手动补偿型事务

核心接口：

public interface TccService {@TwoPhaseBusinessAction(name = "prepare", commitMethod = "commit", rollbackMethod = "rollback")boolean prepare(BusinessActionContext actionContext); // Try阶段boolean commit(BusinessActionContext actionContext);  // Confirm阶段boolean rollback(BusinessActionContext actionContext);// Cancel阶段
}

3. Saga 模式

技术本质：长事务解决方案

执行方式：

// Saga状态机配置示例
StateMachineBuilder<State, Event> builder = StateMachineBuilderFactory.create(...);
builder.externalTransition().from(State.WAIT_PAY).to(State.PAID).on(Event.PAY_SUCCESS).perform(doAction()); // 正向操作

二、模式对比与实践场景

维度	AT 模式	TCC 模式	Saga 模式
一致性	最终一致	强一致	最终一致
侵入性	无侵入	需要实现TCC接口	需要定义补偿方法
适用场景	传统数据库操作（库存扣减）	金融交易（账户余额操作）	长流程业务（旅行订单）
锁机制	全局锁	无锁	无锁
回滚策略	自动生成反向SQL	手动实现Cancel逻辑	事件驱动补偿

三、实战代码案例

案例1：AT模式库存扣减（完整实现）

// InventoryService.java
public class InventoryService {@Autowiredprivate JdbcTemplate jdbcTemplate;// 库存扣减操作public void reduce(String commodityCode, int count) {jdbcTemplate.update("update inventory set count = count - ? where code = ?", count, commodityCode);}
}// OrderService.java 
public class OrderService {@GlobalTransactional // 全局事务注解（核心控制点）public void createOrder(String userId, String commodityCode, int count) {// 生成订单记录jdbcTemplate.update("insert into orders(user_id,commodity_code,count) values(?,?,?)", userId, commodityCode, count);// 调用库存服务inventoryService.reduce(commodityCode, count);}
}

案例2：TCC模式转账交易

// AccountTccServiceImpl.java
@Service
public class AccountTccServiceImpl implements AccountTccService {@Override@Transactional@TwoPhaseBusinessAction(name = "prepareDeduct", commitMethod = "commit", rollbackMethod = "rollback")public boolean prepareDeduct(BusinessActionContext context, String accountNo, BigDecimal amount) {// Try阶段：冻结金额int update = jdbcTemplate.update("update account set frozen = frozen + ? where balance >= ? and account_no = ?", amount, amount, accountNo);return update > 0;}@Override@Transactionalpublic boolean commit(BusinessActionContext context) {// Confirm阶段：扣除冻结金额String accountNo = (String) context.getActionContext("accountNo");BigDecimal amount = (BigDecimal) context.getActionContext("amount");return jdbcTemplate.update("update account set balance = balance - ?, frozen = frozen - ? where account_no = ?",amount, amount, accountNo) > 0;}@Override@Transactionalpublic boolean rollback(BusinessActionContext context) {// Cancel阶段：释放冻结金额String accountNo = (String) context.getActionContext("accountNo");BigDecimal amount = (BigDecimal) context.getActionContext("amount");return jdbcTemplate.update("update account set frozen = frozen - ? where account_no = ?",amount, accountNo) > 0;}
}

案例3：Saga模式旅行订单（事件编排）

// HotelBookingSaga.java
@Service
public class HotelBookingSaga {@SagaStart // Saga事务起点public void bookHotel(String orderId) {// 1. 预订酒店hotelService.book(orderId);// 2. 预订机票（自动触发补偿）flightService.book(orderId);}// 补偿方法（命名规范：业务方法名 + Compensate）public void bookHotelCompensate(String orderId) {hotelService.cancel(orderId);flightService.cancel(orderId);}
}// FlightService.java
@Service
public class FlightService {@SagaService(compensate = "cancel")public void book(String orderId) {// 机票预订逻辑}public void cancel(String orderId) {// 机票取消逻辑}
}

四、配置要点（application.yml）

seata:enabled: trueapplication-id: order-servicetx-service-group: my_tx_groupservice:vgroup-mapping:my_tx_group: defaultenable-degrade: falsedisable-global-transaction: falseconfig:type: nacosnacos:server-addr: 127.0.0.1:8848registry:type: nacos