AopNamespaceHandler

AOP源码分析 - 图1

AspectJAutoProxyBeanDefinitionParser

  1. class AspectJAutoProxyBeanDefinitionParser implements BeanDefinitionParser {
  2.     AspectJAutoProxyBeanDefinitionParser() {
  3.     }
  5.     @Nullable
  6.     public BeanDefinition parse(Element element, ParserContext parserContext) {
  7.         //注册AspectJAnnotationAutoProxyCreator
  8.         AopNamespaceUtils.registerAspectJAnnotationAutoProxyCreatorIfNecessary(parserContext, element);
  9.         //对于注解中的子类的处理
  10.         this.extendBeanDefinition(element, parserContext);
  11.         return null;
  12.     }
  14. }

AbstractAutoProxyCreator

  1. public abstract class AbstractAutoProxyCreator extends ProxyProcessorSupport implements SmartInstantiationAwareBeanPostProcessor, BeanFactoryAware {
  3.     //初始化前处理
  4.     public Object postProcessBeforeInstantiation(Class<?> beanClass, String beanName) {
  5.         Object cacheKey = this.getCacheKey(beanClass, beanName);
  6.         if (!StringUtils.hasLength(beanName) || !this.targetSourcedBeans.contains(beanName)) {
  7.             if (this.advisedBeans.containsKey(cacheKey)) {
  8.                 return null;
  9.             }
  11.             if (this.isInfrastructureClass(beanClass) || this.shouldSkip(beanClass, beanName)) {
  12.                 this.advisedBeans.put(cacheKey, Boolean.FALSE);
  13.                 return null;
  14.             }
  15.         }
  17.         TargetSource targetSource = this.getCustomTargetSource(beanClass, beanName);
  18.         if (targetSource != null) {
  19.             if (StringUtils.hasLength(beanName)) {
  20.                 this.targetSourcedBeans.add(beanName);
  21.             }
  23.             Object[] specificInterceptors = this.getAdvicesAndAdvisorsForBean(beanClass, beanName, targetSource);
  24.             Object proxy = this.createProxy(beanClass, beanName, specificInterceptors, targetSource);
  25.             this.proxyTypes.put(cacheKey, proxy.getClass());
  26.             return proxy;
  27.         } else {
  28.             return null;
  29.         }
  30.     }
  32.     //初始化后处理
  33.     public Object postProcessAfterInitialization(@Nullable Object bean, String beanName) {
  34.         if (bean != null) {
  35.             Object cacheKey = this.getCacheKey(bean.getClass(), beanName);
  36.             if (this.earlyProxyReferences.remove(cacheKey) != bean) {
  37.                 //如果适合被代理,封装指定bean
  38.                 return this.wrapIfNecessary(bean, beanName, cacheKey);
  39.             }
  40.         }
  41.         return bean;
  42.     }
  44.      protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey) {
  45.         //已经处理过
  46.         if (StringUtils.hasLength(beanName) && this.targetSourcedBeans.contains(beanName)) {
  47.             return bean;
  48.         //无需增强
  49.         } else if (Boolean.FALSE.equals(this.advisedBeans.get(cacheKey))) {
  50.             return bean;
  51.         //创建代理对象
  52.         } else if (!this.isInfrastructureClass(bean.getClass()) && !this.shouldSkip(bean.getClass(), beanName)) {
  53.             //如果存在增强方法则创建代理
  54.             Object[] specificInterceptors = this.getAdvicesAndAdvisorsForBean(bean.getClass(), beanName, (TargetSource)null);
  55.             if (specificInterceptors != DO_NOT_PROXY) {
  56.                 //保存需要增强的bean
  57.                 this.advisedBeans.put(cacheKey, Boolean.TRUE);
  58.                 //创建代理
  59.                 Object proxy = this.createProxy(bean.getClass(), beanName, specificInterceptors, new SingletonTargetSource(bean));
  60.                 this.proxyTypes.put(cacheKey, proxy.getClass());
  61.                 return proxy;
  62.             } else {
  63.                 this.advisedBeans.put(cacheKey, Boolean.FALSE);
  64.                 return bean;
  65.             }
  66.         } else {
  67.             this.advisedBeans.put(cacheKey, Boolean.FALSE);
  68.             return bean;
  69.         }
  70.     }
  72.     //创建代理对象
  73.     protected Object createProxy(Class<?> beanClass, @Nullable String beanName, @Nullable Object[] specificInterceptors, TargetSource targetSource) {
  74.         if (this.beanFactory instanceof ConfigurableListableBeanFactory) {
  75.             AutoProxyUtils.exposeTargetClass((ConfigurableListableBeanFactory)this.beanFactory, beanName, beanClass);
  76.         }
  78.         ProxyFactory proxyFactory = new ProxyFactory();
  79.         proxyFactory.copyFrom(this);
  80.         if (!proxyFactory.isProxyTargetClass()) {
  81.             if (this.shouldProxyTargetClass(beanClass, beanName)) {
  82.                 proxyFactory.setProxyTargetClass(true);
  83.             } else {
  84.                 this.evaluateProxyInterfaces(beanClass, proxyFactory);
  85.             }
  86.         }
  87.         //获取增强器
  88.         Advisor[] advisors = this.buildAdvisors(beanName, specificInterceptors);
  89.         //加入增强器
  90.         proxyFactory.addAdvisors(advisors);
  91.         //设置要代理的类
  92.         proxyFactory.setTargetSource(targetSource);
  93.         this.customizeProxyFactory(proxyFactory);
  94.         proxyFactory.setFrozen(this.freezeProxy);
  95.         if (this.advisorsPreFiltered()) {
  96.             proxyFactory.setPreFiltered(true);
  97.         }
  99.         return proxyFactory.getProxy(this.getProxyClassLoader());
  100.     }
  102. }

AbstractAdvisorAutoProxyCreator

  1. public abstract class AbstractAdvisorAutoProxyCreator extends AbstractAutoProxyCreator {
  3.     @Nullable
  4.     protected Object[] getAdvicesAndAdvisorsForBean(Class<?> beanClass, String beanName, @Nullable TargetSource targetSource) {
  5.         ////获取增强方法
  6.         List<Advisor> advisors = this.findEligibleAdvisors(beanClass, beanName);
  7.         return advisors.isEmpty() ? DO_NOT_PROXY : advisors.toArray();
  8.     }
  10. }