4、分布式事务模型：XA协议、TCC模式、Saga模式、本地消息表、事务消息（RocketMQ）

在分布式系统压测场景中，事务一致性是验证的核心难点。本章系统梳理五种主流分布式事务模型，从原理、适用场景到压测关注点逐一拆解，为后续gRPC接口的分布式事务压测脚本设计奠定理论基础。

4.1 分布式事务模型全景对比

五种模型在一致性强度、侵入性、性能与复杂度上各有取舍。下表从压测视角给出关键差异：

4.2 XA协议（2PC）

XA协议基于两阶段提交（2PC），由事务协调器（TM）与资源管理器（RM）协作完成。第一阶段准备（Prepare），RM锁定资源并返回就绪；第二阶段提交/回滚（Commit/Rollback），TM根据所有RM的反馈做最终决策。

4.3 TCC模式（Try-Confirm-Cancel）

TCC将每个服务接口拆分为三个阶段：Try（资源预留）、Confirm（确认执行）、Cancel（取消回滚）。业务方需自行实现幂等与补偿逻辑。

4.4 Saga模式

Saga将长事务拆分为多个本地事务，每个本地事务对应一个补偿事务。执行过程中若某一步失败，则按反向顺序依次调用补偿操作。Saga分为编排（Choreography）与协调（Orchestration）两种实现方式。

4.5 本地消息表

本地消息表的核心思想是将业务操作与消息发送放在同一个本地事务中。业务表更新成功后，消息记录写入本地消息表；后台轮询任务扫描未发送的消息，异步投递到MQ，下游消费方处理成功后回调确认。

-- 本地消息表结构示例
CREATE TABLE local_message (
    id          BIGINT PRIMARY KEY AUTO_INCREMENT,
    biz_id      VARCHAR(64)   NOT NULL COMMENT '业务ID',
    msg_body    TEXT          NOT NULL COMMENT '消息体（JSON）',
    status      TINYINT       NOT NULL DEFAULT 0 COMMENT '0-待发送 1-已发送 2-已确认',
    retry_count INT           NOT NULL DEFAULT 0,
    create_time DATETIME      NOT NULL,
    update_time DATETIME      NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

4.6 事务消息（RocketMQ）

RocketMQ事务消息通过半消息（Half Message）与事务回查机制，将本地事务与消息发送解耦为原子操作。流程如下：

1. 发送半消息：生产者向RocketMQ发送半消息（对消费者不可见）。
2. 执行本地事务：生产者执行本地业务逻辑。
3. 提交/回滚：根据本地事务结果，向MQ发送Commit或Rollback指令。
4. 事务回查：若MQ长时间未收到Commit/Rollback，主动回调生产者查询事务状态。
5. 消费者消费：只有Commit后的消息才会被消费者可见并消费。

4.7 五种模型压测场景总结