SpringBoot2 整合JTA元件，多資料源事務管理

一、JTA元件簡介

1、JTA基本概念

JTA即Java-Transaction-API，JTA允許應用程式執行分布式事務處理，即在兩個或多個網絡計算機資源上通路并且更新資料。JDBC驅動程式對JTA的支援極大地增強了資料通路能力。

XA協定是資料庫層面的一套分布式事務管理的規範,JTA是XA協定在Java中的實作,多個資料庫或是消息廠商實作JTA接口,開發人員隻需要調用SpringJTA接口即可實作JTA事務管理功能。

JTA事務比JDBC事務更強大。一個JTA事務可以有多個參與者，而一個JDBC事務則被限定在一個單一的資料庫連接配接。下列任一個Java平台的元件都可以參與到一個JTA事務中

2、分布式事務

分布式事務（DistributedTransaction）包括事務管理器（TransactionManager）和一個或多個支援 XA 協定的資料總管 ( Resource Manager )。

資料總管是任意類型的持久化資料存儲容器，例如在開發中常用的關系型資料庫：MySQL，Oracle等，消息中間件RocketMQ、RabbitMQ等。

事務管理器提供事務聲明，事務資源管理，同步，事務上下文傳播等功能，并且負責着所有事務參與單元者的互相通訊的責任。JTA規範定義了事務管理器與其他事務參與者互動的接口，其他的事務參與者與事務管理器進行互動。

二、SpringBoot整合JTA

項目整體結構圖

1、核心依賴

<!--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>           

2、環境配置

這裡jtaManager的配置，在日志輸出中非常關鍵。

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           

3、核心容器

這裡兩個資料庫連接配接的配置手法都是一樣的，可以在源碼中自行下載下傳閱讀。基本思路都是把資料源交給JTA元件來統一管理，友善事務的通信。

資料源參數

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

JTA元件配置

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);
    }
}           

4、測試對比

這裡通過兩個方法測試結果做對比，在兩個資料源之間進行資料操作時，隻需要在接口方法加上@Transactional注解即可，這樣保證資料在兩個資料源間也可以保證一緻性。

@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);
    }
}           

三、JTA元件小結

在上面JTA實作多資料源的事務管理，使用方式還是相對簡單，通過兩階段的送出，可以同時管理多個資料源的事務。但是暴露出的問題也非常明顯，就是比較嚴重的性能問題,由于同時操作多個資料源,如果其中一個資料源擷取資料的時間過長,會導緻整個請求都非常的長,事務時間太長,鎖資料的時間就會太長，自然就會導緻低性能和低吞吐量。

是以在實際開發過程中，對性能要求比較高的系統很少使用JTA元件做事務管理。作為一個輕量級的分布式事務解決方案，在小的系統中還是值得推薦嘗試的。

最後作為Java下的API，原理和用法還是值得學習一下，開闊眼界和思路。

四、源代碼位址

GitHub·位址
https://github.com/cicadasmile/middle-ware-parent
GitEE·位址
https://gitee.com/cicadasmile/middle-ware-parent