6 张图带你彻底搞懂分布式事务 XA 模式
xsobi 2025-04-27 17:16 11 浏览
XA 协议是由 X/Open 组织提出的分布式事务处理规范,主要定义了事务管理器 TM 和局部资源管理器 RM 之间的接口。目前主流的数据库,比如 oracle、DB2 都是支持 XA 协议的。
mysql 从 5.0 版本开始,innoDB 存储引擎已经支持 XA 协议,今天的源码介绍实验环境使用的是 mysql 数据库。
两阶段提交
分布式事务的两阶段提交是把整个事务提交分为 prepare 和 commit 两个阶段。以电商系统为例,分布式系统中有订单、账户和库存三个服务,如下图:
第一阶段,事务协调者向事务参与者发送 prepare 请求,事务参与者收到请求后,如果可以提交事务,回复 yes,否则回复 no。
第二阶段,如果所有事务参与者都回复了 yes,事务协调者向所有事务参与者发送 commit 请求,否则发送 rollback 请求。
两阶段提交存在三个问题:
- 同步阻塞,本地事务在 prepare 阶段锁定资源,如果有其他事务也要修改 xiaoming 这个账户,就必须等待前面的事务完成。这样就造成了系统性能下降。
- 协调节点单点故障,如果第一个阶段 prepare 成功了,但是第二个阶段协调节点发出 commit 指令之前宕机了,所有服务的数据资源处于锁定状态,事务将无限期地等待。
- 数据不一致,如果第一阶段 prepare 成功了,但是第二阶段协调节点向某个节点发送 commit 命令时失败,就会导致数据不一致。
三阶段提交
为了解决两阶段提交的问题,三阶段提交做了改进:
- 在协调节点和事务参与者都引入了超时机制。
- 第一阶段的 prepare 阶段分成了两步,canCommi 和 preCommit。
如下图:
引入 preCommit 阶段后,协调节点会在 commit 之前再次检查各个事务参与者的状态,保证它们的状态是一致的。但是也存在问题,那就是如果第三阶段发出 rollback 请求,有的节点没有收到,那没有收到的节点会在超时之后进行提交,造成数据不一致。
XA 事务语法介绍
xa 事务的语法如下:
- 三阶段的第一阶段:开启 xa 事务,这里 xid 为全局事务 id:
XA {START|BEGIN} xid [JOIN|RESUME]
结束 xa 事务:
XA END xid [SUSPEND [FOR MIGRATE]]
- 三阶段的第二阶段,即 prepare:
XA PREPARE xid
- 三阶段的第三阶段,即 commit/rollback:
XA COMMIT xid [ONE PHASE]
XA ROLLBACK xid
- 查看处于 PREPARE 阶段的所有事务:
XA RECOVER XA RECOVER [CONVERT XID]
seata XA 简介
seata 是阿里推出的一款开源分布式事务解决方案,目前有 AT、TCC、SAGA、XA 四种模式。
seata 的 XA 模式是利用分支事务中数据库对 XA 协议的支持来实现的。我们看一下 seata 官网的介绍:[1]
从上面的图可以看到,seata XA 模式的流程跟其他模式一样:
- TM 开启全局事务
- RM 向 TC 注册分支事务
- RM 向 TC 报告分支事务状态
- TC 向 RM 发送 commit/rollback 请求
- TM 结束全局事务
这里介绍一下 RM 客户端初始化关联的 UML 类图:[2]
这个图中有一个类是
AbstractNettyRemotingClient,这个类的内部类 ClientHandler 来处理 TC 发来的请求并委托给父类 AbstractNettyRemoting 的 processMessage 方法来处理。processMessage 方法调用 RmBranchCommitProcessor 类的 process 方法。
需要注意的是,「seata 的 xa 模式对传统的三阶段提交做了优化,改成了两阶段提交」:
- 第一阶段首执行 XA 开启、执行 sql、XA 结束三个步骤,之后直接执行 XA prepare。
- 第二阶段执行 XA commit/rollback。
mysql 目前是支持 seata xa 模式的两阶段优化的。
「但是这个优化对 oracle 不支持,因为 oracle 实现的是标准的 xa 协议,即 xa end 后,协调节点向事务参与者统一发送 prepare,最后再发送 commit/rollback。这也导致了 seata 的 xa 模式对 oracle 支持不太好。」
seata XA 源码
seata 中的 XA 模式是使用数据源代理来实现的,需要手动配置数据源代理,代码如下:
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DruidDataSource druidDataSource() {
return new DruidDataSource();
}
@Bean("dataSourceProxy")
public DataSource dataSource(DruidDataSource druidDataSource) {
return new DataSourceProxyXA(druidDataSource);
}
- 也可以根据普通 DataSource 来创建 XAConnection,但是这种方式有兼容性问题(比如 oracle),所以 seata 使用了开发者自己配置 XADataSource。
- seata 提供的 XA 数据源代理,要求代码框架中必须使用 druid 连接池。
1. XA 第一阶段
当 RM 收到 DML 请求后,seata 会使用 ExecuteTemplateXA来执行,执行方法 execute 中有一个地方很关键,就是把 autocommit 属性改为了 false,而 mysql 默认 autocommit 是 true。事务提交之后,还要把 autocommit 改回默认。
下面我们看一下 XA 第一阶段提交的主要代码。
1)开启 XA
上面代码标注[1]处,调用了 ConnectionProxyXA 类的 setAutoCommit 方法,这个方法的源代码中,XA start 主要做了三件事:
- 向 TC 注册分支事务
- 调用数据源的 XA Start
xaResource.start(this.xaBranchXid, XAResource.TMNOFLAGS);
- 把 xaActive 设置为 true
RM 并没有直接使用 TC 返回的 branchId 作为 xa 数据源的 branchId,而是使用全局事务 id(xid) 和 branchId 重新构建了一个。
2)执行 sql
调用 PreparedStatementProxyXA 的 execute 执行 sql。
3)XA end/prepare
public void commit() throws SQLException {
//省略部分源代码
try {
// XA End: Success
xaResource.end(xaBranchXid, XAResource.TMSUCCESS);
// XA Prepare
xaResource.prepare(xaBranchXid);
// Keep the Connection if necessary
keepIfNecessary();
} catch (XAException xe) {
try {
// Branch Report to TC: Failed
DefaultResourceManager.get().branchReport(BranchType.XA, xid, xaBranchXid.getBranchId(),
BranchStatus.PhaseOne_Failed, null);
} catch (TransactionException te) {
//这儿只打印了一个warn级别的日志
}
throw new SQLException(
"Failed to end(TMSUCCESS)/prepare xa branch on " + xid + "-" + xaBranchXid.getBranchId() + " since " + xe
.getMessage(), xe);
} finally {
cleanXABranchContext();
}
}
从这个源码我们看到,commit 主要做了三件事:
- 调用数据源的 XA end
- 调用数据源的 XA prepare
- 向 TC 报告分支事务状态
到这里我们就可以看到,seata 把 xa 协议的前两个阶段合成了一个阶段。
2. XA commit
这里的调用关系用一个时序图来表示:
看一下 RmBranchCommitProcessor 类的 process 方法,代码如下:
@Override
public void process(ChannelHandlerContext ctx, RpcMessage rpcMessage) throws Exception {
String remoteAddress = NetUtil.toStringAddress(ctx.channel().remoteAddress());
Object msg = rpcMessage.getBody();
if (LOGGER.isInfoEnabled()) {
LOGGER.info("rm client handle branch commit process:" + msg);
}
handleBranchCommit(rpcMessage, remoteAddress, (BranchCommitRequest) msg);
}
从调用关系时序图可以看出,上面的 handleBranchCommit 方法最终调用了 AbstractRMHandler 的 handle 方法,最后通过 branchCommit 方法调用了 ResourceManagerXA 类的 finishBranch 方法。
ResourceManagerXA 类是 XA 模式的资源管理器,看下面这个类图,也就是 seata 中资源管理器(RM)的 UML 类图:
上面的 finishBranch 方法调用了
connectionProxyXA.xaCommit 方法,我们最后看一下 xaCommit 方法:
public void xaCommit(String xid, long branchId, String applicationData) throws XAException {
XAXid xaXid = XAXidBuilder.build(xid, branchId);
//因为使用mysql,这里xaResource是MysqlXAConnection
xaResource.commit(xaXid, false);
releaseIfNecessary();
}
上面调用了数据源的 commit 方法,提交了 RM 分支事务。
到这里,整个 RM 分支事务就结束了。Rollback 的代码逻辑跟 commit 类似。
最后要说明的是,上面的 xaResource,是 mysql-connector-java.jar 包中的 MysqlXAConnection 类实例,它封装了 mysql 提供的 XA 协议接口。
总结
seata 中 XA 模式的实现是使用数据源代理完成的,底层使用了数据库对 XA 协议的原生支持。
mysql 的 java 驱动库中,MysqlXAConnection 类封装类 XA 协议的底层接口供外部调用。
跟 TCC 和 SAGA 模式需要在业务代码中实现 prepare/commit/rollback 逻辑相比,XA 模式对业务代码无侵入。
Reference
[1]:http://seata.io/zh-cn/docs/overview/what-is-seata.html
[2]:https://github.com/seata/seata
作者 | 朱晋君
本文为阿里云原创内容,未经允许不得转载。
- 上一篇:一文带你理解URI 和 URL 有什么区别?
- 下一篇:CSS3 基础知识
相关推荐
- 不要过度使用列表(List): C# 数据结构
-
编程中的每一个决定都会对性能和清晰度产生无声的影响。在C#中,这样重要的选择之一就是选择正确的数据结构。数据结构是基础支柱。这些结构是数据生存、呼吸和交互的地方,决定了代码的效率和可读性。但...
- Power Query中使用List.Accumulate函数做分组操作
-
在Excel中对于分数评级,最简单快捷的办法就是用VLOOKUP函数了,评级的条件可以使用做好的评级表格,也可以直接用数组写在公式内部。或者这样:在PowerQuery中我们用什么办法才能做到这样的...
- C#夯实基础-Lambda在List中的使用
-
在C#中基本类型比如List,Dictionary,数组等都有委托来实现相关的操作。此时Lambda表达式就可以使用了.实例1,查找字符串List的包含a的元素代码//字符串型的listList&...
- JAVA中ArrayList、LinkedList及CopyOnWriteArrayList实现原理
-
ArrayList,LinkedList的存储性能和特性?1、是否保证线程安全:ArrayList和LinkedList都不保证线程安全,如果要线程安全用CopyOnWriteArrayLis...
- js将list转化为tree格式的几种写法
-
最近在考虑一个树状结构存储。最终需要将list转化为tree格式源数据示例源数据共401条[{"menuId":"5f50c5fb8f0d74536bbfb7a4"...
- 列表框(List Box)之应用实例(列表框方法)
-
【分享成果,随喜正能量】人生是需要等候的,等候一阵风的拂过,等候一朵花的盛开,等候伊人的到来,等候生命爆发的强音。心灵是需要在等候中坚守的,坚守无风的日月,坚守落花的寂寞,坚守情感的空白,坚守生活的平...
- 不会用list的程序员不是好程序员,C++标准容器list类实例详解
-
C++中的list(列表)是顺序容器,其中存储的元素并不是内存连续的,这一点和上一节讨论的deque是类似的。list容器类的特点稍后几节将要讨论的C++中的vector(向量)容器中的元素...
- CopyOnWriteArrayList 读写分离,弱一致性
-
为什么会有CopyOnWriteArrayList?我们知道ArrayList和LinkedList实现的List都是非线程安全的,于是就有了Vector,它是基于ArrayList的线程安全集合,但...
- Java 中List 和数组之间互相转换的方法
-
在Java中,List和数组之间的互相转换是非常常见的操作。以下是常用的方法及其示例代码:1.数组转List方法1:使用Arrays.asList()特点:返回的List是一个固定大小...
- VBA数组进阶调用.NET ArrayList(vba function 数组参数)
-
之前很多文章都讲过VBA数组。但是VBA数组比较鸡肋,功能比较弱,使用起来不是很方便,需要自行封装很多数组方法,这对于新手来说很不友好。今天给大家讲讲,怎么用.Net自带的ArrayList扩展VBA...
- 面试官-如何实现数组和 List 之间的转换?
-
数组和List是Java开发中常见的两种数据结构,那么如何实现二者之间的快速转换就成了面试官常问的考点之一,下面我们我们就来从数组转List和List转数组两个方面来展开介绍一下。数组转List方法...
- Java 如何在 Array 和 List 之间进行转换
-
概述在本文章中,我们对如何在Java中对Array和List进行转换进行一些说明和示例。这些示例通过使用CoreJava和一些第三方的转换工具,例如Guava和ApacheC...
- Excel 进阶教程:ArrayList + VBA,轻松搞定复杂数据统计
-
在VBA(VisualBasicforApplications)中,ArrayList是一个动态数组对象,它提供了比普通VBA数组更强大的功能。ArrayList是.NETFram...
- Java并发工具:CopyOnWriteArrayList
-
CopyOnWriteArrayList是Java中java.util.concurrent包提供的一种线程安全的List实现。它特别适用于读多写少(Read-mostly)的并发场景,...
- 一起来聊聊Java中的ArrayList(java arrays.aslist)
-
提起ArrayList相信对于java开发人员来说并不会感到陌生,甚至会有种亲切感。好像每次出去面试,多多少少都会跟它扯上点关系。所以导致网上以及各大培训机构都对其源码有着丰富的解读。但是,本篇文章并...
- 一周热门
- 最近发表
-
- 不要过度使用列表(List): C# 数据结构
- Power Query中使用List.Accumulate函数做分组操作
- C#夯实基础-Lambda在List中的使用
- JAVA中ArrayList、LinkedList及CopyOnWriteArrayList实现原理
- js将list转化为tree格式的几种写法
- 列表框(List Box)之应用实例(列表框方法)
- 不会用list的程序员不是好程序员,C++标准容器list类实例详解
- CopyOnWriteArrayList 读写分离,弱一致性
- Java 中List 和数组之间互相转换的方法
- VBA数组进阶调用.NET ArrayList(vba function 数组参数)
- 标签列表
-
- grid 设置 (58)
- 移位运算 (48)
- not specified (45)
- 导航栏 (58)
- context xml (46)
- scroll (43)
- dedecms模版 (53)
- c 视频教程下载 (33)
- listview排序 (33)
- characterencodingfilter (33)
- getmonth (34)
- label换行 (33)
- android studio 3 0 (34)
- html转js (35)
- 索引的作用 (33)
- checkedlistbox (34)
- xmlhttp (35)
- mysql更改密码 (34)
- 权限777 (33)
- htmlposition (33)
- 学校网站模板 (34)
- textarea换行 (34)
- 轮播 (34)
- asp net三层架构 (38)
- bash (34)