6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试

第一阶段,事务协调者向事务参与者发送 prepare 请求,事务参与者收到请求后,如果可以提交事务,回复 yes,否则回复 no。

第二阶段,如果所有事务参与者都回复了 yes,事务协调者向所有事务参与者发送 commit 请求,否则发送 rollback 请求。

两阶段提交存在三个问题:

  • 同步阻塞,本地事务在 prepare 阶段锁定资源,如果有其他事务也要修改 xiaoming 这个账户,就必须等待前面的事务完成。这样就造成了系统性能下降。

  • 协调节点单点故障,如果第一个阶段 prepare 成功了,但是第二个阶段协调节点发出 commit 指令之前宕机了,所有服务的数据资源处于锁定状态,事务将无限期地等待。

  • 数据不一致,如果第一阶段 prepare 成功了,但是第二阶段协调节点向某个节点发送 commit 命令时失败,就会导致数据不一致。

[](

)三阶段提交

==========================================================================

为了解决两阶段提交的问题,三阶段提交做了改进:

  • 在协调节点和事务参与者都引入了超时机制。

  • 第一阶段的 prepare 阶段分成了两步,canCommi 和 preCommit。

如下图:

6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试

引入 preCommit 阶段后,协调节点会在 commit 之前再次检查各个事务参与者的状态,保证它们的状态是一致的。但是也存在问题,那就是如果第三阶段发出 rollback 请求,有的节点没有收到,那没有收到的节点会在超时之后进行提交,造成数据不一致。

[](

)XA 事务语法介绍

==============================================================================

xa 事务的语法如下:

  1. 三阶段的第一阶段:开启 xa 事务,这里 xid 为全局事务 id:

XA {START|BEGIN} xid [JOIN|RESUME]



结束 xa 事务:


XA END xid [SUSPEND [FOR MIGRATE]]



  1. 三阶段的第二阶段,即 prepare:

XA PREPARE xid



  1. 三阶段的第三阶段,即 commit/rollback:

XA COMMIT xid [ONE PHASE]

XA ROLLBACK xid



  1. 查看处于 PREPARE 阶段的所有事务:

XA RECOVER XA RECOVER [CONVERT XID]



[](

)seata XA 简介

================================================================================

seata 是阿里推出的一款开源分布式事务解决方案,目前有 AT、TCC、SAGA、XA 四种模式。

seata 的 XA 模式是利用分支事务中数据库对 XA 协议的支持来实现的。我们看一下 seata 官网的介绍:[1]

6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试

从上面的图可以看到,seata XA 模式的流程跟其他模式一样:

  1. TM 开启全局事务

  2. RM 向 TC 注册分支事务

  3. RM 向 TC 报告分支事务状态

  4. TC 向 RM 发送 commit/rollback 请求

  5. TM 结束全局事务

这里介绍一下 RM 客户端初始化关联的 UML 类图:[2]

6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试

这个图中有一个类是 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

**
6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试

6 张图带你彻底搞懂分布式事务 XA 模式,准备Java面试
由于篇幅限制,文档的详解资料太全面,细节内容太多,所以只把部分知识点截图出来粗略的介绍,每个小节点里面都有更细化的内容!

大家看完有什么不懂的可以在下方留言讨论也可以关注。

觉得文章对你有帮助的话记得关注我点个赞支持一下!

ttps://upload-images.jianshu.io/upload_images/24195226-7282694889a8660c.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

[外链图片转存中…(img-Fsb6alal-1631366746672)]
由于篇幅限制,文档的详解资料太全面,细节内容太多,所以只把部分知识点截图出来粗略的介绍,每个小节点里面都有更细化的内容!

大家看完有什么不懂的可以在下方留言讨论也可以关注。

觉得文章对你有帮助的话记得关注我点个赞支持一下!

上一篇:腾讯云TDSQL MySQL版 - 开发指南 分布式事务


下一篇:H3C交换机新版本Telnet关闭密码复杂性