Transaction注解原理

开启事务注解 EnableTransactionManagement ,该注解往容器中导入了导入 TransactionManagementConfigurationSelector 组件。该组件有个方法,在容器刷新的时候会被调用。 ( 此处不讲解为什么会被调用,重点讲解 Transaction 注解 )

protected  String[] selectImports(AdviceMode adviceMode) {

switch (adviceMode) {

case PROXY:

return new String[] {AutoProxyRegistrar.class.getName(),

ProxyTransactionManagementConfiguration.class.getName()};

case ASPECTJ:

return new String[] {

TransactionManagementConfigUtils.TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME};

·  default:

·  return null;

·  }

·  }

· 

·  EnableTransactionManagement 默认是 **AdviceMode mode() default AdviceMode.PROXY;** 所以
AutoProxyRegistrar ProxyTransactionManagementConfiguration 会被加载到容器中。

· 

·  AutoProxyRegistrar 功能是往容器中注册了 InfrastructureAdvisorAutoProxyCreator 是个 BeanPostProcessor 后置处理器。

·  ProxyTransactionManagementConfiguration 利用 @Bean 注解往容器中添加多个 bean (BeanFactoryTransactionAttributeSourceAdvisor 是个 Advisor 和前面 Aop @Before 一样都是通知方法,但是此处的是手动导入的, Aop 是自己自动生成的 )

· 

·  bean 生成完成以后会跟单网gendan5.com调用后置处理器初始化。会去查找 bean 有没有合适的通知方法。所以重点是在找通知方法,找到了合适的就会生成代理对象。

· 

·  // 简单的分析一下流程

·  AbstractAutowireCapableBeanFactory#initializeBean() ->

·  AbstractAutowireCapableBeanFactory#applyBeanPostProcessorsAfterInitialization() ->

·  AbstractAutoProxyCreator#postProcessAfterInitialization() ->

·  AbstractAutoProxyCreator#wrapIfNecessary()->

·  AbstractAdvisorAutoProxyCreator#getAdvicesAndAdvisorsForBean()

/**

·   * 寻找可用的通知方法

·   */

·  protected List findEligibleAdvisors(Class beanClass, String beanName) {

·  // 寻找所有的 Advisors, 会去容器遍历所有类型为 Advisor bean

·  //BeanFactoryTransactionAttributeSourceAdvisor 就是我们手动导入的 Advisor           

·  List candidateAdvisors = findCandidateAdvisors();

·  // 在所有的 Advisors, 看是否有 beanClass 匹配的

·  List eligibleAdvisors = findAdvisorsThatCanApply(candidateAdvisors, beanClass, beanName);

·  extendAdvisors(eligibleAdvisors);

·  if (!eligibleAdvisors.isEmpty()) {

·  eligibleAdvisors = sortAdvisors(eligibleAdvisors);

·  }

·  return eligibleAdvisors;

·  }

·  // 找到所有的 Advisors, 剩下就是是否有匹配的 findAdvisorsThatCanApply() 方法 // 最终走到 TransactionAttributeSourcePointcut#matches//->AbstractFallbackTransactionAttributeSource#computeTransactionAttribute

· 

·  ```javaprotected TransactionAttribute computeTransactionAttribute(Method method, Class targetClass) {

·  // 判断方法修饰符是不是 Public allowPublicMethodsOnly() 默认是 true

·  if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {

·  return null;

·  }

· 

·  // 这里面就是判断方法上有没有 Transactional 注解,有进行解析操作并返回。

·  TransactionAttribute txAttr = findTransactionAttribute(specificMethod);

·  if (txAttr != null) {

·  return txAttr;

·  }

·  // 代码每贴全,为了少点没用的东西。。。。

·  那要是找了合适的通知方法,就生成代理对象,并设置回调函数。设置回调函数是CglibAopProxy.DynamicAdvisedInterceptor intercept 方法,该方法有个 getInterceptorsAndDynamicInterceptionAdvice 获取合适的拦截器。 ( 事务的拦截器是 TransactionInterceptor)

·  public Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy) throws Throwable {

·                  // 获取目标对象,不是代理对象

·                  target = getTarget();

·  if (target != null) {

·  targetClass = target.getClass();

·  }

·  // 获取方法合适的拦截器

·  List chain = this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);

·  Object retVal;

·  // 没有合适的拦截器并且方法的修饰符是 Public

·  if (chain.isEmpty() && Modifier.isPublic(method.getModifiers())) {

·  Object[] argsToUse = AopProxyUtils.adaptArgumentsIfNecessary(method, args);

·  // 会调用目标方法

·  retVal = methodProxy.invoke(target, argsToUse);

·  }

·  else {

·  /*

·  * 1. 有合适的拦截器 : 会去执行拦截器 TransactionInterceptor#invoke()

·                      *    事务的提交,回滚等一系列操作都在里面。具体是调去了

·                      *    TransactionAspectSupport#invokeWithinTransaction() 方法   

·  *  2. 没有合适的拦截器并且方法的修饰符不是 Public: 这里面也会去调目标方法

·  *     ( 这里简单可以走进去看一下 )

·  */

·  retVal = new CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed();

·  }

·  retVal = processReturnType(proxy, target, method, retVal);

·  return retVal;

·  }