🔄 Seata分布式事务模式详解

XA模式示例代码

// 1. 配置XA数据源
@Configuration
public class XADataSourceConfig {
    
    @Bean
    @Primary
    public DataSource dataSource() {
        AtomikosDataSourceBean dataSource = new AtomikosDataSourceBean();
        dataSource.setUniqueResourceName("xa-datasource");
        dataSource.setXaDataSourceClassName("com.mysql.cj.jdbc.MysqlXADataSource");
        dataSource.setXaProperties(xaProperties());
        return dataSource;
    }
}

// 2. 业务服务使用全局事务注解
@Service
public class TransferService {
    
    @Autowired
    private AccountService accountService;
    
    @GlobalTransactional(rollbackFor = Exception.class)
    public void transferMoney(String fromAccount, String toAccount, BigDecimal amount) {
        try {
            // 第一阶段：所有操作都会执行但不提交
            
            // 步骤1：扣减源账户余额
            accountService.debit(fromAccount, amount);
            
            // 步骤2：增加目标账户余额
            accountService.credit(toAccount, amount);
            
            // 步骤3：记录转账日志
            logService.recordTransfer(fromAccount, toAccount, amount);
            
            // 如果所有步骤都成功，Seata会协调所有参与者提交事务
            // 如果任何步骤失败，所有操作自动回滚
            
        } catch (Exception e) {
            // 异常时，@GlobalTransactional会触发全局回滚
            throw e;
        }
    }
}