结论
通过多次实践，在执行业务代码场景中，Spring事务并不能同时管理两个数据源的事务，只能管理单个数据源的事务。
如果确实有需要同时操作两个数据源，而且需要事务的场景，可以try catah起来，然后判断需不需要对数据处理(模拟回滚)。
上一篇：SpringBoot项目配置多数据源，结合mybatis-plus框架_在spring boot单体项目中配置多个数据源并使用mybatis且配置扫描不同的mapper-CSDN博客
Spring多事务管理器配置
每个spring管理器都有对应的数据源。
数据源1的事务管理器配置
@Configuration
@MapperScan(basePackages = "com.xxx.xxx.xxx01.mapper", sqlSessionFactoryRef = "db01SqlSessionFactory")
public class DataSourceConfigDB01 {
// 上一篇的多数据源1配置
// ...
@Primary
@Bean(name = "transactionManager1")
PlatformTransactionManager transactionManager(@Qualifier("db01DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
}数据源2的事务管理器配置
@Configuration
@MapperScan(basePackages = "com.xxx.xxx.xxx02.mapper", sqlSessionFactoryRef = "db02SqlSessionFactory")
public class DataSourceConfigDB01 {
// 上一篇的多数据源2配置
// ...
@Bean(name = "transactionManager2")
PlatformTransactionManager transactionManager(@Qualifier("db02DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
}业务代码使用事务示例
@Transactional(transactionManager = "transactionManager1")或@Transactional表示管理数据源1的事务。
为什么@Transactional能管理数据源1的事务？因为在数据源1配置中使用了@Primary注解。在没有指定的transactionManager，Spring默认取带有@Primary的事务管理器。
@Transactional(transactionManager = "transactionManager1")
public void transaction1(){
// 业务代码
}@Transactional(transactionManager = "transactionManager2")表示管理数据源2的事务
@Transactional(transactionManager = "transactionManager2")
public void transaction1(){
// 业务代码
}多数据源事务管理建议
由于Spring事务只能管理单个数据源，其他数据源非要达到回滚效果，需要自己try catch异常，在异常中，手动回滚(伪回滚,数据插入了判断存在删除)。如果在try catch中发生异常，那就很可能出问题了，建议在catch中不用做太多的事情。
建议把数据源2的操作尽量放在后面，这样可以尽量地避免异常带了的影响，比如在操作数据源2之前发生了异常，还没执行数据源2的代码，自然也不需要回滚什么的。
参考示例
@Transactional(transactionManager = "transactionManager1")
public void transaction5(){
User user = new User();
try {
user.setUsername("transaction666");
user.setPwd("transaction5");
userDao.save(user);
user02Dao.save(user);
int aa = 1/0;
} catch (Exception e) {
// 数据源2 伪回滚
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("username", user.getUsername());
User one = user02Dao.getOne(queryWrapper);
if (Objects.nonNull(one)){
user02Dao.removeById(one.getId());
}
throw e;
}
}