Spring @Transaction源码解析

首先从@最外层直接进入debug源码

image.png

刚进去肯定是动态代理的代码,这里直接进入了CglibAopProxy的intercept中,如果是继承接口则是JdkDynamicAopProxy

其中this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass)是比较重要的方法,这个方法里面获取了实现spring transaction拦截事务逻辑的Interceptor
点进去跳到了AdvisedSupport的getInterceptorsAndDynamicInterceptionAdvice方法
执行完这个方法后,查看返回的chain集合中对象

image.png

如上图所示,就是实现Spring事务逻辑的拦截器

代码继续往下执行,到了核心的执行逻辑,这里把拦截器和target等对象封装成一个CglibMethodInvocation对象,然后调用proceed方法执行逻辑

image.png

点进process方法跳到了ReflectiveMethodInvocation类里面

image.png

可以清晰看到这里是使用递归来执行拦截器链的

代码继续往下执行,跳到最后一行,
interceptorOrInterceptionAdvice就是TransactionInterceptor对象,这里终于开始执行Spring事务相关代码

点进去

再进到invokeWithinTransaction方法

image.png

TransactionAttributeSource tas = getTransactionAttributeSource(): 这里是获取事务配置属性策略, 不同的TransactionAttributeSource对事务属性配置获取方式不同,这里用的是@Transactional注解式事务,所以获取的是AnnotationTransactionAttributeSource对象

final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null): 这里就是获取@Transactional上的相关属性

image.png

代码继续往下走,走到createTransactionIfNecessary方法,这里是Spring事务重中之重

image.png

这里跳到了TransactionAspectSupport的createTransactionIfNecessary方法,开始执行事务管理器的getTransaction方法这里用的默认的DataSourceTransactionManager事务管理器

继续往下走

image.png

这里到了AbstractPlatformTransactionManager的getTransaction方法

doGetTransaction方法是很重要的方法,这里面设置了事务上下文

image.png

点进去看到DataSourceTransactionManager覆写了doGetTransaction方法

TransactionSynchronizationManager.getResource(obtainDataSource())就是获取数据库连接上下文,因为一个事务必须是在同一个连接中发送的,这里面需要传入DataSource
点进去

image.png

再进去doGetResource方法

image.png

这里的resources其实就是一个ThreadLocal,保存当前线程上下文的,值得注意的是,value是一个Map,key其实就是DataSource对象,也就是说在@Transactional里面支持不同的DataSource执行操作,如果DataSource不同,那么获取的Connection也就不是当时开启事务的那个Connection,这样后续的那个Connection对象发起的操作是没有起事务作用的,所以事务管理器中的DataSource要和真正执行sql时的DataSource一致,这样才能保持从事务上下文中获取的是同一个Connection
再回到getTransaction方法

由于当前是首次开启事务,isExistingTransaction返回false，当前使用的默认的事务传播行为
PROPAGATION_REQUIRED
这里有一些事务传播相关处理逻辑,这里不重点关注,跳进doBegin方法

image.png

Spring里面do开头的方法基本都是真正干事的方法,也就是说这里面肯定是开启了事务
txObject.hasConnectionHolder()这里面还没有设置当前的数据库连接,所以会进第一个if里面
再往下走

image.png

这里可以清晰的看到关闭了Mysql的自动提交

image.png

txObject.getConnectionHolder().setTransactionActive(true);
将上下文中标记事务是开启的
再往下走走到一步关键代码

image.png

TransactionSynchronizationManager.bindResource(obtainDataSource(), txObject.getConnectionHolder());这里其实就是将当前ConnectionHolder跟当前线程绑定,
TransactionSynchronizationManager管理着线上中事务连接的上下文

image.png

点进去可以看到,将将当前获取的数据库连接与当前线程和DataSource绑定,只要后续执行sql是同一个DataSource就会获取相同的Connection,就会在这个事务中了

上面开启事务的核心代码看完了,再回TransactionAspectSupport的createTransactionIfNecessary方法

image.png

进入prepareTransactionInfo方法

这里将事务相关的信息封装成了一个TransactionInfo对象,然后bindToThread 就是把TransactionInfo绑定到线程上下文中

image.png

transactionInfoHolder是TransactionAspectSupport的静态变量

再回TransactionAspectSupport的invokeWithinTransaction

image.png

至此,createTransactionIfNecessary中的开启事务相关逻辑执行完毕,proceedWithInvocation后面就是业务相关核心执行逻辑了,这时线程上下文中已经绑定了事务需要的相关对象