本文详细介绍如何基于 atomikos 配置 spring boot 多数据源的 jta 分布式事务，确保跨数据库操作的强一致性与自动回滚能力。
本文详细介绍如何基于 atomikos 配置 spring boot 多数据源的 jta 分布式事务，确保跨数据库操作的强一致性与自动回滚能力。
在微服务或单体应用中接入多个异构数据库（如 MySQL + PostgreSQL、或两个独立 MySQL 实例）时，若需保证跨库操作的原子性（例如：订单写入 DB1、库存扣减写入 DB2），必须借助 JTA（Java Transaction API） 实现真正的分布式事务。Spring 原生 @Transactional 默认仅支持单数据源本地事务；当涉及多数据源且要求“全成功或全回滚”时，必须引入支持 XA 协议的事务管理器——Atomikos 是目前最成熟、生产就绪的开源 JTA 实现之一。
✅ 正确配置 Atomikos 多数据源事务
以下为 Spring Boot 3.x + Jakarta EE 环境下的关键配置步骤（以两个 MySQL 数据源为例）：
1. 添加依赖（Maven）
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jta-atomikos</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>⚠️ 注意：spring-boot-starter-jta-atomikos 已内置 Atomikos 与 XA 兼容的连接池（AtomikosDataSourceBean），不可再混用 HikariCP 或 Druid 的 XA 封装，否则将导致事务上下文丢失。
2. 配置两个 XA 数据源（application.yml）
spring:
datasource:
db1:
jdbc-url: jdbc:mysql://localhost:3306/db1?useSSL=false&serverTimezone=UTC
username: user1
password: pass1
xa:
data-source-class-name: com.mysql.cj.jdbc.MysqlXADataSource
db2:
jdbc-url: jdbc:mysql://localhost:3306/db2?useSSL=false&serverTimezone=UTC
username: user2
password: pass2
xa:
data-source-class-name: com.mysql.cj.jdbc.MysqlXADataSource3. 声明 XA 数据源 Bean（Java Config）
@Configuration
public class DataSourceConfig {
@Bean("db1DataSource")
@ConfigurationProperties("spring.datasource.db1")
public DataSource db1DataSource() {
return new AtomikosDataSourceBean(); // 自动识别 XA 属性
}
@Bean("db2DataSource")
@ConfigurationProperties("spring.datasource.db2")
public DataSource db2DataSource() {
return new AtomikosDataSourceBean();
}
@Bean
public PlatformTransactionManager transactionManager(
@Qualifier("db1DataSource") DataSource db1,
@Qualifier("db2DataSource") DataSource db2) {
UserTransactionManager userTransactionManager = new UserTransactionManager();
UserTransaction userTransaction = new UserTransactionImp();
JtaTransactionManager jta = new JtaTransactionManager(userTransaction, userTransactionManager);
jta.setAllowCustomIsolationLevels(true);
return jta;
}
}4. 启用事务并编写业务逻辑
@Service
public class OrderInventoryService {
@Transactional // 使用 JtaTransactionManager，自动传播到所有 XA 数据源
public void createOrderAndDeductStock(Long orderId, String sku, int quantity) {
orderRepository.save(new Order(orderId, sku)); // 写入 db1
stockRepository.deduct(sku, quantity); // 写入 db2 → 若此处抛异常，db1 操作自动回滚
}
}? 关键原理说明
- Atomikos 作为 TM（Transaction Manager），协调多个 RM（Resource Managers，即 XA 数据源） 执行两阶段提交（2PC）：
- Prepare 阶段：询问各数据库是否可提交；
- Commit/Rollback 阶段：统一决策并执行。
- Spring 的 JtaTransactionManager 将 @Transactional 语义桥接到 Atomikos，无需手动调用 UserTransaction.begin()/commit()。
⚠️ 重要注意事项
- ✅ 必须使用支持 XA 的 JDBC 驱动（如 com.mysql.cj.jdbc.MysqlXADataSource），普通 DriverManagerDataSource 不可用；
- ❌ 禁止在同一个事务中混合使用 XA 与非 XA 数据源（会导致事务挂起或静默失败）；
- ? Atomikos 日志路径建议显式配置（避免默认写入 /tmp）：
atomikos: properties: com.atomikos.icatch.output_dir: ./logs/atomikos com.atomikos.icatch.log_base_name: tmlog - ? 测试时可通过主动抛出 RuntimeException 验证跨库回滚效果（如 throw new RuntimeException("Simulate failure"); 插入在第二步后）。
✅ 替代方案对比（不推荐降级）
- ChainedTransactionManager：已废弃，属伪事务（Best-Effort 1PC），无 Prepare 阶段，无法保证强一致性；
- Seata / ShardingSphere-JDBC：适用于云原生或分库分表场景，但引入额外中间件复杂度；
- Atomikos 是 Spring 生态下多数据源 XA 事务的事实标准，稳定、轻量、零代理。
通过以上配置，即可实现“任一数据源操作失败，全部回滚”的强一致性保障——这正是你所期望的可靠分布式事务行为。
