📚 课程目录第2章传统分布式事务方案

2. 传统分布式事务方案：两阶段提交(2PC)原理、三阶段提交(3PC)原理、XA协议与JTA规范

在分布式系统架构中，事务的原子性与一致性面临网络分区、节点故障等挑战。传统分布式事务方案以两阶段提交（2PC）和三阶段提交（3PC）为核心，配合XA协议与JTA规范，构成了早期分布式事务的基石。本章将深入剖析这些方案的原理、流程与局限性。

2.1 两阶段提交（2PC）原理

2PC 是一种协调者-参与者模型，通过引入一个全局协调者（Coordinator）来管理多个参与者（Participant）的事务提交。整个过程分为两个阶段：准备阶段（Voting Phase）和提交阶段（Commit Phase）。

2.1.1 核心流程

准备阶段：协调者向所有参与者发送“准备”请求，参与者执行事务但不提交，并返回“同意”或“中止”投票。
提交阶段：如果所有参与者都返回“同意”，协调者发送“提交”指令；否则发送“回滚”指令。

  关键特性：2PC 是阻塞协议。在准备阶段，参与者持有资源锁，直到收到协调者的最终决定。若协调者崩溃，参与者将长时间阻塞。

2.1.2 2PC 的优缺点

维度	说明
优点	原理简单，实现成熟；强一致性保证（所有节点要么都提交，要么都回滚）。
缺点	同步阻塞（参与者持有锁）；单点故障（协调者崩溃导致阻塞）；数据不一致（协调者发送部分提交后崩溃）。

避坑提示：2PC 在协调者崩溃且参与者无法获取决策时，会进入“悬而未决”状态，导致资源锁长期占用。生产环境中需配合超时机制和人工干预。

2.2 三阶段提交（3PC）原理

3PC 是 2PC 的改进版本，引入超时机制和预提交阶段，减少阻塞时间。它将提交过程拆分为三个阶段：CanCommit、PreCommit 和 DoCommit。

2.2.1 核心流程

CanCommit 阶段：协调者询问参与者是否可以执行事务，参与者仅检查自身状态，不执行操作。
PreCommit 阶段：协调者发送预提交请求，参与者执行事务并写入 undo/redo 日志，但不提交。
DoCommit 阶段：协调者发送最终提交或回滚指令。

  关键改进：3PC 引入了超时中断机制。参与者在 PreCommit 阶段后若未收到协调者指令，会主动提交（避免无限阻塞）。但这也带来了数据不一致的风险。

2.2.2 2PC 与 3PC 对比

对比维度	2PC	3PC
阶段数	2 个阶段	3 个阶段
阻塞性	高（参与者阻塞等待协调者）	低（参与者超时可自行提交）
单点故障	协调者崩溃导致系统阻塞	协调者崩溃影响较小
数据一致性	强一致性（但可能因部分提交而中断）	最终一致性（超时提交可能导致不一致）
适用场景	对一致性要求极高、网络可靠	对可用性要求较高、允许短暂不一致

2.3 XA 协议与 JTA 规范

XA 协议是 X/Open 组织定义的分布式事务处理规范，定义了事务管理器（TM）与资源管理器（RM）之间的接口。XA 协议基于 2PC 实现，是数据库层面分布式事务的标准。

JTA（Java Transaction API）是 Java 平台对 XA 协议的实现规范，提供了 UserTransaction、TransactionManager 等接口，允许 Java 应用在多个数据库或消息队列间执行分布式事务。

2.3.1 XA 协议核心接口

接口	说明
`xa_start`	开始一个 XA 事务分支
`xa_end`	结束当前事务分支
`xa_prepare`	准备阶段（对应 2PC 的准备）
`xa_commit`	提交事务分支
`xa_rollback`	回滚事务分支
`xa_recover`	恢复未完成的事务分支

2.3.2 JTA 编程示例

import javax.transaction.UserTransaction;
import javax.naming.InitialContext;

public class XAExample {
    public void transferMoney() throws Exception {
        UserTransaction utx = (UserTransaction) new InitialContext()
                .lookup("java:comp/UserTransaction");

        try {
            utx.begin();

            // 操作数据库 A
            DataSource dsA = ...;
            Connection connA = dsA.getConnection();
            // 执行 SQL 更新

            // 操作数据库 B
            DataSource dsB = ...;
            Connection connB = dsB.getConnection();
            // 执行 SQL 更新

            utx.commit();  // 全局提交（2PC）
        } catch (Exception e) {
            utx.rollback();  // 全局回滚
            throw e;
        }
    }
}

实践建议：XA/JTA 适用于短事务、低并发场景。在高并发或长事务场景下，锁竞争和性能开销会显著增加。现代微服务架构更倾向于使用 Saga 模式或 TCC（Try-Confirm-Cancel）模式替代 XA。

2.4 传统方案的局限性总结

性能瓶颈：2PC/3PC 需要多次网络交互，事务延迟高。
锁竞争：资源锁在事务期间持续持有，降低系统吞吐量。
单点故障：协调者成为系统脆弱点。
扩展性差：难以支持跨异构资源（如数据库 + 消息队列 + 缓存）的分布式事务。