news 2026/4/22 23:22:05

全局事务入口感知子事务方法-TCC

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
全局事务入口感知子事务方法-TCC

一、核心前提:两个注解的分工

注解定位核心作用执行时机
@GlobalTransactional全局事务入口标记 “主方法”,创建全局事务 XID,管控整体提交 / 回滚主方法执行前
@TwoPhaseBusinessActionTCC 子方法标记 “Try 方法”,绑定 Confirm/Cancel,声明为 TCC 分支子方法执行时(被主方法调用)

简单说:@GlobalTransactional是 “总指挥”,@TwoPhaseBusinessAction是 “小兵”—— 总指挥不会提前知道有哪些小兵,而是小兵执行时主动向总指挥 “报到”。

二、完整流程:从主方法执行到子方法绑定

步骤 1:拦截@GlobalTransactional,创建全局事务(主方法执行前)

Seata 通过GlobalTransactionalInterceptor拦截所有带@GlobalTransactional的主方法,核心逻辑:

java

运行

// GlobalTransactionalInterceptor.java public Object invoke(MethodInvocation invocation) throws Throwable { // 1. 检查是否有全局事务 XID(首次执行时为 null) String xid = RootContext.getXID(); if (xid == null) { // 2. 创建全局事务,生成唯一 XID(如:127.0.0.1:8091:123456) GlobalTransaction tx = GlobalTransactionContext.createNew(); // 3. 开启全局事务(更新 global_table 状态为 “开始”) tx.begin(/* 超时时间 */, /* 事务名称 */); // 4. 将 XID 绑定到当前线程(ThreadLocal) RootContext.bind(tx.getXid()); } try { // 5. 执行主方法(此时会调用所有带 @TwoPhaseBusinessAction 的子方法) return invocation.proceed(); } catch (Exception e) { // 6. 异常时回滚全局事务(触发 Cancel 方法) GlobalTransactionContext.getCurrent().rollback(); throw e; } finally { // 7. 无异常则提交全局事务(触发 Confirm 方法) if (RootContext.getXID() != null) { GlobalTransactionContext.getCurrent().commit(); RootContext.unbind(); // 清除线程绑定的 XID } } }

关键:此时仅创建了全局事务 XID 并绑定到当前线程,还不知道任何 TCC 子方法的存在。

步骤 2:拦截@TwoPhaseBusinessAction,注册分支事务(子方法执行时)

当主方法执行到带@TwoPhaseBusinessAction的子方法时,Seata 通过TccActionInterceptor拦截该子方法,核心逻辑:

java

运行

// TccActionInterceptor.java public Object invoke(MethodInvocation invocation) throws Throwable { // 1. 检查当前线程是否有全局事务 XID(主方法已绑定) String xid = RootContext.getXID(); if (xid == null) { // 无全局事务:直接执行方法(非 TCC 分支,仅普通方法) return invocation.proceed(); } // 2. 解析 @TwoPhaseBusinessAction 注解(绑定 Confirm/Cancel 方法) Method tryMethod = invocation.getMethod(); TwoPhaseBusinessAction tccAnnotation = tryMethod.getAnnotation(TwoPhaseBusinessAction.class); TccAction tccAction = TccActionParser.parse(tryMethod); // 解析出 Try/Confirm/Cancel 方法 // 3. 注册 TCC 分支事务(核心:将子方法关联到全局事务 XID) BranchRegistration branchReg = new BranchRegistration(); branchReg.setXid(xid); branchReg.setBranchType(BranchType.TCC); branchReg.setResourceId(/* TCC 方法唯一标识:类名+方法名 */); branchReg.setApplicationData(/* 序列化 TccAction 对象(含 Confirm/Cancel) */); // 调用 Seata Server 注册分支,返回分支 ID Long branchId = TccResourceManager.INSTANCE.branchRegister(branchReg); try { // 4. 执行 Try 方法(业务逻辑:如冻结金额、预留资源) Object result = invocation.proceed(); // 5. 标记分支事务“Try 阶段完成” TccResourceManager.INSTANCE.branchReport(xid, branchId, BranchStatus.PhaseOne_Done); return result; } catch (Exception e) { // 6. Try 失败:标记分支状态,后续全局事务会触发 Cancel TccResourceManager.INSTANCE.branchReport(xid, branchId, BranchStatus.PhaseOne_Failed); throw e; } }

核心关键

  • 子方法执行时,通过ThreadLocal获取主方法绑定的 XID,确认自己属于哪个全局事务;
  • 解析@TwoPhaseBusinessAction注解,将 Try/Confirm/Cancel 方法序列化后,注册为 “TCC 分支事务”,并写入 Seata 数据库的branch_table(关联 XID);
  • 此时,全局事务(主方法)就通过branch_table知道了 “自己有哪些 TCC 子方法”。
步骤 3:全局事务提交 / 回滚,触发二阶段方法(主方法执行后)

当主方法执行完成(无异常 / 有异常),@GlobalTransactional触发提交 / 回滚逻辑,核心是branch_table读取已注册的 TCC 分支

java

运行

// DefaultGlobalTransaction.java public void commit() throws TransactionException { // 1. 根据 XID 查询所有已注册的 TCC 分支(来自步骤 2 的注册) List<BranchDO> branchList = branchStorage.findBranchListByXid(this.xid); for (BranchDO branch : branchList) { if (branch.getBranchType() == BranchType.TCC) { // 2. 反序列化 TccAction 对象(获取 Confirm 方法) TccAction tccAction = JSON.parseObject(branch.getApplicationData(), TccAction.class); // 3. 反射执行 Confirm 方法(子方法的二阶段) invokeTargetMethod(tccAction.getConfirmMethod(), branch.getArgs()); // 4. 更新分支状态为“已提交” branchStorage.updateBranchStatus(branch.getBranchId(), BranchStatus.PhaseTwo_Committed); } } // 5. 更新全局事务状态为“已提交” globalStorage.updateGlobalStatus(this.xid, GlobalStatus.Committed); }

回滚逻辑同理:从branch_table读取分支,执行Cancel方法。

三、核心原理总结(一句话说透)

@GlobalTransactional不会 “主动扫描” 子方法的@TwoPhaseBusinessAction,而是:

  1. 主方法执行前,创建全局事务 XID 并绑定到当前线程;
  2. 子方法执行时,Seata 拦截@TwoPhaseBusinessAction,通过线程绑定的 XID 向全局事务 “注册自己”;
  3. 全局事务提交 / 回滚时,从数据库读取已注册的 TCC 分支,执行二阶段方法。

四、关键细节(避免误解)

  1. 线程绑定是核心桥梁:XID 存储在RootContext(本质是ThreadLocal<String>),子方法和主方法在同一个线程执行,因此能拿到同一个 XID,这是 “关联” 的基础。
  2. 非侵入式拦截:无需在主方法中显式声明子方法,只要子方法加@TwoPhaseBusinessAction且被主方法调用,就会自动注册为分支 —— 这是 Seata TCC 无侵入的关键。
  3. 分支注册是持久化保障:TCC 分支信息写入branch_table,即使 Seata Server 宕机,恢复后仍能根据 XID 找到分支方法,保证二阶段执行(幂等性由业务层保证)。

五、调试验证(快速确认绑定关系)

  1. 断点 1:GlobalTransactionalInterceptor.invoke()→ 查看 XID 的创建和绑定;
  2. 断点 2:TccActionInterceptor.invoke()→ 查看子方法如何解析@TwoPhaseBusinessAction并注册分支;
  3. 数据库验证:执行主方法后,查询branch_table

    sql

    SELECT xid, resource_id, application_data FROM branch_table WHERE branch_type = 'TCC';
    application_data字段会序列化存储 Try/Confirm/Cancel 方法的全限定名,可直接看到主方法(XID)和子方法的绑定关系。

最终类比

  • @GlobalTransactional像 “项目经理”,启动项目(创建 XID)后开始干活;
  • @TwoPhaseBusinessAction像 “员工”,干活时(执行子方法)主动向项目经理报到(注册分支);
  • 项目收尾时(提交 / 回滚),项目经理根据报到记录(branch_table)安排员工做收尾工作(Confirm/Cancel)。
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/4/23 14:41:32

Windows构建工具终极指南:一键配置C++开发环境

Windows构建工具终极指南&#xff1a;一键配置C开发环境 【免费下载链接】windows-build-tools :package: Install C Build Tools for Windows using npm 项目地址: https://gitcode.com/gh_mirrors/wi/windows-build-tools 在Windows平台上进行Node.js原生模块开发时&a…

作者头像 李华
网站建设 2026/4/23 0:20:23

从零开始使用Kotaemon实现生产级智能问答系统

从零开始使用Kotaemon实现生产级智能问答系统 在金融、医疗、法律等行业&#xff0c;客户对信息准确性的要求近乎苛刻——一个数字的偏差可能引发严重的合规问题。而传统智能客服常因“张口就来”饱受诟病&#xff1a;它们看似流畅地回答问题&#xff0c;实则依赖预设话术或通用…

作者头像 李华
网站建设 2026/4/22 18:41:01

Source Han Sans TTF 完全指南:3分钟快速部署多语言字体解决方案

Source Han Sans TTF 完全指南&#xff1a;3分钟快速部署多语言字体解决方案 【免费下载链接】source-han-sans-ttf A (hinted!) version of Source Han Sans 项目地址: https://gitcode.com/gh_mirrors/so/source-han-sans-ttf 还在为不同语言环境下的字体兼容性问题而…

作者头像 李华
网站建设 2026/4/23 12:45:20

13、深入解析文件系统安全:权限、加密与数据保护

深入解析文件系统安全:权限、加密与数据保护 1. 粘性位(Sticky Bits) 在Linux和Unix系统中,粘性位在文件和目录上有着不同的表现。对于文件,较新的Unix版本不再支持粘性位,而Linux从一开始就未在文件上使用该标志。但在目录方面,粘性位的支持依然活跃。 当一个目录设…

作者头像 李华
网站建设 2026/4/23 12:17:08

Windows微信机器人零门槛部署指南:告别付费Token的束缚

Windows微信机器人零门槛部署指南&#xff1a;告别付费Token的束缚 【免费下载链接】puppet-xp Wechaty Puppet WeChat Windows Protocol 项目地址: https://gitcode.com/gh_mirrors/pu/puppet-xp 还在为Windows平台上的微信自动化发愁吗&#xff1f;每次看到那些复杂的…

作者头像 李华
网站建设 2026/4/23 12:17:09

Apollo Save Tool:PS4存档管理的终极解决方案

Apollo Save Tool&#xff1a;PS4存档管理的终极解决方案 【免费下载链接】apollo-ps4 Apollo Save Tool (PS4) 项目地址: https://gitcode.com/gh_mirrors/ap/apollo-ps4 还在为游戏存档丢失而烦恼吗&#xff1f;Apollo Save Tool正是你需要的专业存档管理工具&#xf…

作者头像 李华