Seata1。5。2源码学习

　　文章有点长，我决定用半个小时来和你分享废话不多说，上代码。
　　基于Seata1。5。2，项目中用seataspringbootstarter
　　1。SeataDataSourceAutoConfiguration
　　SeataDataSourceAutoConfiguration主要是配置数据源代理，可以看到：默认seata。enabled、seata。enableAutoDataSourceProxy、seata。enableautodatasourceproxy都是true只有当classpath中有DataSource时才会进行此配置创建了一个SeataAutoDataSourceProxyCreator，用于自动代理数据源
　　先记一下，SeataAutoDataSourceProxyCreator是一个BeanPostProcessor
　　刚才new了一个SeataAutoDataSourceProxyCreator，继续看构造方法，默认useJdkProxy是false，excludes为空，dataSourceProxyMode是AT
　　构造方法中最重要的一件事情是构造AOP通知（拦截器），这里new了一个SeataAutoDataSourceProxyAdvice
　　SeataAutoDataSourceProxyAdvice是一个MethodInterceptor。
　　MethodInterceptor是aop中的一个接口，当目标方法被调用时就会调用与之关联的MethodInterceptor的invoke方法
　　至此，在构造方法中完成了advisors的赋值，advisors〔〕中有一个DefaultIntroductionAdvisor，DefaultIntroductionAdvisor中引用了SeataAutoDataSourceProxyAdvice
　　前面说过，SeataAutoDataSourceProxyCreator是一个BeanPostProcessor，而BeanPostProcessor是BeanFactory中的一个钩子（回调），称之为后置处理器
　　AbstractAutoProxyCreatorpostProcessBeforeInstantiation（）
　　AbstractAutoProxyCreatorpostProcessAfterInitialization（）
　　AbstractAutoProxyCreatorwrapIfNecessary（）
　　AbstractAutoProxyCreatorgetAdvicesAndAdvisorsForBean（）
　　SeataAutoDataSourceProxyCreatorgetAdvicesAndAdvisorsForBean（）
　　SeataAutoDataSourceProxyCreatorwrapIfNecessary（）
　　DataSourceProxyHolder维护了数据源对象与数据源代理对象的映射
　　至此，数据源代理部分就看完了，下面总结一下：
　　1、启动的时候自动配置数据源代理，创建了一个SeataAutoDataSourceProxyCreator
　　2、SeataAutoDataSourceProxyCreator在构造方法中创建AOP通知，并赋值给其属性
　　3、AbstractAutoProxyCreator是一个抽象类不能被实例化，能实例化的只有SeataAutoDataSourceProxyCreator
　　4、SeataAutoDataSourceProxyCreator从AbstractAutoProxyCreator那里继承了很多属性和方法，其中就包括postProcessBeforeInstantiation（）、postProcessAfterInitialization（）、createProxy（）等等
　　5、SeataAutoDataSourceProxyCreator间接实现了BeanPostProcessor接口，也就是说它也是BeanPostProcessor的一个实现类
　　6、BeanFactory回调所有的BeanPostProcessorpostProcessAfterInitialization（）时，就会调用SeataAutoDataSourceProxyCreator的postProcessAfterInitialization（）方法，最终会调用wrapIfNecessary（）方法
　　7、wrapIfNecessary（）只关心DataSource对象，它负责为DataSource对象生成代理对象，并且在SeataAutoDataSourceProxyCreator中维护了DataSource对象与SeataDataSourceProxy对象之间的映射关心
　　8、创建代理对象时，会给DataSource对象应用AOP拦截器。用AOP的话来讲，就是给目标对象DataSource织入通知，并创建一个被增强的代理对象
　　9、通知（拦截器）是SeataAutoDataSourceProxyAdvice，它实现了MethodInterceptor接口
　　10、SeataAutoDataSourceProxyAdviceinvoke（）方法所做的事情就是，拿到原始DataSource的代理对象，并且在代理对象上调用目标方法
　　综上所述，以上做的所有工作都是为了将来调用javax。sql。DataSource上的任意方法时都会被拦截，然后调用其代理对象上对应的方法。而DataSource中最重要的一个方法就是getConnection（）
　　划重点：将来，所有调用javax。sql。DataSourcegetConnection（）都会被拦截，然后在代理对象上执行getConnection（），因此可以这样说
　　调javax。sql。DataSourcegetConnection（）实际上执行的是io。seata。rm。datasource。SeataDataSourceProxygetConnection（）
　　2。SeataAutoConfiguration
　　SeataAutoConfiguration里面主要是配置GlobalTransactionScanner（全局事务扫描器）
　　seata。enabledtrue才会开启SeataAutoConfiguration
　　GlobalTransactionScanner也继承自AbstractAutoProxyCreator，同时还实现了InitializingBean接口。BeanFactory在设置了所有bean属性之后会调用InitializingBean的afterPropertiesSet（）方法
　　GlobalTransactionScannerafterPropertiesSet（）
　　io。seata。common。DefaultValues中定义了很多默认值
　　同样地，因为实现了BeanPostProcessor接口，所以在启动时BeanFactory实例化Bean之后，会调用GlobalTransactionScanner的postProcessAfterInitialization（），尽管这个postProcessAfterInitialization（）方法时从AbstractAutoProxyCreator那里继承来的，但是不影响啊，还是会调用GlobalTransactionScanner这个bean的postProcessAfterInitialization（）方法。于是，最终又会调wrapIfNecessary（）方法。
　　GlobalTransactionScannerwrapIfNecessary（）
　　这里面有一个很重要的逻辑就是，创建了一个GlobalTransactionalInterceptor对象，并赋值给interceptor
　　AbstractAutoProxyCreatorgetAdvicesAndAdvisorsForBean（）是一个抽象方法，实现在子类GlobalTransactionScanner中
　　因此，所有在GlobalTransactionScannerwrapIfNecessary（）中被代理的对象，都被应用GlobalTransactionalInterceptor
　　GlobalTransactionalInterceptor也是一个MethodInterceptor
　　也就是说，目标方法的调用都会转到GlobalTransactionalInterceptorinvoke（）上
　　GlobalTransactionalInterceptorhandleGlobalTransaction（）
　　事务执行直接调用TransactionalTemplate的execute（）方法
　　io。seata。tm。api。TransactionalTemplateexecute（）
　　io。seata。tm。api。GlobalTransactionContextgetCurrent（）获取当前事务
　　io。seata。tm。api。TransactionalTemplatebeginTransaction（）
　　tx是DefaultGlobalTransaction
　　io。seata。tm。api。DefaultGlobalTransactionbegin（）
　　DefaultGlobalTransaction中的TransactionManager是DefaultTransactionManager
　　DefaultTransactionManager中提供了事务相关的底层操作
　　io。seata。tm。api。DefaultGlobalTransactioncommit（）
　　io。seata。tm。api。DefaultGlobalTransactionrollback（）的逻辑与commit（）类似，都是重试调用transactionManager。rollback（xid）
　　全局事务扫描器部分的代码就看到这里，下面总结一下：
　　1、配置项seata。enabledtrue会触发SeataAutoConfiguration自动配置
　　2、SeataAutoConfiguration中创建了一个GlobalTransactionScanner
　　3、GlobalTransactionScanner继承了AbstractAutoProxyCreator，并实现InitializingBean接口
　　4、初始化TM、RM
　　5、由于继承了AbstractAutoProxyCreator，所以BeanFactory会调用GlobalTransactionScanner方法postProcessAfterInitialization（），最终会调用GlobalTransactionScannerwrapIfNecessary（）来为目标对象创建代理对象
　　6、GlobalTransactionScannerwrapIfNecessary（）中创建了一个GlobalTransactionalInterceptor，GlobalTransactionalInterceptor是一个MethodInterceptor
　　7、在创建代理对象的时候，在AbstractAutoProxyCreatorwrapIfNecessary（）方法中，为代理对象应用GlobalTransactionalInterceptor，于是所有目标对象上的方法调用就会转为调用GlobalTransactionalInterceptorinvoke（）
　　8、GlobalTransactionalInterceptorinvoke（）方法中，首先获取被调用的目标对象的Class和Method对象，然后检查目标方法或类上是否有GlobalTransactional或GlobalLock注解，而且配置项中不能禁用全局事务
　　9、如果加了GlobalTransactional注解，则创建一个AspectTransactional，然后开始处理全局事务，默认传播特性是REQUIRED
　　10、如果加了GlobalLock注解，则开始处理全局锁
　　11、处理全局事务就是直接调用事务模板中的execute方法，TransactionalTemplateexecute（）是一个模板方法，其中定义了事务处理的流程。首先开启事务，然后执行业务逻辑，最后提交事务，异常回滚事务。
　　12、事务操作是在DefaultGlobalTransaction中处理的，最终处理在DefaultTransactionManager。DefaultTransactionManager负责同步远程调用，向TC发请求来开启、提交、回滚事务等操作
　　3。数据库操作执行SQL语句
　　通过Java自带的JDBC操作数据库通常是这样的：Class。forName（driverClass）；获取ConnectionConnectionconnectionDriverManager。getConnection（url，user，password）；创建Statement或者PreparedStatementStatementstmtconnection。createStatement（）；stmt。execute（sql）；PreparedStatementpsconnection。prepareStatement（sql）；ps。execute（）；
　　MyBatis底层也是这一套
　　接下来看Seata是如何做的
　　首先是获取数据库连接Connection，前面已经说过了，调用DataSource的getConnection（）方法底层是在代理对象SeataDataSourceProxy上调用getConnection（）。SeataDataSourceProxy是接口，如果是AT模式，则这个数据源代理对象是DataSourceProxy
　　DataSourceProxygetConnection（）获取数据库连接
　　ConnectionProxycreateStatement（）
　　ConnectionProxyprepareStatement（）
　　PreparedStatementProxy继承自StatementProxy，因此下面就直接看PreparedStatementProxy如何执行SQL
　　PreparedStatementProxyexecute（）
　　ExecuteTemplateexecute（）是一个模板方法
　　挑一个看看吧，就挑UpdateExecutor
　　UpdateExecutor构造方法中一直调父类的构造法，既然如此，那么直接看BaseTransactionalExecutor
　　UpdateExecutorexecute（）
　　这个方法时从BaseTransactionalExecutor那里继承来的，又是一个模板方法，可见设计模式是多么重要
　　AbstractDMLBaseExecutordoExecute（）
　　AbstractDMLBaseExecutorexecuteAutoCommitTrue（）
　　ConnectionProxychangeAutoCommit（）
　　现在事务自动提交已经被Seata改成false了
　　UpdateExecutorbeforeImage（）
　　BaseTransactionalExecutorprepareUndoLog（）
　　接下来，提交事务
　　ConnectionProxycommit（）
　　ConnectionProxyprocessGlobalTransactionCommit（）处理全局事务提交
　　分支事务提交以后，业务数据更改和undolog就都提交了
　　回想一下，为什么在执行业务修改前要先将默认的自动提交改成手动提交，最后再改成自动提交呢？
　　因为，要将业务数据修改和插入undolog放在同一个事务里，一起提交
　　这一切都归功于代理
　　回顾一下整个调用链
　　结合之前的案例，AT模式TC、TM、RM三者的交互应该是这样的：
　　问题一：为什么在执行的时候，先将数据库自动提交autoCommit设为false，最后再改成true呢？
　　答：因为，需要将undolog和业务数据修改放到同一个事务中，这样可以保证业务数据修改成功后undolog必然插入成功，所以Seata要将其改为手动提交。最后再改成true是因为默认autoCommit就是true，这样可以不影响其它业务。
　　问题二：什么情况下ConnectionContext中xidnull，且isGlobalLockRequiretrue呢？或者换一种问法，什么情况下不在全局事务中，当仍然需要全局锁呢？
　　答：当业务方法上不加GlobalTransactional，而是只加了GlobalLock注解的情况下，就会出现上述情况，也就会执行ConnectionProxyprocessLocalCommitWithGlobalLocks（）方法，在事务提交前检查全局锁，这样设计的目的是在AT模式下，不出现脏读、脏写。由于数据源被代理了，当一个加了GlobalTransactional的全局事务，与另一个加了GlobalTransactional或GlobalLock注解的事务在本地事务提交前就会检查全局锁，要先获得全局锁才能提交本地事务，这样就避免了脏读脏写，从而相当于实现了全局事务的读已提交隔离级别。参见：https：seata。iozhcnblogseataatlock。html
　　关于Seata1。5。2Client端的源码学习就先到这里，欢迎交流
　　如果你都已经看到了这里，不妨给我点个赞吧