Advice
通知:
-
BeforeAdvice
:接口MethodBeforeAdvice
,方法before()
-
AfterAdvice
:接口AfterReturningAdvice
,方法afterReturning()
-
ThrowsAdvice
:在抛出异常时回调,这个回调是AOP通过反射机制完成的。
Pointcut
切点:
概念:决定Advice
通知应该作用于哪个连接点。返回一个MethodMatcher
,由它来判断是否需要对当前方法调用进行增强,或者是否需要对当前调用方法应用配置好的Advice
通知。
- 通过正则表达式进行匹配
- 通过方法名进行匹配
- 等等
Spring AOP的设计和实现
JVM动态代理
Advisor通知器:
概念:将Advice
和pointcut
结合起来,可以定义应该使用哪个通知在哪个关注点使用。
建立AopProxy代理对象
ProxyFactoryBean:封装了主要代理对象的生成过程,生成方式有两种
- JDK的Proxy
-
CGLIB
这里写图片描述
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);
}
拦截器调用的实现
JdkDynamicAopProxy
的invoke
拦截:
当Proxy对象的代理方法被调用的时候,JdkDynamicAopProxy
的invoke
方法作为Proxy对象的回调函数被触发,从而通过invoke的具体实现,构造ReflectiveMethodInvocation
对象来完成对目标对象方法调用的拦截或者说功能增强。
Cglib2AopProxy
的intercept
拦截:
与JdkDynamicAopProxy
的回调实现非常类似,唯一不同的是构造CglibMethodInvocation
对象来完成拦截器链的调用。
对目标方法的调用:
- jdk:使用反射机制得到调用方法的反射对象,然后使用invoke启动对方法反射对象的调用。
- cglib:通过
MethodProxy
对象来直接invoke完成的
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;
}
网友评论