由于項目上的需要，我要同時往orcale數(shù)據(jù)庫與sqlserver數(shù)據(jù)中插入數(shù)據(jù)，需要在一個事務(wù)之內(nèi)完成這兩個庫的提交。參考了一下網(wǎng)上的各種JTA（Java Transaction API）實現(xiàn)之后，選擇了Atomikos的實現(xiàn)。

因為當(dāng)時使用的時候繞的彎路大了點，所以寫篇文章記錄下基本的實現(xiàn)過程，方便日后查看。如果是第一次使用，強烈建議去Atomikos查看官方例子與指導(dǎo)，寫的很詳細(xì)。

前提

----XA是啥？
XA是由X/Open組織提出的分布式事務(wù)的架構(gòu)（或者叫協(xié)議）。XA架構(gòu)主要定義了（全局）事務(wù)管理器（Transaction Manager）和（局部）資源管理器（Resource Manager）之間的接口。XA接口是雙向的系統(tǒng)接口，在事務(wù)管理器（Transaction Manager）以及一個或多個資源管理器（Resource Manager）之間形成通信橋梁。也就是說，在基于XA的一個事務(wù)中，我們可以針對多個資源進行事務(wù)管理，例如一個系統(tǒng)訪問多個數(shù)據(jù)庫，或即訪問數(shù)據(jù)庫、又訪問像消息中間件這樣的資源。這樣我們就能夠?qū)崿F(xiàn)在多個數(shù)據(jù)庫和消息中間件直接實現(xiàn)全部提交、或全部取消的事務(wù)。XA規(guī)范不是java的規(guī)范，而是一種通用的規(guī)范，
目前各種數(shù)據(jù)庫、以及很多消息中間件都支持XA規(guī)范。
JTA是滿足XA規(guī)范的、用于Java開發(fā)的規(guī)范。所以，當(dāng)我們說，使用JTA實現(xiàn)分布式事務(wù)的時候，其實就是說，使用JTA規(guī)范，實現(xiàn)系統(tǒng)內(nèi)多個數(shù)據(jù)庫、消息中間件等資源的事務(wù)。

JTA(Java Transaction API)，是J2EE的編程接口規(guī)范，它是XA協(xié)議的JAVA實現(xiàn)。它主要定義了：

• 一個事務(wù)管理器的接口javax.transaction.TransactionManager，定義了有關(guān)事務(wù)的開始、提交、撤回等>操作。
• 一個滿足XA規(guī)范的資源定義接口javax.transaction.xa.XAResource，一種資源如果要支持JTA事務(wù)，就需要讓它的資源實現(xiàn)該XAResource接口，并實現(xiàn)該接口定義的兩階段提交相關(guān)的接口。
  如果我們有一個應(yīng)用，它使用JTA接口實現(xiàn)事務(wù)，應(yīng)用在運行的時候，就需要一個實現(xiàn)JTA的容器，一般情況下，這是一個J2EE容器，像JBoss，Websphere等應(yīng)用服務(wù)器。但是，也有一些獨立的框架實現(xiàn)了JTA，例如Atomikos, bitronix都提供了jar包方式的JTA實現(xiàn)框架。這樣我們就能夠在Tomcat或者Jetty之類的服務(wù)器上運行使用JTA實現(xiàn)事務(wù)的應(yīng)用系統(tǒng)。
  在上面的本地事務(wù)和外部事務(wù)的區(qū)別中說到，JTA事務(wù)是外部事務(wù)，可以用來實現(xiàn)對多個資源的事務(wù)性。它正是通過每個資源實現(xiàn)的XAResource來進行兩階段提交的控制。感興趣的同學(xué)可以看看這個接口的方法，除了commit, rollback等方法以外，還有end(), forget(), isSameRM(), prepare()等等。光從這些接口就能夠想象JTA在實現(xiàn)兩階段事務(wù)的復(fù)雜性。
  ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? -------------- REST微服務(wù)的分布式事務(wù)實現(xiàn)-分布式系統(tǒng)、事務(wù)以及JTA介紹

如果還想了解更多的關(guān)于分布式事務(wù)的實現(xiàn)方式的可以看一個這個，里面寫了7種思路。Spring的分布式事務(wù)實現(xiàn)-使用和不使用XA(翻譯)

環(huán)境： spring-boot 2.x + maven + atomikos + orcale + sqlserver + mybatis

maven:pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>con.demo</groupId>
    <artifactId>demo</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>demo</name>
    <description>demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.13.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>

        <dependency>
            <groupId>com.github.noraui</groupId>
            <artifactId>ojdbc7</artifactId>
            <version>12.1.0.2</version>
        </dependency>

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.5</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jta-atomikos</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

        <dependency>
            <groupId>com.microsoft.sqlserver</groupId>
            <artifactId>mssql-jdbc</artifactId>
            <version>6.4.0.jre8</version>
        </dependency>
    </dependencies>

    <build>
        <resources>
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.xml</include>
                </includes>
            </resource>
            <resource>
                <directory>src/main/resources</directory>
                <includes>
                    <include>**/*</include>
                </includes>
            </resource>
        </resources>
    </build>
</project>

application.properties里配置3個數(shù)據(jù)源

server.port=8085
logging.file=logs\\msgexchange.log
logging.level.root=INFO
logging.level.org.springframework.web=INFO

logging.level.cn.gov.customs.msgexchange=DEBUG
mybatis.check-config-location=true
mybatis.config-locations=classpath:mybatis-config.xml

#primary datasource
spring.datasource.driverClassName = oracle.jdbc.driver.OracleDriver
spring.datasource.url=jdbc:oracle:thin:@ip:port:dbname
spring.datasource.username=username
spring.datasource.password=password
spring.datasource.initialSize=5 
spring.datasource.minIdle=10  
spring.datasource.maxActive=30  
spring.datasource.maxWait=60000  
spring.datasource.timeBetweenEvictionRunsMillis=60000  
spring.datasource.minEvictableIdleTimeMillis=300000  
spring.datasource.validationQuery=SELECT 1 FROM DUAL  
spring.datasource.testWhileIdle=true  
spring.datasource.testOnBorrow=false  
spring.datasource.testOnReturn=false  
spring.datasource.poolPreparedStatements=true  
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20  

#XADataSource orcale 數(shù)據(jù)源
spring.datasource.msg.xaDataSourceClassName=oracle.jdbc.xa.client.OracleXADataSource
spring.datasource.msg.url=jdbc:oracle:thin:@ip:port:dbname
spring.datasource.msg.user=user
spring.datasource.msg.password=password
spring.datasource.msg.uniqueResourceName=OracleXADataSource
spring.datasource.msg.initialSize=5 
spring.datasource.msg.minIdle=10  
spring.datasource.msg.maxActive=30  
spring.datasource.msg.maxWait=60000  
spring.datasource.msg.timeBetweenEvictionRunsMillis=60000  
spring.datasource.msg.minEvictableIdleTimeMillis=300000  
spring.datasource.msg.validationQuery=SELECT 1 FROM DUAL  
spring.datasource.msg.testWhileIdle=true  
spring.datasource.msg.testOnBorrow=false  
spring.datasource.msg.testOnReturn=false  
spring.datasource.msg.poolPreparedStatements=true  
spring.datasource.msg.maxPoolPreparedStatementPerConnectionSize=20

#sqlserver 數(shù)據(jù)源
spring.datasource.dps.driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver 
spring.datasource.dps.url=jdbc:sqlserver://localhost:port;database=dbname
spring.datasource.dps.username=username
spring.datasource.dps.password=password
spring.datasource.dps.initialSize=5 
spring.datasource.dps.minIdle=10  
spring.datasource.dps.maxActive=30  
spring.datasource.dps.maxWait=60000  
spring.datasource.dps.timeBetweenEvictionRunsMillis=60000  
spring.datasource.dps.minEvictableIdleTimeMillis=300000  
spring.datasource.dps.validationQuery=SELECT 1 FROM DUAL  
spring.datasource.dps.testWhileIdle=true  
spring.datasource.dps.testOnBorrow=false  
spring.datasource.dps.testOnReturn=false  
spring.datasource.dps.poolPreparedStatements=true  
spring.datasource.dps.maxPoolPreparedStatementPerConnectionSize=20

這里很尷尬，配置了這么多，由于使用的并不是springboot-start里的自動裝配。我又沒有手動裝配，所有其實都沒有用上。。其中主數(shù)據(jù)源是平時單庫操作用的，他不需要使用分布式事務(wù)。
我使用了mybatis，所以現(xiàn)在來寫一下配置文件。

主數(shù)據(jù)源

@Configuration
@MapperScan(basePackages = {"com.demo.orcale.dao"}, sqlSessionTemplateRef = "SqlSessionTemplate")
public class MybatisConfig {

    @Bean(name = "MybatisDS")
    @ConfigurationProperties(prefix = "spring.datasource")
    @Primary
    public DataSource DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "SqlSessionFactory")
    @Primary
    public SqlSessionFactory SqlSessionFactory(@Qualifier("MybatisDS") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Primary
    @Bean(name = "TransactionManager")
    public DataSourceTransactionManager TransactionManager(@Qualifier("MybatisDS") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Primary
    @Bean(name = "SqlSessionTemplate")
    public SqlSessionTemplate SqlSessionTemplate(@Qualifier("SqlSessionFactory") SqlSessionFactory sqlSessionFactory)
            throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

這里是配置了一下單庫操作的主數(shù)據(jù)源，這個和分布式事務(wù)沒有一點關(guān)系，為了平時數(shù)據(jù)庫的增刪改查使用。

sqlserver數(shù)據(jù)源

@Configuration
@MapperScan(basePackages = ""com.demo.xa.sqlserver.dao", sqlSessionTemplateRef = "DpsSqlSessionTemplate")
@ConfigurationProperties(prefix = "spring.datasource.dps")
public class DPSMybatisConfig {
    private String url;
    private String username;
    private String password;

    @Bean(name = "DpsMybatisDS")
    public DataSource DataSource() {
        SQLServerXADataSource xaDataSource = new SQLServerXADataSource();
        xaDataSource.setURL(url);
        xaDataSource.setUser(username);
        xaDataSource.setPassword(password);

        AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
        ds.setXaDataSource(xaDataSource);
        return ds;
    }

    @Bean(name = "DpsSqlSessionFactory")
    public SqlSessionFactory SqlSessionFactory(@Qualifier("DpsMybatisDS") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Bean(name = "DpsSqlSessionTemplate")
    public SqlSessionTemplate SqlSessionTemplate(@Qualifier("DpsSqlSessionFactory") SqlSessionFactory sqlSessionFactory)
            throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

orcale數(shù)據(jù)源

@Configuration
@MapperScan(basePackages = {"com.demo.xa.orcale.dao"}, sqlSessionTemplateRef = "SqlSessionTemplate")
public class MybatisConfig {

        //從配置文件里注入吧
    @Bean(name = "MybatisDS")
    public DataSource DataSource() {
        Properties properties = new Properties();
        properties.setProperty("URL", "jdbc:oracle:thin:@172.18.11.62:1521:test");
        properties.setProperty("user", "user");
        properties.setProperty("password", "password");

        AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
        ds.setXaProperties(properties);
        ds.setUniqueResourceName("OracleXADataSource");
        ds.setXaDataSourceClassName("oracle.jdbc.xa.client.OracleXADataSource");
        return ds;
    }

    @Bean(name = "SqlSessionFactory")
    public SqlSessionFactory SqlSessionFactory(@Qualifier("MybatisDS") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Bean(name = "SqlSessionTemplate")
    public SqlSessionTemplate SqlSessionTemplate(@Qualifier("SqlSessionFactory") SqlSessionFactory sqlSessionFactory)
            throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

使用XA的時候只需要把數(shù)據(jù)源配置成對應(yīng)數(shù)據(jù)庫的XA數(shù)據(jù)源就行了，其他的配置不用改

mysql就把數(shù)據(jù)源換成MysqlXADataSource完全沒區(qū)別。

定義個獨立的事務(wù)管理器，spring會為你管理的。(很遺憾沒有研究一下spring是如何接手事務(wù)管理的)

    @Bean(name = "xatx")
    @Primary
    public JtaTransactionManager regTransactionManager () {
        UserTransactionManager userTransactionManager = new UserTransactionManager();
        UserTransaction userTransaction = new UserTransactionImp();
        return new JtaTransactionManager(userTransaction, userTransactionManager);
    }

至此配置就配置完成了。然后看一下如何使用

    @Transactional(transactionManager = "xatx")
    @GetMapping("/test")
    public String test(){
        //sqlservice
        User user = new User();
        user.setNo(UUID.randomUUID().toString().substring(10));
        user.setName("bob");
        userMapper.insert(user);

        if (true){
            throw new RuntimeException("this is my RunTime error");
        }

        //orcale
        Car car = new Car();
        car.setNo(UUID.randomUUID().toString().substring(10));
        car.setName("sherry");
        carMapper.insert(car);

        return "操作成功";
    }

在事務(wù)中拋出任意的RuntimeException的時候都會觸發(fā)事務(wù)的回滾，要不兩個數(shù)據(jù)庫都提交，否則就都不提交。
其實搭建分布式事務(wù)的難點并不是在配置mybatis數(shù)據(jù)源這里。而是在配置數(shù)據(jù)庫上，orcale的還好說，只要給一下orcale賬戶的權(quán)限就完事，但是sqlserver數(shù)據(jù)庫的配置簡直了，老老實實跟著官網(wǎng)步驟走吧。
atomikos官網(wǎng)步驟： Configuring Microsoft SQL Server for XA
微軟官網(wǎng)：Understanding XA Transactions
上面這兩個才是最坑的。這里舉兩個我碰到的坑

問題1：沒有存儲過程xxx

這個問題基本看看是orcale還是sqlserver，如果是orcale的就是沒有數(shù)據(jù)庫的表權(quán)限。找到官網(wǎng)的4個授權(quán)語句加上，問題可以解決

grant select on sys.dba_pending_transactions to <user name>;
grant select on sys.pending_trans$ to <user name>;
grant select on sys.dba_2pc_pending to <user name>;
grant execute on sys.dbms_system to <user name>;

如果是sqlserver數(shù)據(jù)源報出的問題，那么找到驅(qū)動中的xa_install.sql文件，運行一下，他會建立很多觸發(fā)器與表，還會建立一個數(shù)據(jù)庫角色，你需要把sqlserver的登錄用戶賦予這個新建的角色。

問題2：函數(shù) RECOVER: 失敗。狀態(tài)為: -3。錯誤:“*** SQLJDBC_XA DTC_ERROR Context: xa_recover, state=1

javax.transaction.xa.XAException: 函數(shù) RECOVER: 失敗。狀態(tài)為: -3。錯誤:“*** SQLJDBC_XA DTC_ERROR Context: xa_recover, state=1, StatusCode:-3 (0xFFFFFFFD) ***”
    at com.microsoft.sqlserver.jdbc.SQLServerXAResource.DTC_XA_Interface(SQLServerXAResource.java:550) ~[sqljdbc4-4.0.jar:na]
    at com.microsoft.sqlserver.jdbc.SQLServerXAResource.recover(SQLServerXAResource.java:728) ~[sqljdbc4-4.0.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.recoverXidsFromXAResource(XATransactionalResource.java:554) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.recover(XATransactionalResource.java:512) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.recoverXidsFromResourceIfNecessary(XATransactionalResource.java:615) 
............................

2018-08-08 09:11:33.221  WARN 2020 --- [           main] c.a.icatch.imp.TransactionServiceImp     : ERROR IN RECOVERY

com.atomikos.datasource.ResourceException: Error in recovery
    at com.atomikos.datasource.xa.XATransactionalResource.recoverXidsFromXAResource(XATransactionalResource.java:565) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.recover(XATransactionalResource.java:512) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.recoverXidsFromResourceIfNecessary(XATransactionalResource.java:615) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.endRecovery(XATransactionalResource.java:583) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.icatch.imp.TransactionServiceImp.recover(TransactionServiceImp.java:558) [transactions-3.9.3.jar:na]
    at com.atomikos.datasource.xa.XATransactionalResource.setRecoveryService(XATransactionalResource.java:435) [transactions-jta-3.9.3.jar:na]
    at com.atomikos.icatch.system.Configuration.installRecoveryService(Configuration.java:260) [transactions-3.9.3.jar:na]
    at com.atomikos.icatch.imp.TransactionServiceImp.prepareConfigurationForPresumedAbortIfNecessary(TransactionServiceImp.java:581) 

這個錯誤折騰了很久。原因基本就是程序使用的sqlserver連接驅(qū)動版本與數(shù)據(jù)庫dll的版本不一致，嘗試以下步驟：

1.檢查pom文件

mssql-jdbc版本，我這里是6.4.0.jre8。那么就去微軟官網(wǎng)下同版本驅(qū)動，把驅(qū)動里面的sqljdbc_xa.dll丟帶相應(yīng)文件夾下，這個的詳細(xì)操作網(wǎng)上很多。

2.sqljdbc_auth.dll

把驅(qū)動中的sqljdbc_auth.dll丟到C:\Windows\System32下，然后重啟sqlserver服務(wù)。

3.都沒用..

是的，我試了一下都沒用，在這里卡了好幾個小時，但是我的直覺告訴我還是版本問題，所以我又去看了一眼pom文件。然后我發(fā)現(xiàn)了sqljdbc4這個包，那么mssql-jdbc包又是干嘛的，都是sqlserver的jdbc驅(qū)動嗎，是不是重復(fù)了？然后我把sqljdbc4包刪了，世界恢復(fù)了正常，程序不報異常了。這兩個應(yīng)該都是sqlserver的jdbc驅(qū)動，我也沒找到區(qū)別在哪，但是官網(wǎng)頁面使用的是mssql-jdbc的驅(qū)動，保持一致就好了。

        <dependency>
            <groupId>com.microsoft.sqlserver</groupId>
            <artifactId>sqljdbc4</artifactId>
            <version>4.0</version>
        </dependency>

以上就是我用XA遇到的一些問題，最坑的就是sqlserver數(shù)據(jù)庫這一塊的配置了。但是根本原因還是自己用之前沒有好好的讀一遍官網(wǎng)的使用說明文檔，白白的浪費了時間。教訓(xùn)就是用之前有官網(wǎng)就去官網(wǎng)，官網(wǎng)有例子就改例子，有文檔就先讀文檔，別去百度里瞎搜。

結(jié)束語

分布式事務(wù)或者說，就分布式、微服務(wù)架構(gòu)的系統(tǒng)如何保證數(shù)據(jù)的一致性這一點來考慮，當(dāng)然這是一個很大的話題，完全應(yīng)該獨立一篇文章出來討論。在MQ中，你可以選擇使用回執(zhí)或者事務(wù)保持一致性。在SpringCloud你可以使用Hystrix的fallback或者TCC（Try-Confirm-Cancel）模式。又或者說存儲每一次的數(shù)據(jù)操作或者說儲存沒一個事件，那么當(dāng)發(fā)生異常的時候我們能夠根據(jù)歷史事件重新生成數(shù)據(jù)的事件溯源（Event Sourcing）模式。等等這些都是用非事務(wù)的方式來確保數(shù)據(jù)一致。

附錄

微軟官網(wǎng)：Understanding XA Transactions
atomikos： Configuring TransactionsEssentials?

感謝博客的分析文章：
codin：codin
微服務(wù)架構(gòu)下處理分布式事務(wù)，你必須知道的事兒
如何保障微服務(wù)架構(gòu)下的數(shù)據(jù)一致性？
從銀行轉(zhuǎn)賬失敗到分布式事務(wù)：總結(jié)與思考