欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

MySQL分布式事務(wù)xa的介紹與使用小結(jié)

 更新時間:2024年07月21日 09:52:28   作者:雨下的竹子  
xa指的是分布式事務(wù),傳統(tǒng)的事務(wù)針對的是單機(jī)MySQL,本文主要介紹了MySQL分布式事務(wù)xa的介紹與使用小結(jié),有一定的參考價值,有需要的朋友可以參考一下,希望對你有所幫助

1.什么是xa

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

2.xa的組成

xa包含兩個重要的角色:事務(wù)管理器(Transaction Manager)和資源管理器(Resource Manager)

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

3.xa工作流程

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

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

4.xa語法

4.1基本命令

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

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

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

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

用戶沒有權(quán)限,授予權(quán)限即可

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

4.3xid的組成

xid由三部分組成

  • gtrid:必須寫,全局事務(wù)標(biāo)識符
  • bqual:可選,分支事務(wù)的標(biāo)識符(一個xa事務(wù)包含多個分支事務(wù)),默認(rèn)為長度為0的空字符串""
  • formatID:可選,用于標(biāo)識gtrid和bqual的格式,默認(rèn)為0

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

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

5.java借助jdbc使用xa事務(wù)

需要先引入jdbc的依賴,maven坐標(biāo)如下:

<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);
        //獲取事務(wù)管理器
        XAResource resourceManager1 = xa1.getXAResource();
        XAResource resourceManager2 = xa2.getXAResource();

        //構(gòu)造組成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è)務(wù)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è)務(wù)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,那么就不需要進(jìn)行分布式的二階段提交了
        boolean onePhase = false;
        //都準(zhǔn)備好了
        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í)行的日志信息如下:

在這里插入圖片描述

到此這篇關(guān)于MySQL分布式事務(wù)xa的介紹與使用小結(jié)的文章就介紹到這了,更多相關(guān)MySQL分布式事務(wù)xa內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家! 

相關(guān)文章

  • Mysql和文件系統(tǒng)的關(guān)聯(lián)詳情

    Mysql和文件系統(tǒng)的關(guān)聯(lián)詳情

    這篇文章主要介紹了Mysql和文件系統(tǒng)的關(guān)聯(lián)詳情,Mysql常用的存儲引擎如InnoDB、MyISAM采用的是文件存儲,自然和文件系統(tǒng)掛鉤,那么Mysql都有哪些地方用到了文件系統(tǒng)呢,下面我們一起進(jìn)入文章學(xué)習(xí)詳細(xì)內(nèi)容吧
    2022-09-09
  • 用MySQL創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表代碼

    用MySQL創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表代碼

    了解了一些最基本的操作命令后,我們再來學(xué)習(xí)如何創(chuàng)建一個數(shù)據(jù)庫和數(shù)據(jù)庫表。
    2008-10-10
  • 一文了解MySQL的四大子查詢

    一文了解MySQL的四大子查詢

    本文主要介紹了一文了解MySQL的四大子查詢,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-06-06
  • MySQL筆記之?dāng)?shù)學(xué)函數(shù)詳解

    MySQL筆記之?dāng)?shù)學(xué)函數(shù)詳解

    本篇文章對MySQL的數(shù)學(xué)函數(shù)進(jìn)行了詳細(xì)的介紹。需要的朋友參考下
    2013-05-05
  • Mysql 執(zhí)行一條語句的整個過程詳細(xì)

    Mysql 執(zhí)行一條語句的整個過程詳細(xì)

    這篇文章主要介紹了Mysql 執(zhí)行一條語句的整個詳細(xì)過程,Mysql的邏輯架構(gòu)整體分為兩部分,Server層和存儲引擎層,下面文章內(nèi)容具有一定的參考價值,需要的小伙伴可以參考一下,希望對你有所幫助
    2022-02-02
  • Linux(CentOS7)安裝MySQL8全過程

    Linux(CentOS7)安裝MySQL8全過程

    這篇文章主要介紹了Linux(CentOS7)安裝MySQL8全過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-06-06
  • mysql?字段括號拼接的實現(xiàn)示例

    mysql?字段括號拼接的實現(xiàn)示例

    在使用MySQL進(jìn)行數(shù)據(jù)查詢時,有時候需要對字段進(jìn)行拼接,并用括號包圍起來,本文主要介紹了mysql?字段括號拼接的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下
    2024-01-01
  • mysql 8.0.15 安裝圖文教程及數(shù)據(jù)庫基礎(chǔ)

    mysql 8.0.15 安裝圖文教程及數(shù)據(jù)庫基礎(chǔ)

    這篇文章主要為大家詳細(xì)介紹了mysql 8.0.15 安裝方法圖文教程,及數(shù)據(jù)庫基礎(chǔ)知識,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-03-03
  • Mysql聯(lián)合查詢UNION和UNION ALL的使用介紹

    Mysql聯(lián)合查詢UNION和UNION ALL的使用介紹

    本文詳細(xì)介紹了Mysql的聯(lián)合查詢命令UNION和UNION ALL,總結(jié)了使用語法和注意事項,以及學(xué)習(xí)例子和項目例子,需要的朋友可以參考下
    2014-04-04
  • MySQL PHP語法淺析

    MySQL PHP語法淺析

    在本篇文章里小編給大家分享了關(guān)于MySQL PHP語法的相關(guān)知識點,需要的朋友們學(xué)習(xí)參考下。
    2019-02-02

最新評論