Spring Aop

2020-09-03  本文已影响0人  AnyL8023

Advice通知

Pointcut切点
概念:决定Advice通知应该作用于哪个连接点。返回一个MethodMatcher,由它来判断是否需要对当前方法调用进行增强,或者是否需要对当前调用方法应用配置好的Advice通知。

Spring AOP的设计和实现

JVM动态代理

这里写图片描述

Advisor通知器
概念:将Advicepointcut结合起来,可以定义应该使用哪个通知在哪个关注点使用。

建立AopProxy代理对象

ProxyFactoryBean:封装了主要代理对象的生成过程,生成方式有两种

JDK生成AopProxy代理对象

public Obejct getObject(ClassLoader classLoader) {
        if (logger.isDebugEnabled()) {
            logger.debug("Creating JDK dynamic proxy: target source is " + this.advised.getTargetSource());
        }
        Class[] proxiedInterfaces AopProxyUtils.completeProxiedInterfaces(this.advised);
        findDefinedEqualsAndHashCodeMethods(proxiedInterfaces);
        //这是调用JDK生成Proxy的地方
        return Proxy.newProxyInstance(classLoader, proxiedInterfaces, this);
    }

拦截器调用的实现

JdkDynamicAopProxyinvoke拦截
当Proxy对象的代理方法被调用的时候,JdkDynamicAopProxyinvoke方法作为Proxy对象的回调函数被触发,从而通过invoke的具体实现,构造ReflectiveMethodInvocation对象来完成对目标对象方法调用的拦截或者说功能增强。

Cglib2AopProxyintercept拦截
JdkDynamicAopProxy的回调实现非常类似,唯一不同的是构造CglibMethodInvocation对象来完成拦截器链的调用。

对目标方法的调用

AOP拦截器链的调用
1. 先进行判断,如果已经运行到拦截器链的末尾,直接调用目标对象的实现方法
2. 否则,沿着拦截器链继续进行,得到下一个拦截器,通过这个拦截器进行matches判断,是否适用于横切增强的场合,如果是,从拦截器中得到通知器,并启动通知器的invoke方法进行切面增强
3. 结束之后,迭代调用proceed方法,直到拦截器链中的拦截器都完成以上的拦截过程为止

配置通知器
MethodBeforeAdviceAdapter的实现

 class MethodBeforeAdviceAdapter implements AdvisorAdapter, Serializable {

    @Override
    public boolean supportsAdvice(Advice advice) {
        return (advice instanceof MethodBeforeAdvice);
    }

    @Override
    public MethodInterceptor getInterceptor(Advisor advisor) {
        MethodBeforeAdvice advice = (MethodBeforeAdvice) advisor.getAdvice();
        return new MethodBeforeAdviceInterceptor(advice);
    }
}

MethodBeforeAdviceInterceptor的实现

public class MethodBeforeAdviceInterceptor implements MethodInterceptor, Serializable {

    private MethodBeforeAdvice advice;

    //为指定的Advice创建对应的MethodBeforeAdviceInterceptor对象
    public MethodBeforeAdviceInterceptor(MethodBeforeAdvice advice) {
        Assert.notNull(advice, "Advice must not be null");
        this.advice = advice;
    }

//这个invoke方法是拦截器的回调方法,会在代理对象的方法被调用时触发回调
    @Override
    public Object invoke(MethodInvocation mi) throws Throwable {
        this.advice.before(mi.getMethod(), mi.getArguments(), mi.getThis() );
        return mi.proceed();
    }
}

AfterReturningAdviceInterceptor的实现

public class AfterReturningAdviceInterceptor implements MethodInterceptor, AfterAdvice, Serializable {

    private final AfterReturningAdvice advice;

    /**
     * Create a new AfterReturningAdviceInterceptor for the given advice.
     * @param advice the AfterReturningAdvice to wrap
     */
    public AfterReturningAdviceInterceptor(AfterReturningAdvice advice) {
        Assert.notNull(advice, "Advice must not be null");
        this.advice = advice;
    }

    @Override
    public Object invoke(MethodInvocation mi) throws Throwable {
        Object retVal = mi.proceed();
        this.advice.afterReturning(retVal, mi.getMethod(), mi.getArguments(), mi.getThis());
        return retVal;
    }

 }

Spring AOP的高级特性

HotSwappableTaregetSource:使用户可以以线程安全的方式切换目标对象,提供所谓的热交换功能。

    public synchronized Object swap(Object newTarget) throws IllegalArgumentException {
        Assert.notNull(newTarget, "Target object must not be null");
        Object old = this.target;
        this.target = newTarget;
        return old;
    }

    public synchronized Object getTarget() {
        return this.target;
    }
上一篇下一篇

猜你喜欢

热点阅读