共计 4459 个字符,预计需要花费 12 分钟才能阅读完成。
咱们先说如果该办法是 public,钻研一下其中的细节
@Service
public class TestServiceImpl {@Transactional(rollbackFor = Exception.class)
public void trans1(){}
}
AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsAfterInitialization(), 其中 applyBeanPostProcessorsAfterInitialization()继承自 AbstractAutoProxyCreator,上面是办法细节
public Object applyBeanPostProcessorsAfterInitialization(Object existingBean, String beanName)
throws BeansException {
Object result = existingBean;
//getBeanPostProcessors()是 sptring boot 启动时系统配置的 BeanPostProcessor;其中有一个 BeanPostProcessor 叫做 AnnotationAwareAspectJAutoProxyCreator;for (BeanPostProcessor beanProcessor : getBeanPostProcessors()) {// 当遍历 AnnotationAwareAspectJAutoProxyCreator 时,执行其 postProcessAfterInitialization()
Object current = beanProcessor.postProcessAfterInitialization(result, beanName);
if (current == null) {return result;}
result = current;
}
return result;
}
以下是 AbstractAutoProxyCreator.postProcessAfterInitialization()细节:
public Object postProcessAfterInitialization(@Nullable Object bean, String beanName) throws BeansException {if (bean != null) {Object cacheKey = getCacheKey(bean.getClass(), beanName);
if (!this.earlyProxyReferences.contains(cacheKey)) {
// 这个办法的重要逻辑是,依据 beanName 获取告诉列表,如果列表不为空,创立代理类;return wrapIfNecessary(bean, beanName, cacheKey);
}
}
return bean;
}
图 2
图 3
protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
// 获取 bean 和 beanName 获取告诉列表.
Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, null);
// 本示例中 testServiceImpl 的 specificInterceptors 如图 2 所示;// 如果告诉列表不为空,则创立代理类
if (specificInterceptors != DO_NOT_PROXY) {this.advisedBeans.put(cacheKey, Boolean.TRUE);
// 执行具体创立代理逻辑,本示例中 testServiceImpl 的 specificInterceptors 如图 3 所示
Object proxy = createProxy(bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
this.proxyTypes.put(cacheKey, proxy.getClass());
// 间接返回
return proxy;
}
// 如果没有匹配的告诉列表,返回一般的 bean
this.advisedBeans.put(cacheKey, Boolean.FALSE);
return bean;
}
如果咱们测试用例中的 public 去掉呢?,咱们间接贴出后果:
图 4
能够看到 specificInterceptors = null, 也就是说并没有为其生成代理类。什么起因呢?咱们持续往下看:
//candidateAdvisors 来自 spring boot 启动是配置的告诉列表
protected List<Advisor> findAdvisorsThatCanApply(List<Advisor> candidateAdvisors, Class<?> beanClass, String beanName) {ProxyCreationContext.setCurrentProxiedBeanName(beanName);
try {// 由 AopUtils.findAdvisorsThatCanApply()执行具体的匹配逻辑
return AopUtils.findAdvisorsThatCanApply(candidateAdvisors, beanClass);
}
finally {ProxyCreationContext.setCurrentProxiedBeanName(null);
}
}
咱们能够看到候选的告诉列表有 24 个
图 5
public static boolean canApply(Pointcut pc, Class<?> targetClass, boolean hasIntroductions) {
IntroductionAwareMethodMatcher introductionAwareMethodMatcher = null;
if (methodMatcher instanceof IntroductionAwareMethodMatcher) {introductionAwareMethodMatcher = (IntroductionAwareMethodMatcher) methodMatcher;
}
Set<Class<?>> classes = new LinkedHashSet<>();
if (!Proxy.isProxyClass(targetClass)) {classes.add(ClassUtils.getUserClass(targetClass));
}
classes.addAll(ClassUtils.getAllInterfacesForClassAsSet(targetClass));
for (Class<?> clazz : classes) {Method[] methods = ReflectionUtils.getAllDeclaredMethods(clazz);
for (Method method : methods) {
// 因为 introductionAwareMethodMatcher == null, 所以 methodMatcher.matches 理论执行咱们的候选告诉器 match 办法;if (introductionAwareMethodMatcher != null ?
introductionAwareMethodMatcher.matches(method, targetClass, hasIntroductions) :
methodMatcher.matches(method, targetClass)) {return true;}
}
}
return false;
}
图 6
以 TransactionAttributeSourcePointcut.matches()为例:
图 7
public boolean matches(Method method, @Nullable Class<?> targetClass) {if (targetClass != null && TransactionalProxy.class.isAssignableFrom(targetClass)) {return false;}
// 图 7 为 tas 实例
TransactionAttributeSource tas = getTransactionAttributeSource();
return (tas == null || tas.getTransactionAttribute(method, targetClass) != null);
}
public TransactionAttribute getTransactionAttribute(Method method, @Nullable Class<?> targetClass) {
// We need to work it out.
TransactionAttribute txAttr = computeTransactionAttribute(method, targetClass);
return (tas == null || tas.getTransactionAttribute(method, targetClass) != null);
}
tas.getTransactionAttribute()会调用 AbstractFallbackTransactionAttributeSource.computeTransactionAttribute():
protected TransactionAttribute computeTransactionAttribute(Method method, @Nullable Class<?> targetClass) {
// Don't allow no-public methods as required.
// 通过下面这个正文看出不容许非 public,因而返回 null;
if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {return null;}
}
此时下面的 matches()返回 false, 最终 AopUtils.findAdvisorsThatCanApply(candidateAdvisors, beanClass)返回空列表,这样一来 AbstractAutoProxyCreator.wrapIfNecessary()中的 specificInterceptors 变量为 null,也就没有方法创立代理类了!
最初,再抛出一个问题,如果一个 service @Transactional 办法既有 public, 又有 no-pubic 会怎么呢?欢送一起探讨~~~