标签：事务 xa Java seata XA 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 注册分支事务
最后
在面试前我整理归纳了一些面试学习资料，文中结合我的朋友同学面试美团滴滴这类大厂的资料及案例
**[CodeChina开源项目：【一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频】](
)
网盘：pan.baidu.com/s/1MtPP4d9Xy3qb7zrF4N8Qpg
提取码：2p8n
**
由于篇幅限制，文档的详解资料太全面，细节内容太多，所以只把部分知识点截图出来粗略的介绍，每个小节点里面都有更细化的内容！
大家看完有什么不懂的可以在下方留言讨论也可以关注。
觉得文章对你有帮助的话记得关注我点个赞支持一下！
ttps://upload-images.jianshu.io/upload_images/24195226-7282694889a8660c.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
[外链图片转存中…(img-Fsb6alal-1631366746672)]
由于篇幅限制，文档的详解资料太全面，细节内容太多，所以只把部分知识点截图出来粗略的介绍，每个小节点里面都有更细化的内容！
大家看完有什么不懂的可以在下方留言讨论也可以关注。
觉得文章对你有帮助的话记得关注我点个赞支持一下！
标签：事务,xa,Java,seata,XA,commit,搞懂,节点 来源： https://blog.csdn.net/m0_60707263/article/details/120243530
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。