63、Spring5.x源码之旅六十四深入AOP事务原理一

• 传播机制图
• AOP拦截原理
• • TransactionAspectSupport的invokeWithinTransaction
• TransactionAspectSupport的determineTransactionManager获取事务管理器
• TransactionAspectSupport的createTransactionIfNecessary创建事务信息(重点)

传播机制图

AOP拦截原理

简单的示意图：

前面我们实战了7中传播机制，现在我们就来看下原理吧，源码比较复杂，我只选重点的讲。首先前面说了AOP事务的初始化，我们知道事务是基于AOP的拦截的，前面创建了JdkDynamicAopProxy：

调用里面的invoke方法，这个在讲AOP的时候也讲过，其实就是获取拦截器链：

将目标对象的方法封装成MethodInvocation，然后执行拦截器，里面是个递归执行的方法：

最后执行的是拦截器的方法，也就是事务拦截器TransactionInterceptor的invoke：

TransactionAspectSupport的invokeWithinTransaction

简单的一次事务就是这个样子，但是目标方法里面可能还有其他方法，也是有事务的，就涉及到事务的传播机制啦。

内部就是获取事务属性源TransactionAttributeSource，然后获取方法的事务注解属性，如果缓存里没有，就会去解析方法上的事务注解，然后返回注解属性，然后获取事务管理器，也就是我们注入的DataSourceTransactionManager，之后创建事务信息，这个最重要，是为了回滚和提交用的，最后调用目标方法。

@Nullable
	protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass,
			final InvocationCallback invocation) throws Throwable {
   
     

		// If the transaction attribute is null, the method is non-transactional.
		TransactionAttributeSource tas = getTransactionAttributeSource();//事务注解属性
		final TransactionAttribute txAttr = (tas != null ? tas.getTransactionAttribute(method, targetClass) : null);
		final TransactionManager tm = determineTransactionManager(txAttr);//获取事务管理器

		...

		PlatformTransactionManager ptm = asPlatformTransactionManager(tm);
		final String joinpointIdentification = methodIdentification(method, targetClass, txAttr);//连接点唯一标识 类名+方法名

		if (txAttr == null || !(ptm instanceof CallbackPreferringPlatformTransactionManager)) {
   
     
			// Standard transaction demarcation with getTransaction and commit/rollback calls.
			TransactionInfo txInfo = createTransactionIfNecessary(ptm, txAttr, joinpointIdentification);

			Object retVal;
			try {
   
     
			
				retVal = invocation.proceedWithInvocation();//调用方法
			}
			catch (Throwable ex) {
   
     

				completeTransactionAfterThrowing(txInfo, ex);
				throw ex;
			}
			finally {
   
     
				cleanupTransactionInfo(txInfo);//清除事务信息，恢复线程私有的老的事务信息
			}

			...
			//成功后提交，会进行资源储量，连接释放，恢复挂起事务等操作
			commitTransactionAfterReturning(txInfo);
			return retVal;
		}
	}

注入的事务管理器：

TransactionAspectSupport的determineTransactionManager获取事务管理器

这个方法就是要获取事务管理器，如果前面没注入事务的话getBean会报异常：

TransactionAspectSupport的createTransactionIfNecessary创建事务信息(重点)

首先会生成一个代理事务属性，然后进行事务的获取，主要还是分析事务注解上的属性来进行事务状态的创建，最后创建事务信息，将事务状态放入事务信息中。

重点就在status = tm.getTransaction(txAttr);这句代码中，下一篇详细说吧。

好了，今天就到这里了，希望对学习理解有帮助，大神看见勿喷，仅为自己的学习理解，能力有限，请多包涵。