Seata 包括 Server端和Client端。Seata中有三种角色：TC、TM、RM，其中，Server端就是TC，TM和RM属Client端。Client端的源码学习上一篇已讲过，详见 《Seata 1.5.2源码学习》，今天来学习Server端的源码。
源码下载地址：https://github.com/seata/seata
启动类 ServerApplication 没什么好说的，重点是ServerRunner
ServerRunner 是一个 CommandLineRunner 实例，因此在Spring Boot启动完成后会回调其run()方法。而在ServerRunner的run()方法中调用了Server.start()方法。
在Server#start()方法中，初始化了包括id生成器在内的很多组件，我们先不管这些，重点关注以下几行代码：
NettyRemotingServer nettyRemotingServer = new NettyRemotingServer(workingThreads);
DefaultCoordinator coordinator = DefaultCoordinator.getInstance(nettyRemotingServer);
coordinator.init();
nettyRemotingServer.setHandler(coordinator);DefaultCoordinator是一个单例Bean，在整个应用中只有一个DefaultCoordinator实例
DefaultCoordinator 实现了 TransactionMessageHandler
NettyRemotingServer#setHandler()设置的正是TransactionMessageHandler
DefaultCoordinator#onRequest()
重点是这三行：
AbstractTransactionRequestToTC transactionRequest = (AbstractTransactionRequestToTC) request;
transactionRequest.setTCInboundHandler(this);
transactionRequest.handle(context);DefaultCoordinator实现了TCInboundHandler接口，所以它不仅是一个TransactionMessageHandler，还是一个TCInboundHandler
这里transactionRequest.setTCInboundHandler(this)，就是指定AbstractTransactionRequestToTC中的TCInboundHandler设置为DefaultCoordinator
AbstractTransactionRequest#handle()
不同的请求分发给对应的处理器去处理
现在请求和对应的处理器都有了，下面具体看一下每种请求都是如何被处理的
1. 开启全局事务
开启事务直接调用子类DefaultCoordinator#doGlobalBegin()，同时放在一个处理模板中执行
在doGlobalBean()中调用DefaultCore#begin()并返回全局事务ID（xid）
new GlobalSession()
添加一个SessionManager作为Session的监听器
Core
总结一下，开启事务：
开启事务，创建一个全局事务，如果是seata.store.mode=db的话，向global_table表插入一条记录
2. 分支事务注册
DefaultCore#branchRegister()
如果是AT模式，这里调用的就是ATCore#branchSessionLock()
ATCore#branchSessionLock()检查是否拿到锁了
具体每种锁的实现就不往下看了，挑其中一个看下，就RedisLocker吧
总之，分支注册的时候需要检查锁，拿到本次事务中所涉及的所有需要加锁的行的锁才能注册成功
所有行都加锁成功，分支注册才算成功，才会返回true
再回到AbstractCore#branchRegister()，整个方法是放在SessionHolder#lockAndExecute()中执行的
总结一下，分支注册：
分支注册，创建BranchSession，获取全局锁成功后将branchSession加入globalSession
3. 提交全局事务
首先判断全局事务状态是否为begin，如果不是则不应该提交。如果是，则将事务active置为false，释放全局锁，判断是否可以异步提交。分支类型是AT的都可以异步提交，因此AT模式，默认是异步提交。如果不能异步提交，则采取同步提交。
3.1. 同步提交
遍历所有已注册的分支事务，向分支发送同步请求，告诉它全局事务开始提交了，不出意外的情况下返回分支状态是二阶段提交成功。当所有分支都提交成功，则返回true，于是全局事务提交成功，返回全局事务状态为已提交。如果有分支提交失败，则返回false，全局事务提交失败，返回全局状态为提交失败。如果抛异常了，则会有定时任务稍后重试提交。
3.2. 异步提交
异步提交只是将全局状态置为异步提交中，剩下的事情交给定时任务去执行
启动的时候调用了DefaultCoordinator#init()方法，启动定时任务
每次，定时任务执行前，要先获取一把分布式锁，这个锁是io.seata.core.store.DistributedLocker，不是分支注册时的那把锁io.seata.core.lock.Locker
异步提交首先将全局状态设置为AsyncCommitting，返回返回全局状态Committed。后台有定时任务扫描，找到所有状态为AsyncCommitting的全局事务，循环遍历。对于每个全局事务提交，调用DefaultCore#doGlobalCommit()，遍历所有已注册的分支事务，向分支事务发请求，通知其提交事务，分支事务返回二阶段提交成功，表示该分支事务提交成功，当所有分支事务都二阶段提交成功，则全局事务提交成功。
4. 回滚全局事务
回滚，首先检查全局事务状态是否为Begin，不是的话直接结束。遍历当前全局事务中已注册的分支事务，依次给每个分支发请求，告诉分支事务需要回滚。如果所有分支返回回滚成功，则全局回滚成功。如果有分支回滚失败且不重试，则直接直接结束。如果失败且可重试，或者执行过程中抛异常，则稍后会有定时任务重试回滚操作。
5. 分支上报
RM向TC报告分支事务状态
只是更新一下分支状态及相关数据
6. 查询全局事务状态
7. 查询全局锁
挑RedisLocker看一下吧
关于Seata Server 的源码学习就先到这里，欢迎交流，多谢点赞 (^_^)
一、引擎主循环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
目录前言滤波电路科普主要分类实际情况单位的概念常用评价参数函数型滤波器简单分析滤波电路构成低通滤波器RC低通滤波器RL低通滤波器高通滤波器RC高通滤波器RL高通滤波器部分摘自《LC滤波器设计与制作》，侵权删。前言最近需要学习放大电路和滤波电路，但是由于只在之前做音乐频谱分析仪的时候简单了解过一点点运放，所以也是相当从零开始学习了。滤波电路科普主要分类滤波器：主要是从不同频率的成分中提取出特定频率的信号。有源滤波器：由RC元件与运算放大器组成的滤波器。可滤除某一次或多次谐波，最普通易于采用的无源滤波器结构是将电感与电容串联，可对主要次谐波（3、5、7）构成低阻抗旁路。无源滤波器：无源滤波器，又称
最近在学习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总线个人知识总
深度学习部署：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
我完全不是程序员，正在学习使用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
我有一个放在lib/network中的类:moduleNetworkApiclassNetworkProxyendend然后在另一个类中，我引用了这个类:network_proxy=::NetworkApi::NetworkProxy.new(params)一切都在我的开发环境中正常运行，但是当我部署到服务器时，我在上面一行收到错误消息:NameError:uninitializedconstantNetworkApi::NetworkProxy我不知道为什么会出现这个奇怪的错误。请告诉我为什么。 最佳答案 请注意Rails5dis
如何学习ruby的正则表达式？(对于假人) 最佳答案 http://www.rubular.com/在Ruby中使用正则表达式时是一个很棒的工具，因为它可以立即将结果可视化。 关于ruby-我如何学习ruby的正则表达式？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/1881231/
深度学习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
文章目录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模型，求出其滞
写在之前Shader变体、Shader属性定义技巧、自定义材质面板，这三个知识点任何一个单拿出来都是一套知识体系，不能一概而论，本文章目的在于将学习和实际工作中遇见的问题进行总结，类似于网络笔记之用，方便后续回顾查看，如有以偏概全、不祥不尽之处，还望海涵。1、Shader变体先看一段代码......Properties{ [KeywordEnum(on,off)]USL_USE_COL("IsUseColorMixTex?",int)=0 [Toggle(IS_RED_ON)]_IsRed("IsRed?",int)=0}......//中间省略，后续会有完整代码 #pragmamulti_c