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常用的存儲引擎如InnoDB、MyISAM采用的是文件存儲,自然和文件系統(tǒng)掛鉤,那么Mysql都有哪些地方用到了文件系統(tǒng)呢,下面我們一起進(jìn)入文章學(xué)習(xí)詳細(xì)內(nèi)容吧2022-09-09用MySQL創(chuàng)建數(shù)據(jù)庫和數(shù)據(jù)庫表代碼
了解了一些最基本的操作命令后,我們再來學(xué)習(xí)如何創(chuàng)建一個數(shù)據(jù)庫和數(shù)據(jù)庫表。2008-10-10MySQL筆記之?dāng)?shù)學(xué)函數(shù)詳解
本篇文章對MySQL的數(shù)學(xué)函數(shù)進(jìn)行了詳細(xì)的介紹。需要的朋友參考下2013-05-05mysql 8.0.15 安裝圖文教程及數(shù)據(jù)庫基礎(chǔ)
這篇文章主要為大家詳細(xì)介紹了mysql 8.0.15 安裝方法圖文教程,及數(shù)據(jù)庫基礎(chǔ)知識,具有一定的參考價值,感興趣的小伙伴們可以參考一下2019-03-03Mysql聯(lián)合查詢UNION和UNION ALL的使用介紹
本文詳細(xì)介紹了Mysql的聯(lián)合查詢命令UNION和UNION ALL,總結(jié)了使用語法和注意事項,以及學(xué)習(xí)例子和項目例子,需要的朋友可以參考下2014-04-04