Spring @Transactional跨多数据源事务实现及回滚问题咨询

首先直接给结论：默认的@Transactional无法直接实现跨两个独立数据源的事务一致性，因为它只能绑定单个事务管理器，而每个数据源对应自己的事务管理器。你遇到的setRollbackOnly()只回滚DB1的情况，本质是两个数据源的事务处于完全独立的上下文，setRollbackOnly()只能影响当前绑定的DB1事务，对DB2的事务没有约束力。

问题根源拆解 #

当你在方法上标注@Transactional时，Spring会默认使用一个事务管理器（比如你配置的DB1的事务管理器）来管理事务。此时调用updateDb02操作DB2时，DB2的事务是由它自己的事务管理器单独处理的，和DB1的事务属于两个完全隔离的事务上下文。当DB2更新失败你调用setRollbackOnly()，只会标记DB1的事务需要回滚，但DB2的事务可能已经完成提交（如果没在事务里）或者无法感知这个回滚标记，导致数据不一致。

解决方案：使用链式事务管理器或JTA分布式事务 #

下面提供两种可行的实现方案，优先推荐轻量的ChainedTransactionManager：

方案1：Spring ChainedTransactionManager（轻量推荐）

这个管理器可以把多个独立的事务管理器链在一起，当事务提交时会依次提交每个事务，只要有一个提交失败，所有已提交的事务都会尝试回滚。

1. 配置双数据源和对应的事务管理器

@Configuration
public class DataSourceConfig {

    // 配置DB1数据源
    @Bean
    @Primary
    public DataSource db1DataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/db1");
        dataSource.setUsername("db1_user");
        dataSource.setPassword("db1_pass");
        return dataSource;
    }

    // 配置DB2数据源
    @Bean
    public DataSource db2DataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/db2");
        dataSource.setUsername("db2_user");
        dataSource.setPassword("db2_pass");
        return dataSource;
    }

    // DB1事务管理器
    @Bean
    @Primary
    public PlatformTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    // DB2事务管理器
    @Bean
    public PlatformTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    // 链式事务管理器，组合两个事务管理器
    @Bean
    public PlatformTransactionManager chainedTransactionManager(
            @Qualifier("db1TransactionManager") PlatformTransactionManager tm1,
            @Qualifier("db2TransactionManager") PlatformTransactionManager tm2) {
        return new ChainedTransactionManager(tm1, tm2);
    }
}

2. 在业务方法上指定使用链式事务管理器

@Service
public class CrossDbService {

    @Autowired
    private JdbcTemplate db1JdbcTemplate;
    @Autowired
    private JdbcTemplate db2JdbcTemplate;

    // 指定使用链式事务管理器
    @Transactional(transactionManager = "chainedTransactionManager")
    public void crossDbUpdate() {
        try {
            // 更新DB1
            db1JdbcTemplate.update("UPDATE table1 SET value = ? WHERE id = ?", "updated", 1);
            // 更新DB2
            updateDb02();
        } catch (Exception e) {
            // 抛出异常触发链式事务自动回滚
            throw new RuntimeException("跨库更新失败", e);
        }
    }

    private void updateDb02() {
        // 模拟DB2更新失败场景
        int affectedRows = db2JdbcTemplate.update("UPDATE table2 SET value = ? WHERE id = ?", "updated", 9999);
        if (affectedRows == 0) {
            throw new RuntimeException("DB2更新失败：无匹配记录");
        }
    }
}

这里不需要手动调用setRollbackOnly()，只要抛出异常，链式事务管理器会自动回滚两个数据源的事务。

方案2：JTA分布式事务（重量级，适合强一致性场景）

如果你的应用需要严格的ACID保证，或者处于分布式环境，可以使用JTA事务管理器（比如Atomikos、Bitronix）。JTA会协调多个数据源的事务，实现真正的分布式事务回滚。

配置核心思路：

• 用JTA兼容的数据源包装原有数据源
• 配置JTA事务管理器作为全局事务管理器
• 业务方法上直接使用@Transactional（默认绑定JTA事务管理器）

关键注意事项 #

• ChainedTransactionManager是伪分布式事务：它的回滚是"尽力而为"的，如果先提交的数据源（比如DB1）回滚失败，会导致数据不一致。如果需要强一致性，建议用JTA或分布式事务框架（比如Seata）。
• 链式管理器的顺序要和你操作数据源的顺序一致：先操作的数据源对应的事务管理器放在前面，这样回滚逻辑才能正确触发。

内容的提问来源于stack exchange，提问作者Do Will