mysql xid原理_MySQL数据库分布式事务XA实现原理分析
【IT168 技术】MySQL XA原理
MySQL XA分为两类,内部XA与外部XA;内部XA用于同一实例下跨多个引擎的事务,由大家熟悉的Binlog作为协调者;外部XA用于跨多MySQL实例的分布式事务,需要应用层介入作为协调者(崩溃时的悬挂事务,全局提交还是回滚,需要由应用层决定,对应用层的实现要求较高);
本文,假设读者已经知道MySQL数据库外部分布式事务XA的使用,而将重点放在MySQL数据库,如何处理外部分布式事务XA的crash recover,以及面对不同的crash recover的情形,应用程序如何处理,才能够保证分布式事务的一致性。最后,本文简单分析一下目前MySQL数据库外部XA支持存在的问题,以及可选的解决方案。
源代码分析基于MySQL 5.1.49,MySQL 5.5.16。
MySQL处理流程
1.MySQL 外部XA – 正常处理流程
MySQL数据库外部XA的正常处理流程,这里不准备介绍,可以参考[1][2][3]。接下来我重点描述一下MySQL数据库外部分布式事务XA的崩溃恢复流程,毕竟此流程跟应用程序如何正确使用外部XA息息相关。
2.MySQL外部XA – 崩溃恢复流程
若一个运行外部XA分布式事务的MySQL数据库节点发生崩溃,那么其重启之后的崩溃恢复,涉及到外部XA处理的流程如下:
Crash recover:
// 1. 读取binlog文件,将文件中的xid存入commit_list hash表
// 顾名思义,所谓的commit_list,就是说此list中对应prepare状态的xid
// 在崩溃恢复过程中均可以被提交,而不在commit_list中的xid,均须回滚
// binlog中的xid,都是属于内部xid,由MySQL产生,用于内部XA
Log.cc::TC_LOG_BINLOG::recover
// 2. 遍历底层所有的事务引擎,收集处于XA_PREPARED状态的所有xid
// 这些xid列表,既包括内部xid,也包括外部xid,存储引擎内部不做区分
Handler.cc::ha_recover(commit_list)
// 执行各引擎层面提供的recover方法,收集所有的处于prepared状态的xid
// 根据xid分类:
// 3. 若xid属于内部xid,那么在commit_list中查找此xid,
// 若存在,则提交此xid对应的事务;否则,回滚此事务
// 4. 若xid属于外部xid,那么则将xid插入xid_cache hash表
// xid_cache中的所有xid,将会通过xa recover命令返回,等待外部程序决策
Handler.cc::xarecover_handlerton
// 5. 收集InnoDB存储引擎中,处于prepare状态的所有xid,并返回
got=hton->recover (innobase_xa_recover)
my_xid x=info->list[i].get_my_xid();if(!x)//若当前为外部xid,那么将xid插入xid_cache hash表
xid_cache_insert(&xid_cache, x);elseif(xincommit_list)//若当前为内部xid,同时此xid在binlog中存在,则提交
hton->commit_by_xid();else//若当前为内部xid,同时此xid在binlog中不存在,则回滚
hton->rollback_by_xid();
通过以上的分析,可以总结出:
MySQL数据库内部,会对xid做区分。内部xid有MySQL数据库自己产生(MySQL内部xid格式,将在本文下面给出),用于多引擎间事务的一致性;外部xid由应用程序给出,用于跨多MySQL实例的分布式事务。但是存储引擎层不做区分(区分在MySQL上层)。
crash recover时,存储引擎负责将引擎内部,处于prepare状态的事务收集,并返回MySQL上层。
Binlog作为内部XA的协调者[5],在binlog中出现的内部xid,在crash recover时,由binlog负责提交;在binlog中未出现的xid,由binlog负责回滚。(这是因为,binlog不进行prepare,只进行commit,因此在binlog中出现的内部xid,一定能够保证其在底层各存储引擎中已经完成prepare)。
外部XA事务的xid,在crash recover过程中仅仅是插入xid_cache中,而不做其他处理。等到用户发起xa recover命令时,将xid_cache中处于prepare状态的xid返回。
xa recover命令的流程处理如下。
xa recover命令处理流程:
sql_parse.cc::mysql_execute_commandcaseSQLCOM_XA_RECOVER:
mysql_xa_recover();//遍历xid_cache,找出其中的状态处于XA_PREPARED的事务,发送客户端while(xs=hash_element(&xid_cache,))if(xs->xa_state==XA_PREPARED)
protocol->write();
根据xa recover命令收集到的各MySQL数据库实例返回的xid列表,然后再对比应用程序端日志,决定这些xid,哪些全局commit,哪些rollback。
由于测试中只有一个MySQL数据库实例,因此此时可以直接选择commit处于prepare状态的xid。
注:
MySQL内部xid格式: MYSQL_XID_PREFIX + server_id + my_xid
MYSQL_XID_PREFIX: MySQLXid (源码写死) 8 bytes
server_id: MySQL实例的id,ulong, 4 bytes
my_xid: 内部自增序列,ulonglong, 8 bytes
例如:”MySQLXid 0004”
server_id = ‘ ’;my_xid = 4
因此,使用时应该注意,不要在外部构造这种形式的xid,否则MySQL数据库就会将内部xid与外部xid混淆。
一般情况下,构造一个内部xid比较困难,由于server_id一般小于4 bytes,不足的部分以ASCI NIL(null)补齐,而应用程序一般都不会构造此类的外部xid。
mysql xid原理_MySQL数据库分布式事务XA实现原理分析相关推荐
- mysql xa 实现_MySQL数据库分布式事务XA的实现原理分析
1 原理 关于MySQL数据库的分布式事务XA,分布式事务实现的原理,可见[3];关于MySQL XA的说明,可见[1][2]. MySQL XA分为两类,内部XA与外部XA;内部XA用于同一实例下跨 ...
- MySQL数据库分布式事务XA实现原理分析
MySQL XA分为两类,内部XA与外部XA;内部XA用于同一实例下跨多个引擎的事务,由大家熟悉的Binlog作为协调者;外部XA用于跨多MySQL实例的分布式事务,需要应用层介入作为协调者(崩溃时的 ...
- 深入解析:MySQL对分布式事务 XA Transactions 的支持
导读:MySQL对分布式事务(XA Transactions)进行了很好的支持,我们看看它是怎么做的,并实战验证其提供的分布式事务控制语句效果. MySQL从5.0.3开始,InnoDB存储引擎支持X ...
- 【网站架构】一招搞定90%的分布式事务,实打实介绍数据库事务、分布式事务的工作原理应用场景
大家好,欢迎来到停止重构的频道.本期,我们来聊一下数据库事务以及分布式事务. 大家都在强调事务的重要性,而分布式事务也说是微服务必备的.但又说事务会影响性能,分布式事务更是很复杂的东西.使得大家都很迷 ...
- 阿里分布式事务框架Seata原理解析
阿里分布式事务框架Seata原理解析 作者:伊凡的一天 链接:https://www.jianshu.com/p/044e95223a17 Seata框架是一个业务层的XA(两阶段提交)解决方案.在理 ...
- Seata分布式事务XA与AT全面解析
Seata 分布式事务 XA与AT Seata 是一款开源的分布式事务解决方案,star高达17300+,社区活跃度极高,致力于在微服务架构下提供高性能和简单易用的分布式事务服务. 注:本期分享借鉴于 ...
- 分布式事务框架Seata原理详解
本文来深度解析下分布式事务框架Seata原理,知其然知其所以然. 文章目录 Seata概述 什么是2PC二阶段提交协议 MySQL XA方案 Seata核心知识 Seata设计目标 Seata组成结构 ...
- mysql2阶段提交具体实现_ShardingSphere 4.x 分布式事务之实现原理
导览 本小节主要介绍ShardingSphere分布式事务的实现原理 两阶段XA事务 Seata柔性事务 两阶段事务-XA 实现原理 实现原理 ShardingSphere里定义了分布式事务的SPI接 ...
- 分布式事务之底层原理揭秘
, hi 大家好,今天分享一这篇文章,让大家彻底了解分布式原理,这个是后台开发必须掌握技能. 刚性事务 柔性事务 本地事务 分布式事务 单阶段原子提交协议 两阶段提交协议 定义 原理 性能 恢复 缺陷 ...
最新文章
- 并发编程--线程池与进程池
- springboot---mybits整合
- 万字长文,带你彻底理解EF Core5的运行机制,让你成为团队中的EF Core专家
- 【CASS精品教程】CASS 9.2 for AutoCAD2014启动提示文件加载,怎么处理?
- 搞定所有的跨域请求问题
- 《C++ Primer 第五版》(第6.1~6.3节) 函数形参和实参传递,可变参数列表和函数返回值
- mysql 触发器 库存管理_Mysql中的触发器(库存、用户订单中用到)
- 微信小程序瀑布流列表
- [Icehouse][cinder] volume状态为 error_deleting无法删除 的解决方案
- Web多媒体:编解码器和容器
- 芒果DB:mongodb
- [视频]AI 机器学习 深度学习 视频教程汇总
- 【图论·习题】同余最短路:跳楼机
- 零点起飞学java web_零点起飞学Java Web开发 (徐林林) 高清PDF扫描版 114M
- ios label内字体置顶_IOS_Vertically align UILabel文本置顶 | 学步园
- 蜗牛爬井题目c语言,【3年级】40、蜗牛爬井问题
- VIM 参考手册 For Vim version 7.3
- visual studio(vs)2022如何在解决方案中自动配置文件路径(如何向解决方案中批量添加文件)(如何将修改路径之后的的源文件添加到解决方案中)
- 世界十大骨传导耳机排行榜、实测主流骨传导耳机推荐解析必看榜单
- |2105|小泉的难题
热门文章
- R创建透视表(Pivot Tables)
- 基于TF-IDF编码进行文本聚类分析:文档成对相似性计算、层次聚类(链接矩阵、树形图dendrogram绘制、聚类标签)
- MMD_5b_ComputationalAdvertising
- 阿里云 Linux指令入门-文件与权限
- 平方的观测值表概率_中央气象台:“三九”大概率不会比“二九”更冷
- 关于短文本匹配的深度学习模型
- 复数 Complex Number 教程
- python 调用 javascript函数
- python opencv imread()函数,关于:灰度图(二维数组图),彩色图(三维数组图)
- 随机采样池化--S3Pool: Pooling with Stochastic Spatial Sampling