SpringBoot2整合JTA组件实现多数据源事务管理

<!--SpringBoot核心依赖-->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--JTA组件核心依赖-->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jta-atomikos</artifactId>
</dependency>

spring:
 jta:
  transaction-manager-id: jtaManager
 # 数据源配置
 datasource:
  type: com.alibaba.druid.pool.DruidDataSource
  data01:
   driverClassName: com.mysql.jdbc.Driver
   dbUrl: jdbc:mysql://localhost:3306/data-one
   username: root
   password: 000000
  data02:
   driverClassName: com.mysql.jdbc.Driver
   dbUrl: jdbc:mysql://localhost:3306/data-two
   username: root
   password: 000000

@Component
@ConfigurationProperties(prefix = "spring.datasource.data01")
public class DruidOneParam {
  private String dbUrl;
  private String username;
  private String password;
  private String driverClassName;
}

package com.jta.source.conifg;

@Configuration
@MapperScan(basePackages = {"com.jta.source.mapper.one"},sqlSessionTemplateRef = "data01SqlSessionTemplate")
public class DruidOneConfig {

  private static final Logger LOGGER = LoggerFactory.getLogger(DruidOneConfig.class) ;

  @Resource
  private DruidOneParam druidOneParam ;

  @Primary
  @Bean("dataSourceOne")
  public DataSource dataSourceOne () {

    // 设置数据库连接
    MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
    mysqlXADataSource.setUrl(druidOneParam.getDbUrl());
    mysqlXADataSource.setUser(druidOneParam.getUsername());
    mysqlXADataSource.setPassword(druidOneParam.getPassword());
    mysqlXADataSource.setPinGlobalTxToPhysicalConnection(true);

    // 事务管理器
    AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();
    atomikosDataSourceBean.setXaDataSource(mysqlXADataSource);
    atomikosDataSourceBean.setUniqueResourceName("dataSourceOne");
    return atomikosDataSourceBean;
  }

  @Primary
  @Bean(name = "sqlSessionFactoryOne")
  public SqlSessionFactory sqlSessionFactoryOne(
      @Qualifier("dataSourceOne") DataSource dataSourceOne) throws Exception{
    // 配置Session工厂
    SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    sessionFactory.setDataSource(dataSourceOne);
    ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
    sessionFactory.setMapperLocations(resolver.getResources("classpath*:/dataOneMapper/*.xml"));
    return sessionFactory.getObject();
  }

  @Primary
  @Bean(name = "data01SqlSessionTemplate")
  public SqlSessionTemplate sqlSessionTemplate(
      @Qualifier("sqlSessionFactoryOne") SqlSessionFactory sqlSessionFactory) {
    // 配置Session模板
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

@Service
public class TransferServiceImpl implements TransferService {

  @Resource
  private UserAccount01Mapper userAccount01Mapper ;

  @Resource
  private UserAccount02Mapper userAccount02Mapper ;

  @Override
  public void transfer01() {
    userAccount01Mapper.transfer("jack",100);
    System.out.println("i="+1/0);
    userAccount02Mapper.transfer("tom",100);
  }

  @Transactional
  @Override
  public void transfer02() {
    userAccount01Mapper.transfer("jack",200);
    System.out.println("i="+1/0);
    userAccount02Mapper.transfer("tom",200);
  }
}