MySQL分布式事務xa的介紹與使用小結

更新時間：2024年07月21日 09:52:28 作者：雨下的竹子

xa指的是分布式事務,傳統(tǒng)的事務針對的是單機MySQL,本文主要介紹了MySQL分布式事務xa的介紹與使用小結,有一定的參考價值,有需要的朋友可以參考一下,希望對你有所幫助

1.什么是xa

xa指的是分布式事務，傳統(tǒng)的事務針對的是單機MySQL。在如今大數(shù)據(jù)時代下，往往需要多臺MySQL組成一個集群存儲數(shù)據(jù)。這種情況下，針對所有MySQL節(jié)點操作就無法保證所有MySQL的事務一致性，即只要一臺MySQL上執(zhí)行的事務回滾了，那么其他所有MySQL也要回滾。

2.xa的組成

xa包含兩個重要的角色：事務管理器（Transaction Manager）和資源管理器（Resource Manager）

事務管理器：作為協(xié)調(diào)者，與針對單機的事務們進行通信，以讓他們能夠保持全局事務性。事務管理器通常由客戶端程序?qū)崿F(xiàn)，如后端通過調(diào)用JDBC的api來實現(xiàn)事務管理器，以處理分布式事務
資源管理器：就是指的MySQL服務，能夠支持事務

3.xa工作流程

xa在執(zhí)行全局事務的過程中使用兩階段提交：

準備階段：此時資源管理器已經(jīng)執(zhí)行完sql操作但還沒有提交，事務管理器通知資源管理器準備提交
提交/回滾階段：事務管理器通知資源管理器是提交還是回滾，只要有任意一個資源管理器出現(xiàn)異常，則所有資源管理器都需要回滾

4.xa語法

4.1基本命令

#1.開啟一個xa事務，后面跟的字符串是xid，它是一個唯一的xa事務標識符
xa start '123';
#2.開啟完xa事務后，就能執(zhí)行業(yè)務sql了
update test_table set user = 'zhuzi' where id = 1;
#3.end代表業(yè)務sql執(zhí)行完畢，后續(xù)可以開始二階段提交工作了
xa end '123';
#4.第一階段，進行準備工作
xa prepare '123';
#5.返回該MySQL上那些處于prepare階段的xa事務的信息
xa recover;
#6.第二階段，回滾或提交
xa commit '123';
#xa rollback '123';

注意，這些命令如果只是在一臺mysql上執(zhí)行是沒什么意義的，就跟普通事務一樣。需要客戶端程序和多臺mysql配合使用，才能實現(xiàn)分布式事務。

4.2執(zhí)行xa recover時報錯

ERROR 1401 (XAE03): XAER_RMERR: Fatal error occurred in the transaction branch - check your data for consistency

用戶沒有權限，授予權限即可

GRANT xa_recover_admin ON *.* TO root@'%';

4.3xid的組成

xid由三部分組成

gtrid：必須寫，全局事務標識符
bqual：可選，分支事務的標識符（一個xa事務包含多個分支事務），默認為長度為0的空字符串""
formatID：可選，用于標識gtrid和bqual的格式，默認為0

程序會將這三部分取16進制拼接起來組成xid。

以上內(nèi)容只是xid的一個規(guī)范，實際使用時xid只要不與其他xa事務的xid沖突即可

5.java借助jdbc使用xa事務

需要先引入jdbc的依賴，maven坐標如下：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.28</version>
</dependency>

private static void testXA() {
    Connection connection1 = null;
    Connection connection2 = null;
    MysqlXAConnection xa1 = null;
    MysqlXAConnection xa2 = null;
    Statement statement1 = null;
    Statement statement2 = null;
    try {
        //獲取兩臺MySQL的連接
        connection1 = DriverManager.getConnection("jdbc:mysql://192.168.86.111:3306/db3", "root", "123456");
        connection2 = DriverManager.getConnection("jdbc:mysql://192.168.86.112:3306/db1", "root", "123456");
        //獲取XA連接 true表示打印日志
        xa1 = new MysqlXAConnection((JdbcConnection) connection1, true);
        xa2 = new MysqlXAConnection((JdbcConnection) connection2, true);
        //獲取事務管理器
        XAResource resourceManager1 = xa1.getXAResource();
        XAResource resourceManager2 = xa2.getXAResource();

        //構造組成xid的三部分
        byte[] globalTransactionId = UUID.randomUUID().toString().replace("-", "").getBytes();
        byte[] branch1 = "分支1".getBytes();
        byte[] branch2 = "分支2".getBytes();
        int formatId = 1;
		//獲取xid對象
        MysqlXid xid1 = new MysqlXid(globalTransactionId, branch1, formatId);
        MysqlXid xid2 = new MysqlXid(globalTransactionId, branch2, formatId);
        //要執(zhí)行的業(yè)務sql
        String sql1 = "insert into test(`name`, `age`) values('竹子', 23)";
        String sql2 = "insert into employee(`employee_name`, `department_id`) values('竹葉', 1)";
        //執(zhí)行xa start xid命令
        resourceManager1.start(xid1, XAResource.TMNOFLAGS);
        resourceManager2.start(xid2, XAResource.TMNOFLAGS);
        //執(zhí)行業(yè)務sql
        statement1 = connection1.createStatement();
        statement1.execute(sql1);
        statement2 = connection2.createStatement();
        statement2.execute(sql2);
        //執(zhí)行xa end xid命令
        resourceManager1.end(xid1, XAResource.TMSUCCESS);
        resourceManager2.end(xid2, XAResource.TMSUCCESS);

        //執(zhí)行xa prepare xid命令
        int prepare1 = resourceManager1.prepare(xid1);
        int prepare2 = resourceManager2.prepare(xid2);
        //是否只存在一臺MySQL，如果只存在一臺MySQL，那么就不需要進行分布式的二階段提交了
        boolean onePhase = false;
        //都準備好了
        if (prepare1 == XAResource.XA_OK && prepare2 == XAResource.XA_OK) {
            //執(zhí)行xa commit xid命令
            resourceManager1.commit(xid1, onePhase);
            resourceManager2.commit(xid2, onePhase);
        } else {
            //執(zhí)行xa rollback xid命令
            resourceManager1.rollback(xid1);
            resourceManager2.rollback(xid2);
        }
    } catch (SQLException | XAException e) {
        e.printStackTrace();
    } finally {
        try {
            statement1.close();
            statement2.close();
            xa1.close();
            xa2.close();
            connection1.close();
            connection2.close();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

執(zhí)行的日志信息如下：

在這里插入圖片描述