Sharding-JDBC目前還整合其他分布式事務模式來解決事務問題，今天就來介紹一下兩階段事務XA是如何解決分布式事務

什么是XA規(guī)范

XA 規(guī)范 是 X/Open 組織定義的分布式事務處理（DTP，Distributed Transaction Processing）標準。

XA 規(guī)范描述了全局的事務管理器與局部的資源管理器之間的接口。XA規(guī)范的目的是允許多個資源（如數(shù)據(jù)庫，應用服務器，消息隊列等）在同一事務中訪問，這樣可以使 ACID 屬性跨越應用程序而保持有效。

XA 規(guī)范使用兩階段提交來保證所有資源同時提交或回滾任何特定的事務。

XA 事務的基礎是兩階段提交協(xié)議。需要有一個事務協(xié)調(diào)者來保證所有的事務參與者都完成了準備工作(第一階段)。如果協(xié)調(diào)者收到所有參與者都準備好的消息，就會通知所有的事務都可以提交了（第二階段）。

MySQL 在這個 XA 事務中扮演的是參與者的角色，而不是協(xié)調(diào)者(事務管理器)。

MySQL中的XA事務分為外部XA和內(nèi)部XA：

• 外部XA：可以參與外部的分布式事務，需要協(xié)調(diào)者參與協(xié)調(diào)
• 內(nèi)部XA：用于同一實例下跨多引擎事務，由 Binlog 作為協(xié)調(diào)者，比如在一個存儲引擎提交時，需要將提交信息寫入二進制日志，這就是一個分布式內(nèi)部 XA 事務，只不過二進制日志的參與者是 MySQL 本身。

基于XA規(guī)范分布式事務對業(yè)務是無侵入的，用戶可以像使用本地事務一樣使用基于XA規(guī)范的分布式事務。

但是基于XA規(guī)范的分布式事務屬于強一致性事務，性能比較低，尤其在長事務的情況下，對資源的鎖定時間較長，一般適用于短事務、低并發(fā)的場景。

MySQL中XA事務

接下來就以為MySQL中XA來演示一下，如下；

上述命令什么意思呢？解析如下：

• XA START "test_xid"?：開啟一個XA事務，test_xid是全局事務xid，名稱任意
• update product_base set price=1000 where product_id=743948772064624640：執(zhí)行的SQL語句
• XA END "test_xid"?：這個表示結(jié)束一個 XA 事務，此時事務的狀態(tài)轉(zhuǎn)為IDLE。
• XA PREPARE "test_xid"：這個將事務置為 PREPARE 狀態(tài)
• XA COMMIT "test_xid"：這個用來提交事務，提交之后，事務的狀態(tài)就是 COMMITED。
• XA ROLLBACK "test_xid"：這個用來回滾事務

Sharding-JDBC中的XA事務

Sharding-JDBC目前已經(jīng)整合了XA事務的支持，支持的Atomikos、NARAYANA 、BITRONIX 事務的實現(xiàn)，默認的實現(xiàn)是Atomikos。下面將以Atomikos為例子介紹一下Sharding-JDBC如何實現(xiàn)XA事務

SharingSphere是通過SPI的方式去定制分布式事務解決方案的，XA的默認實現(xiàn)是org.apache.shardingsphere.transaction.xa.XAShardingTransactionManager，有興趣的可以看下其中源碼

后文介紹到的弱一致性事務使用Seata的AT模式，對應的是org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingTransactionManager

當然Seata也是支持XA事務，如果后續(xù)改寫的話，可以通過SPI的方式的定制

1. 添加依賴

使用XA事務需要添加一個依賴，如下：

<!-- 使用XA事務時，需要引入此模塊 -->
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-transaction-xa-core</artifactId>
</dependency>

可以看到這個依賴中內(nèi)置了ATOMIKOS，如下：

2. 配置事務管理器

使用事務之前當然需要配置一個事務管理器，這里和Spring Boot 中配置沒差別，如下：

@Configuration
@EnableTransactionManagement
public class TransactionConfiguration {
    @Bean
    public PlatformTransactionManager txManager(final DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

3. @ShardingTransactionType注解

想要開啟XA分布式事務還需要使用一個注解@ShardingTransactionType，其中的value屬性的值如下：

• TransactionType.LOCAL：開啟本地事務的支持，默認值
• TransactionType.XA：開啟XA事務的支持
• TransactionType.BASE：開啟弱事務的支持

那么顯然這里只需要配置TransactionType.XA就能開啟XA事務的支持

偽代碼如下：

@ShardingTransactionType(value = TransactionType.XA)
@Transactional
public void method(){
    //跨庫操作
    ..............
}

4. 啟動測試

演示的源碼請看視頻教程中的源碼，需要注意的是Atomikos會在項目的logs目錄下生成xa_tx.log文件，其中記錄了事務日志，在XA崩潰恢復時所需要的日志，一定不要刪除

對于Atomikos的一些配置可以通過在項目的classpath中添加jta.properties來定制化Atomikos配置項，這里就不再給大家詳細介紹了。