深入理解Spring源码之剖析AOP(注解配置方式)(二)

简介: 深入理解Spring源码之剖析AOP(注解配置方式)

下面从整体剖析下 AnnotationAwareAspectJAutoProxyCreator【InstantiationAwareBeanPostProcessor】    的作用:

 AnnotationAwareAspectJAutoProxyCreator【InstantiationAwareBeanPostProcessor】  的作用:
  1)、每一个bean创建之前,调用postProcessBeforeInstantiation();
      关心MathCalculator和LogAspect的创建
       1.1)、判断当前bean是否在advisedBeans中(保存了所有需要增强bean)
       1.2)、判断当前bean是否是基础类型的Advice、Pointcut、Advisor、
               AopInfrastructureBean,或者是否是切面(@Aspect)
       1.3)、是否需要跳过
        1.3.1)、获取候选的增强器(切面里面的通知方法)【List<Advisor> 
                candidateAdvisors】
          每一个封装的通知方法的增强器是 InstantiationModelAwarePointcutAdvisor;
          判断每一个增强器是否是 AspectJPointcutAdvisor 类型的;返回true
        1.3.2)、永远返回false
  2)、创建对象
  postProcessAfterInitialization;
      return wrapIfNecessary(bean, beanName, cacheKey);//包装如果需要的情况下
       2.1)、获取当前bean的所有增强器(通知方法)  Object[]  specificInterceptors
        2.1.1、找到候选的所有的增强器(找哪些通知方法是需要切入当前bean方法的)
        2.1.2、获取到能在bean使用的增强器。
        2.1.3、给增强器排序
      2.2)、保存当前bean在advisedBeans中;
      2.3)、如果当前bean需要增强,创建当前bean的代理对象;
        2.3.1)、获取所有增强器(通知方法)
        2.3.2)、保存到proxyFactory
        2.3.3)、创建代理对象:Spring自动决定
          JdkDynamicAopProxy(config);jdk动态代理;
          ObjenesisCglibAopProxy(config);cglib的动态代理;
      2.4)、给容器中返回当前组件使用cglib增强了的代理对象;
      2.5)、以后容器中获取到的就是这个组件的代理对象,执行目标方法的时候,代理对象就会执行通知
              方法的流程;
 3)、目标方法执行  ;
      容器中保存了组件的代理对象(cglib增强后的对象),这个对象里面保存了详细信息(比如增强 
                器,目标对象,xxx);
      3.1)、CglibAopProxy.intercept();拦截目标方法的执行
      3.2)、根据ProxyFactory对象获取将要执行的目标方法拦截器链;
        List<Object> chain = 
                           this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);
        3.2.1)、List<Object> interceptorList保存所有拦截器 5
              一个默认的ExposeInvocationInterceptor 和 4个增强器;
        3.2.2)、遍历所有的增强器,将其转为Interceptor;
              registry.getInterceptors(advisor);
        3.2.3)、将增强器转为List<MethodInterceptor>;
              如果是MethodInterceptor,直接加入到集合中
              如果不是,使用AdvisorAdapter将增强器转为MethodInterceptor;
              转换完成返回MethodInterceptor数组;
      3.3)、如果没有拦截器链,直接执行目标方法;
        拦截器链(每一个通知方法又被包装为方法拦截器,利用MethodInterceptor机制)
      3.4)、如果有拦截器链,把需要执行的目标对象,目标方法,
        拦截器链等信息传入创建一个 CglibMethodInvocation 对象,
        并调用 Object retVal =  mi.proceed();
      3.5)、拦截器链的触发过程;
        3.5.1)、如果没有拦截器执行执行目标方法,或者拦截器的索引和拦截器数组-1大小一样(指定
                    到了最后一个拦截器)执行目标方法;
        3.5.2)、链式获取每一个拦截器,拦截器执行invoke方法,每一个拦截器等待下一个拦截器执
                    行完成返回以后再来执行;拦截器链的机制,保证通知方法与目标方法的执行顺序;

三、创建AOP代理

断点打在AbstractAutoProxyCreator的postProcessAfterInitialization(Object, String)   方法

  @Override
  public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
    if (bean != null) {
      Object cacheKey = getCacheKey(bean.getClass(), beanName);
      if (!this.earlyProxyReferences.contains(cacheKey)) {
        return wrapIfNecessary(bean, beanName, cacheKey);
      }
    }
    return bean;
  }

进入wrapIfNecessary方法->进入createProxy方法->buildAdvisors方法返回, 如下图可以查看四个增强器    

logStart(JoinPoint joinPoint)

logEnd(JoinPoint joinPoint)

logReturn(JoinPoint joinPoint,Object result)

logException(JoinPoint joinPoint,Exception exception)

 

断点进入proxyFactory.getProxy(getProxyClassLoader())后可以看到创建了个LogAspects类AOP的cglib代理

 

org.springframework.aop.framework.ProxyFactory: 0 interfaces []; 5 
advisors [org.springframework.aop.interceptor.ExposeInvocationInterceptor.ADVISOR, 
InstantiationModelAwarePointcutAdvisor: expression [pointCut()];
advice method [public void 
com.atguigu.aop.LogAspects.logException(org.aspectj.lang.JoinPoint,java.lang.Exception)]; 
perClauseKind=SINGLETON, InstantiationModelAwarePointcutAdvisor: expression [pointCut()]; 
advice method [public void 
com.atguigu.aop.LogAspects.logReturn(org.aspectj.lang.JoinPoint,java.lang.Object)]; 
perClauseKind=SINGLETON, InstantiationModelAwarePointcutAdvisor: expression 
[com.atguigu.aop.LogAspects.pointCut()]; 
advice method [public void com.atguigu.aop.LogAspects.logEnd(org.aspectj.lang.JoinPoint)]; 
perClauseKind=SINGLETON, InstantiationModelAwarePointcutAdvisor: expression [pointCut()]; 
advice method [public void
com.atguigu.aop.LogAspects.logStart(org.aspectj.lang.JoinPoint)]; perClauseKind=SINGLETON]; 
targetSource [SingletonTargetSource for target object 
[com.atguigu.aop.MathCalculator@7d898981]]; proxyTargetClass=true; optimize=false; 
opaque=false; exposeProxy=false; frozen=false

四、获取拦截器链-MethodInterceptor

AOP拦截器链MethodInterceptor拦截下了mathCalculator.div(1, 0)然后执行所有对应的增强器

断点打在mathCalculator.div(1, 0)

step into mathCalculator.div(1, 0) ->

step return->step into->step return->step into->step return反复几次后进入CglibAopProxy内部类DynamicAdvisedInterceptor的intercept方法->

step into advised.getInterceptorsAndDynamicInterceptionAdvice->

step into advisorChainFactory.getInterceptorsAndDynamicInterceptionAdvice->

step into   registry.getInterceptors(advisor)->

返回MethodInterceptor[]

3)、如果没有拦截器链,直接执行目标方法;

       拦截器链(每一个通知方法又被包装为方法拦截器,利用MethodInterceptor机制)

4)、如果有拦截器链,把需要执行的目标对象,目标方法,

        拦截器链等信息传入创建一个 CglibMethodInvocation 对象,

        并调用 Object retVal =  mi.proceed();

链式调用通知方法

接下来剖析下 new CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed()的proceed()方法

源码如下:

@Override
public Object proceed() throws Throwable {
    //  We start with an index of -1 and increment early.
  if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
      return invokeJoinpoint();
  }
  Object interceptorOrInterceptionAdvice =
        this.interceptorsAndDynamicMethodMatchers.get(++this.currentInterceptorIndex);
  if (interceptorOrInterceptionAdvice instanceof InterceptorAndDynamicMethodMatcher) {
    // Evaluate dynamic method matcher here: static part will already have
    // been evaluated and found to match.
    InterceptorAndDynamicMethodMatcher dm =
          (InterceptorAndDynamicMethodMatcher) interceptorOrInterceptionAdvice;
    if (dm.methodMatcher.matches(this.method, this.targetClass, this.arguments)) {
        return dm.interceptor.invoke(this);
    }else {
      // Dynamic matching failed.
      // Skip this interceptor and invoke the next in the chain.
      return proceed();
    }
  }else {
      // It's an interceptor, so we just invoke it: The pointcut will have
      // been evaluated statically before this object was constructed.
      return ((MethodInterceptor) interceptorOrInterceptionAdvice).invoke(this);
  }
}

从上图可以看出前面四次都执行了interceptorOrInterceptionAdvice).invoke(this)分别是下面5个类的invoke,而invoke又执行了mi.proceed() (mi就是CglibMethodInvocation),每次执行变量currentInterceptorIndex就会加1

ExposeInvocationInterceptor的invoke

  @Override
  public Object invoke(MethodInvocation mi) throws Throwable {
    MethodInvocation oldInvocation = invocation.get();
    invocation.set(mi);
    try {
      return mi.proceed();
    }
    finally {
      invocation.set(oldInvocation);
    }
  }

AspectJAfterThrowingAdvice 的invoke

  @Override
  public Object invoke(MethodInvocation mi) throws Throwable {
    try {
      return mi.proceed();
    }
    catch (Throwable ex) {
      if (shouldInvokeOnThrowing(ex)) {
        invokeAdviceMethod(getJoinPointMatch(), null, ex);
      }
      throw ex;
    }
  }

AOP总结

1)、@EnableAspectJAutoProxy 开启AOP功能
2)、@EnableAspectJAutoProxy 会给容器中注册一个组件 AnnotationAwareAspectJAutoProxyCreator
3)、AnnotationAwareAspectJAutoProxyCreator是一个后置处理器;
4)、容器的创建流程:
    4.1)、registerBeanPostProcessors()注册后置处理器;创建
               AnnotationAwareAspectJAutoProxyCreator对象
    4.2)、finishBeanFactoryInitialization()初始化剩下的单实例bean
      4.2.1)、创建业务逻辑组件和切面组件
      4.2.2)、AnnotationAwareAspectJAutoProxyCreator拦截组件的创建过程
      4.2.3)、组件创建完之后,判断组件是否需要增强是:切面的通知方法,包装成增强器
                   (Advisor);给业务逻辑组件创建一个代理对象(cglib);
5)、执行目标方法:
    5.1)、代理对象执行目标方法
    5.2)、CglibAopProxy.intercept();
      5.2.1)、得到目标方法的拦截器链(增强器包装成拦截器MethodInterceptor)
      5.2.2)、利用拦截器的链式机制,依次进入每一个拦截器进行执行;
      5.2.3)、效果:
            正常执行:前置通知-》目标方法-》后置通知-》返回通知
            出现异常:前置通知-》目标方法-》后置通知-》异常通知

 

相关文章
|
15天前
|
SQL Java 数据库连接
(自用)Spring常用配置
(自用)Spring常用配置
16 0
|
2天前
|
XML 人工智能 Java
Spring Bean名称生成规则(含源码解析、自定义Spring Bean名称方式)
Spring Bean名称生成规则(含源码解析、自定义Spring Bean名称方式)
|
7天前
|
存储 安全 Java
第2章 Spring Security 的环境设置与基础配置(2024 最新版)(下)
第2章 Spring Security 的环境设置与基础配置(2024 最新版)(下)
16 0
|
7天前
|
安全 Java 数据库
第2章 Spring Security 的环境设置与基础配置(2024 最新版)(上)
第2章 Spring Security 的环境设置与基础配置(2024 最新版)
33 0
|
9天前
|
安全 Java Spring
Spring Security 5.7 最新配置细节(直接就能用),WebSecurityConfigurerAdapter 已废弃
Spring Security 5.7 最新配置细节(直接就能用),WebSecurityConfigurerAdapter 已废弃
20 0
|
9天前
|
安全 Java 应用服务中间件
江帅帅:Spring Boot 底层级探索系列 03 - 简单配置
江帅帅:Spring Boot 底层级探索系列 03 - 简单配置
25 0
江帅帅:Spring Boot 底层级探索系列 03 - 简单配置
|
9天前
|
Java 关系型数据库 MySQL
一套java+ spring boot与vue+ mysql技术开发的UWB高精度工厂人员定位全套系统源码有应用案例
UWB (ULTRA WIDE BAND, UWB) 技术是一种无线载波通讯技术,它不采用正弦载波,而是利用纳秒级的非正弦波窄脉冲传输数据,因此其所占的频谱范围很宽。一套UWB精确定位系统,最高定位精度可达10cm,具有高精度,高动态,高容量,低功耗的应用。
一套java+ spring boot与vue+ mysql技术开发的UWB高精度工厂人员定位全套系统源码有应用案例
|
14天前
|
JSON Java 数据库连接
属性注入掌握:Spring Boot配置属性的高级技巧与最佳实践
属性注入掌握:Spring Boot配置属性的高级技巧与最佳实践
23 1
|
14天前
|
Java 数据库连接 Spring
简化配置,提高灵活性:Spring中的参数化配置技巧
简化配置,提高灵活性:Spring中的参数化配置技巧
19 0
|
14天前
|
Java Shell 测试技术
一次配置,多场景适用:Spring Boot多套配置文件的深度剖析
一次配置,多场景适用:Spring Boot多套配置文件的深度剖析
32 0
一次配置,多场景适用:Spring Boot多套配置文件的深度剖析