开启事务注解EnableTransactionManagement,该注解往容器中导入了导入TransactionManagementConfigurationSelector组件。该组件有个方法,在容器刷新的时候会被调用。(此处不讲解为何会被调用,重点讲解Transaction注解)
protected String[] selectImports(AdviceMode adviceMode) {
switch (adviceMode) {
case PROXY:java
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生成完成之后会调用后置处理器初始化。会去查找bean有没有合适的通知方法。因此重点是在找通知方法,找到了合适的就会生成代理对象。
//简单的分析一下流程
AbstractAutowireCapableBeanFactory#initializeBean() ->
AbstractAutowireCapableBeanFactory#applyBeanPostProcessorsAfterInitialization() ->
AbstractAutoProxyCreator#postProcessAfterInitialization() ->
AbstractAutoProxyCreator#wrapIfNecessary()->
AbstractAdvisorAutoProxyCreator#getAdvicesAndAdvisorsForBean()
/**
* 寻找可用的通知方法
*/
protected List<Advisor> findEligibleAdvisors(Class<?> beanClass, String beanName) {
//寻找全部的Advisors,会去容器遍历全部类型为Advisor的bean,
//BeanFactoryTransactionAttributeSourceAdvisor就是咱们手动导入的Advisor
List<Advisor> candidateAdvisors = findCandidateAdvisors();
//在全部的Advisors,看是否有beanClass匹配的
List<Advisor> 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<Object> 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.有合适的拦截器:跟单网www.gendan5.com会去执行拦截器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;
}
app