草庐IT

Seata 1.5.2 源码学习（Client端）

狂乱的贵公子 2023-04-18 原文

在上一篇中通过阅读Seata服务端的代码，我们了解到TC是如何处理来自客户端的请求的，今天这一篇一起来了解一下客户端是如何处理TC发过来的请求的。要想搞清楚这一点，还得从GlobalTransactionScanner说起。

启动的时候，会调用GlobalTransactionScanner#initClient()方法，在initClient()中初始化TM和RM

TM初始化，主要是注册各种处理器，最终构造一个处理器映射表，不再多说

HashMap<Integer/*MessageType*/, Pair<RemotingProcessor, ExecutorService>> processorTable = new HashMap<>(32);

重点关注RM初始化

RM初始化过程中，设置了 resourceManager 和 transactionMessageHandler，然后也是注册各种处理器，最终也是构造一个消息类型和对应的处理器的一个映射关系

可以看到，图中上半部分是RM特有的，下半部分与TM初始化注册处理器类似

然鹅，真正处理请求的还是靠调用各个处理器中的handler.onRequest()方法，于是问题的关键就很明显了，就在于handler

1.  ResourceManager

在了解ResourceManager之前，让我们首先了解一下ResourceManagerInbound和ResourceManagerOutbound

ResourceManagerInbound是处理接收到TC的请求的，是TC向RM发请求

ResourceManagerOutbound是处理流出的消息的，是RM向TC发请求

ResourceManager继承了二者，所以既负责向TC发请求，又负责接收从TC来的请求。

还记得刚才在RMClient中是怎么获取ResourceManager的吗？是调用DefaultResourceManager.get()获取的

DefaultResourceManager.get()得到的是一个单例DefaultResourceManager，创建DefaultResourceManager的时候会构建一个分支类型与ResourceManager的一个Map

2. TransactionMessageHandler

TransactionMessageHandler负责处理接收到的RPC消息

前面在 RMClient 中通过 DefaultRMHandler.get() 获取 TransactionMessageHandler

3. 消息处理

RMClient#init()的时候new了一个RmNettyRemotingClient

这里要记住，rmNettyRemotingClient的两个成员变量此时已经被赋值了：

  • resourceManager是DefaultResourceManager，
  • transactionMessageHandler是DefaultRMHandler

RmNettyRemotingClient构造方法中调用父类AbstractNettyRemotingClient的构造方法

可以看到，根据收到的RPC消息类型，从processorTable中获取对应的Processor，最后调用对应RemotingProcessor的process()方法进行处理消息

RemotingProcessor的实现类很多，挑其中一个RmBranchCommitProcessor看一下

真相大白，最终还是调DefaultRMHandler#handle()

捋一下这个过程

最后，补充一个，this为什么是DefaultRMHandler

补充二：AbstractTransactionRequestToRM

4. 分支事务提交（二阶段）

交给AsyncWorker去执行

可以看到：

  1. 封装成一个Phase2Context对象，并将其放入队列中
  2. 如果放入成功，则立即返回提交成功，后续交由定时任务执行
  3. 如果放入失败，则主动触发定时任务先执行一次，以便腾出空间来，待执行完后，队列里面就有空间了，再将任务放入队列，等待下一次定时任务执行
  4. 定时任务1秒执行一次，执行的时候将队列中的任务取出，然后循环遍历分段执行
  5. 执行的过程就是删除对应事务的undo log
  6. 如果过程中抛异常，则将任务再放回队列中

所以，RM收到TC发的提交指令后，仅仅只是删除该事务的undo_log表记录

5. 分支事务回滚（二阶段）

与提交类似

所以，回滚就是根据事务的undo_log进行回滚

6. 总结

1、启动时，自动代理数据源，应用GlobalTransactionalInterceptor，初始化TM和RM

2、进入@GlobalTransactional业务方法时，TM向TC发请求申请开启全局事务，并获得全局事务ID

3、业务方法调用远程服务接口完成业务处理

4、RM执行本地逻辑，注册分支事务，获取全局锁，成功后提交本地事务并写入undo_log，本地事务提交成功后向TC报告分支事务

5、TM发起全局事务提交请求，TC向所有已注册的RM发请求，让RM进行分支提交，删除本地undo_log

6、若执行失败，TM发起全局事务回滚，TC向所有RM发请求，回滚分支事务，还原数据

 

ClientSeataspan874963font-sizeJava

有关Seata 1.5.2 源码学习（Client端）的更多相关文章

  1. UE4 源码阅读：从引擎启动到Receive Begin Play - 2

    一、引擎主循环UE版本：4.27一、引擎主循环的位置：Launch.cpp:GuardedMain函数二、、GuardedMain函数执行逻辑：1、EnginePreInit：加载大多数模块int32ErrorLevel=EnginePreInit(CmdLine);PreInit模块加载顺序：模块加载过程：（1）注册模块中定义的UObject，同时为每个类构造一个类默认对象（CDO，记录类的默认状态，作为模板用于子类实例创建）（2）调用模块的StartUpModule方法2、FEngineLoop::Init()1、检查Engine的配置文件找出使用了哪一个GameEngine类（UGame

  2. LC滤波器设计学习笔记（一）滤波电路入门 - 2

    目录前言滤波电路科普主要分类实际情况单位的概念常用评价参数函数型滤波器简单分析滤波电路构成低通滤波器RC低通滤波器RL低通滤波器高通滤波器RC高通滤波器RL高通滤波器部分摘自《LC滤波器设计与制作》，侵权删。前言最近需要学习放大电路和滤波电路，但是由于只在之前做音乐频谱分析仪的时候简单了解过一点点运放，所以也是相当从零开始学习了。滤波电路科普主要分类滤波器：主要是从不同频率的成分中提取出特定频率的信号。有源滤波器：由RC元件与运算放大器组成的滤波器。可滤除某一次或多次谐波，最普通易于采用的无源滤波器结构是将电感与电容串联，可对主要次谐波（3、5、7）构成低阻抗旁路。无源滤波器：无源滤波器，又称

  3. CAN协议的学习与理解 - 2

    最近在学习CAN，记录一下，也供大家参考交流。推荐几个我觉得很好的CAN学习，本文也是在看了他们的好文之后做的笔记首先是瑞萨的CAN入门，真的通透；秀！靠这篇我竟然2天理解了CAN协议！实战STM32F4CAN！原文链接：https://blog.csdn.net/XiaoXiaoPengBo/article/details/116206252CAN详解（小白教程）原文链接：https://blog.csdn.net/xwwwj/article/details/105372234一篇易懂的CAN通讯协议指南1一篇易懂的CAN通讯协议指南1-知乎(zhihu.com)视频推荐CAN总线个人知识总

  4. 深度学习部署：Windows安装pycocotools报错解决方法 - 2

    深度学习部署：Windows安装pycocotools报错解决方法1.pycocotools库的简介2.pycocotools安装的坑3.解决办法更多Ai资讯：公主号AiCharm本系列是作者在跑一些深度学习实例时，遇到的各种各样的问题及解决办法，希望能够帮助到大家。ERROR:Commanderroredoutwithexitstatus1:'D:\Anaconda3\python.exe'-u-c'importsys,setuptools,tokenize;sys.argv[0]='"'"'C:\\Users\\46653\\AppData\\Local\\Temp\\pip-instal

  5. ruby - 我正在学习编程并选择了 Ruby。我应该升级到 Ruby 1.9 吗？ - 2

    我完全不是程序员，正在学习使用Ruby和Rails框架进行编程。我目前正在使用Ruby1.8.7和Rails3.0.3，但我想知道我是否应该升级到Ruby1.9，因为我真的没有任何升级的“遗留”成本。缺点是什么？我是否会遇到与普通gem的兼容性问题，或者甚至其他我不太了解甚至无法预料的问题？ 最佳答案 你应该升级。不要坚持从1.8.7开始。如果您发现不支持1.9.2的gem，请避免使用它们(因为它们很可能不被维护)。如果您对gem是否兼容1.9.2有任何疑问，您可以在以下位置查看:http://www.railsplugins.or

  6. ruby - 我如何学习 ruby​​ 的正则表达式？ - 2

    如何学习ruby​​的正则表达式？(对于假人) 最佳答案 http://www.rubular.com/在Ruby中使用正则表达式时是一个很棒的工具，因为它可以立即将结果可视化。 关于ruby-我如何学习ruby​​的正则表达式？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/1881231/

  7. ruby - Google-api-ruby-client 翻译 API 示例 - 2

    很高兴看到google代码:google-api-ruby-client项目，因为这对我来说意味着Ruby人员可以使用GoogleAPI-s来完善代码。虽然我现在很困惑，因为给出的唯一示例使用Buzz，并且根据我的实验，Google翻译(v2)api的行为必须与google-api-ruby-client中的Buzz完全不同。.我对“Explorer”演示示例很感兴趣——但据我所知，它并不是一个探索器。它所做的只是调用一个Buzz服务，然后浏览它已经知道的关于Buzz服务的事情。对我来说，Explorer应该让您“发现”所公开的服务和方法/功能，而不一定已经知道它们。我很想听听使用这个

  8. 深度学习12. CNN经典网络 VGG16 - 2

    深度学习12.CNN经典网络VGG16一、简介1.VGG来源2.VGG分类3.不同模型的参数数量4.3x3卷积核的好处5.关于学习率调度6.批归一化二、VGG16层分析1.层划分2.参数展开过程图解3.参数传递示例4.VGG16各层参数数量三、代码分析1.VGG16模型定义2.训练3.测试一、简介1.VGG来源VGG（VisualGeometryGroup）是一个视觉几何组在2014年提出的深度卷积神经网络架构。VGG在2014年ImageNet图像分类竞赛亚军，定位竞赛冠军；VGG网络采用连续的小卷积核（3x3）和池化层构建深度神经网络，网络深度可以达到16层或19层，其中VGG16和VGG

  9. 机器学习——时间序列ARIMA模型(四)：自相关函数ACF和偏自相关函数PACF用于判断ARIMA模型中p、q参数取值 - 2

    文章目录1、自相关函数ACF2、偏自相关函数PACF3、ARIMA(p,d,q)的阶数判断4、代码实现1、引入所需依赖2、数据读取与处理3、一阶差分与绘图4、ACF5、PACF1、自相关函数ACF自相关函数反映了同一序列在不同时序的取值之间的相关性。公式：ACF(k)=ρk=Cov(yt,yt−k)Var(yt)ACF(k)=\rho_{k}=\frac{Cov(y_{t},y_{t-k})}{Var(y_{t})}ACF(k)=ρk​=Var(yt​)Cov(yt​,yt−k​)​其中分子用于求协方差矩阵，分母用于计算样本方差。求出的ACF值为[-1,1]。但对于一个平稳的AR模型，求出其滞

  10. Unity Shader 学习笔记（5）Shader变体、Shader属性定义技巧、自定义材质面板 - 2

    写在之前Shader变体、Shader属性定义技巧、自定义材质面板，这三个知识点任何一个单拿出来都是一套知识体系，不能一概而论，本文章目的在于将学习和实际工作中遇见的问题进行总结，类似于网络笔记之用，方便后续回顾查看，如有以偏概全、不祥不尽之处，还望海涵。1、Shader变体先看一段代码......Properties{ [KeywordEnum(on,off)]USL_USE_COL("IsUseColorMixTex?",int)=0 [Toggle(IS_RED_ON)]_IsRed("IsRed?",int)=0}......//中间省略，后续会有完整代码 #pragmamulti_c

随机推荐