首先从@最外层直接进入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对象
image.png
代码继续往下走,走到createTransactionIfNecessary方法,这里是Spring事务重中之重
image.png
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
image.png
transactionInfoHolder是TransactionAspectSupport的静态变量
再回TransactionAspectSupport的invokeWithinTransaction
image.png
至此,createTransactionIfNecessary中的开启事务相关逻辑执行完毕,proceedWithInvocation后面就是业务相关核心执行逻辑了,这时线程上下文中已经绑定了事务需要的相关对象
网友评论