XA分布式事务

XA基本原理在分布式数据库如你正在研究的TDSQL中XA 分布式事务是保证跨多个节点操作时数据“要么全成功要么全回滚”的标准方案。它是一种基于强一致性的设计在金融级场景中应用广泛。1. 什么是 XAXA 是由 X/Open 组织提出的分布式事务处理标准。它定义了三个核心组件之间的交互应用程序 (AP)定义事务的边界开始、提交、回滚。资源管理器 (RM)通常指数据库如 MySQL、Oracle。它们负责管理实际的数据。事务管理器 (TM)也就是协调器。负责统筹全局协调所有 RM 的状态。2.核心机制两阶段提交 (2PC) 的完整流程在分布式数据库如 TDSQL中2PC 旨在将跨多个分片Set的操作封装为一个原子事务。该过程由事务管理器TM如 SQL 引擎统一调度各资源管理器RM如 MySQLAgent协同配合。第一阶段准备阶段 (Prepare Phase)此阶段的目标是“探测”所有参与者是否具备提交事务的能力并锁定必要资源。下发预提议TM 向所有参与该事务的 RM 发送XA PREPARE指令。资源锁定与日志落盘RM 在本地执行 SQL 操作。RM 记录Redo Log用于故障恢复和Undo Log用于回滚。RM 锁定相关的数据库行记录防止其他事务修改。反馈承诺若执行成功RM 返回Ready状态并承诺只要 TM 要求提交它一定能成功。若因锁冲突或空间不足失败RM 返回Fail。第二阶段提交与确认阶段 (Commit ACK Phase)此阶段根据第一阶段的投票结果执行“全成”或“全败”的最终决策。决策逻辑全局提交只有当所有 RM 都反馈Ready时TM 才在日志中标记事务为“已决定提交”并广播XA COMMIT。全局回滚只要有任意一个 RM 反馈Fail或超时未响应TM 广播XA ROLLBACK。执行与释放RM 接收到COMMIT指令后正式修改数据状态并释放持有的物理锁。确认回执 (ACK)RM 在完成本地提交后必须向 TM 发送ACK 确认信号。事务终结TM 收集到所有 RM 的 ACK 后认为该分布式事务生命周期彻底结束从内存中抹除事务状态并向客户端返回成功。如何解决丢包与宕机问题根据不同的阶段和丢包发生的时刻处理机制有所不同。我们可以分情况来看1. 情况一第一阶段Prepare的响应丢包场景SQL 引擎协调器发送了PREPARE某个 Set 执行成功并返回了Ready但这个响应包在网络中丢了。结果SQL 引擎在规定的超时时间内没有收到该 Set 的回复。处理SQL 引擎会认为该节点可能发生了故障或网络中断。为了保证绝对安全SQL 引擎会向所有涉及到的 Set 发送ROLLBACK指令。状态此时所有 Set 都会回滚事务以失败告终保证了原子性。2. 情况二第二阶段Commit的指令丢包场景所有 Set 都返回了Ready。SQL 引擎发出了COMMIT指令但发往其中一个 Set 的指令包丢了。结果其他 Set 成功提交了但那个丢包的 Set 还傻傻地带着锁在等指令。处理重试机制推模式SQL 引擎作为协调器会记录事务日志。如果发现某个 Set 没有确认 Commit 成功它会不断地重试发送COMMIT指令直到该 Set 成功接收并返回确认为止。Agent 的作用拉模式在 TDSQL 架构中分布在各机器上的Agent会发现本地有一个“处于 Prepare 状态但超时的事务”它会去询问 ZooKeeper 或管理节点“这个事务到底该不该提” 一旦得到确认为CommitAgent 会在本地强制 MySQL 完成提交。3. 最危险的情况协调器与参与者同时宕机如果 SQL 引擎在刚发出第一个COMMIT包后就挂了且接收到包的 Set 也挂了。问题剩下的 Set 处于Ready状态它们不敢私自提交万一有人失败了呢也不敢私自回滚万一协调器已经让别人提交了呢。这就造成了资源阻塞。TDSQL 的解决办法利用 ZooKeeperTDSQL 将全局事务的状态记录在强一致性的ZooKeeper中。故障自愈当新的 SQL 引擎新协调器通过选举产生后它会去 ZooKeeper 读取未完成的事务状态。如果发现事务标记为“已决定提交”它会通知所有 Set 继续执行。为什么重试要推拉模式结合之所以“推”和“拉”都要本质上是为了在性能、实时性和极端容灾之间取得平衡。为什么不能只有“推模式”协调者重试核心问题无法处理“协调者单点崩溃”。场景陷阱如果 SQL 引擎协调者在发出一半COMMIT指令后突然宕机而此时网络又发生了丢包。后果由于协调者已经“死了”没人会再发起重试。那些没收到指令的 Set 会一直保持PREPARED状态死死锁住数据库资源。结论只靠“推”在协调者出故障时整个集群会陷入长时间的死锁阻塞直到人工干预。这在金融场景下是不可接受的。为什么不能只有“拉模式”Agent 主动询问核心问题实时性差且对核心组件压力巨大。效率低下Agent 扫描本地事务并询问 ZooKeeper 通常是定时触发的比如每 5 秒或 10 秒一次。如果只靠“拉”每次网络抖动导致的丢包都要等几秒钟才能恢复这会显著拉低系统的吞吐量。“惊群效应”与性能损耗如果一个事务涉及 100 个 Set丢包后这 100 个 Agent 都去疯狂询问 ZooKeeper会给 ZK 带来巨大的瞬间压力。频繁轮询本地事务表也会消耗数据库服务器的 CPU 和 IO。结论只靠“拉”系统会变得非常“迟钝”且在高并发场景下容易产生不必要的性能瓶颈。XA 事务的优缺点优点缺点强一致性最接近单机数据库的体验不会出现中间状态。性能损耗高两次网络往返RTT且在整个过程中会长时间占用数据库锁。业务透明由底层架构处理开发者不需要写复杂的补偿逻辑。同步阻塞如果 TM 在第二阶段前宕机参与者会陷入等待资源无法释放。行业标准主流数据库MySQL, PostgreSQL, Oracle原生支持。单点故障对协调器TM的依赖性极强。