一、动态代理基础:spring aop的基石
1.1 代理模式的核心思想
代理模式的本质是:为其他对象提供一种代理以控制对这个对象的访问。在spring aop中,我们通过代理模式来增强目标对象的方法。
1.2 jdk动态代理与cglib对比
1.2.1 cglib动态代理示例
public class userservice {
public void test() {
system.out.println("test...");
}
}
// cglib动态代理
userservice target = new userservice();
enhancer enhancer = new enhancer();
enhancer.setsuperclass(userservice.class);
enhancer.setcallback(new methodinterceptor() {
@override
public object intercept(object obj, method method, object[] args,
methodproxy proxy) throws throwable {
system.out.println("before...");
object result = proxy.invoke(target, args);
system.out.println("after...");
return result;
}
});
userservice userservice = (userservice) enhancer.create();
userservice.test();cglib特点:
- 基于继承实现,代理类是目标类的子类
- 不需要目标类实现接口
- 直接操作字节码,性能相对较高
1.2.2 jdk动态代理示例
public interface userinterface {
void test();
}
public class userservice implements userinterface {
public void test() {
system.out.println("test...");
}
}
// jdk动态代理
userservice target = new userservice();
userinterface proxy = (userinterface) proxy.newproxyinstance(
userservice.class.getclassloader(),
new class[]{userinterface.class},
new invocationhandler() {
@override
public object invoke(object proxy, method method, object[] args)
throws throwable {
system.out.println("before...");
object result = method.invoke(target, args);
system.out.println("after...");
return result;
}
}
);
proxy.test();jdk动态代理特点:
- 基于接口实现
- 只能代理实现了接口的类
- 使用反射机制,性能相对较低
1.3 spring的选择策略
spring通过proxyfactory统一了两种动态代理技术的使用,并根据以下规则自动选择:
// proxyfactory选择代理类型的逻辑
if (config.isoptimize() || config.isproxytargetclass() ||
hasnousersuppliedproxyinterfaces(config)) {
class<?> targetclass = config.gettargetclass();
if (targetclass == null) {
throw new aopconfigexception("targetsource cannot determine target class");
}
// 目标类是接口,使用jdk动态代理
if (targetclass.isinterface() || proxy.isproxyclass(targetclass)) {
return new jdkdynamicaopproxy(config);
}
// 否则使用cglib
return new objenesiscglibaopproxy(config);
} else {
// 使用jdk动态代理
return new jdkdynamicaopproxy(config);
}选择规则总结:
optimize为true → cglibproxytargetclass为true → cglib- 目标类没有实现接口 → cglib
- 目标类是接口或已经是代理类 → jdk动态代理
- 其他情况 → jdk动态代理
二、spring aop核心概念详解
2.1 proxyfactory:统一的代理工厂
proxyfactory是spring提供的统一代理创建工厂,它屏蔽了底层动态代理技术的差异:
userservice target = new userservice();
proxyfactory proxyfactory = new proxyfactory();
proxyfactory.settarget(target);
proxyfactory.addadvice(new methodinterceptor() {
@override
public object invoke(methodinvocation invocation) throws throwable {
system.out.println("before...");
object result = invocation.proceed();
system.out.println("after...");
return result;
}
});
userinterface userservice = (userinterface) proxyfactory.getproxy();
userservice.test();2.2 advice:通知的类型
spring aop提供了五种类型的通知,对应aspectj的五个注解:
| 通知类型 | 对应注解 | 执行时机 |
|---|---|---|
| before advice | @before | 方法执行前 |
| after returning advice | @afterreturning | 方法正常返回后 |
| after throwing advice | @afterthrowing | 方法抛出异常后 |
| after (finally) advice | @after | 方法执行后(finally) |
| around advice | @around | 方法执行前后(最强大) |
around advice示例:
@around("execution(* com.example.service.*.*(..))")
public object aroundadvice(proceedingjoinpoint joinpoint) throws throwable {
// 方法执行前逻辑
system.out.println("before method: " + joinpoint.getsignature().getname());
try {
// 执行目标方法
object result = joinpoint.proceed();
// 方法正常返回后逻辑
system.out.println("after method returning");
return result;
} catch (exception e) {
// 方法抛出异常后逻辑
system.out.println("after method throwing: " + e.getmessage());
throw e;
} finally {
// 方法执行后逻辑(一定会执行)
system.out.println("after method (finally)");
}
}2.3 advisor:切面 = 切点 + 通知
advisor是spring aop的核心概念,它将pointcut(切点)和advice(通知)组合在一起:
userservice target = new userservice();
proxyfactory proxyfactory = new proxyfactory();
proxyfactory.settarget(target);
proxyfactory.addadvisor(new pointcutadvisor() {
@override
public pointcut getpointcut() {
// 定义切点:只匹配名为"testabc"的方法
return new staticmethodmatcherpointcut() {
@override
public boolean matches(method method, class<?> targetclass) {
return method.getname().equals("testabc");
}
};
}
@override
public advice getadvice() {
// 定义通知逻辑
return new methodinterceptor() {
@override
public object invoke(methodinvocation invocation) throws throwable {
system.out.println("before...");
object result = invocation.proceed();
system.out.println("after...");
return result;
}
};
}
@override
public boolean isperinstance() {
return false;
}
});三、spring aop的三种配置方式
3.1 proxyfactorybean:工厂bean方式
@configuration
public class aopconfig {
@bean
public methodinterceptor zhouyuaroundadvice() {
return new methodinterceptor() {
@override
public object invoke(methodinvocation invocation) throws throwable {
system.out.println("before...");
object result = invocation.proceed();
system.out.println("after...");
return result;
}
};
}
@bean
public proxyfactorybean userservice() {
userservice userservice = new userservice();
proxyfactorybean proxyfactorybean = new proxyfactorybean();
proxyfactorybean.settarget(userservice);
proxyfactorybean.setinterceptornames("zhouyuaroundadvice");
return proxyfactorybean;
}
}特点:
- 基于factorybean机制
- 可以针对单个bean进行aop配置
- 支持通过名称引用已定义的advice
3.2 beannameautoproxycreator:按bean名称匹配
@bean
public beannameautoproxycreator beannameautoproxycreator() {
beannameautoproxycreator creator = new beannameautoproxycreator();
// 支持通配符匹配
creator.setbeannames("userse*");
creator.setinterceptornames("zhouyuaroundadvice");
creator.setproxytargetclass(true); // 强制使用cglib
return creator;
}特点:
- 批量配置,支持通配符
- 只能根据bean名称匹配
- 配置简单,但不灵活
3.3 defaultadvisorautoproxycreator:自动代理创建器
@bean
public defaultpointcutadvisor defaultpointcutadvisor() {
namematchmethodpointcut pointcut = new namematchmethodpointcut();
pointcut.addmethodname("test");
defaultpointcutadvisor advisor = new defaultpointcutadvisor();
advisor.setpointcut(pointcut);
advisor.setadvice(new zhouyuafterreturningadvice());
return advisor;
}
@bean
public defaultadvisorautoproxycreator defaultadvisorautoproxycreator() {
return new defaultadvisorautoproxycreator();
}特点:
- 自动扫描所有advisor
- 根据pointcut匹配决定是否创建代理
- 最灵活,功能最强大
四、注解驱动的spring aop
4.1 @enableaspectjautoproxy的作用
@enableaspectjautoproxy注解是开启spring aop注解支持的关键:
@configuration
@enableaspectjautoproxy
public class appconfig {
}该注解的作用是向spring容器注册一个annotationawareaspectjautoproxycreator bean,这是一个beanpostprocessor,负责:
- 解析
@aspect注解的类 - 将
@before、@after等注解转换为对应的advisor - 在bean初始化后创建代理对象
4.2 注解使用示例
@aspect
@component
public class loggingaspect {
@before("execution(* com.example.service.*.*(..))")
public void logbefore(joinpoint joinpoint) {
system.out.println("before method: " + joinpoint.getsignature().getname());
}
@afterreturning(
pointcut = "execution(* com.example.service.*.*(..))",
returning = "result"
)
public void logafterreturning(joinpoint joinpoint, object result) {
system.out.println("method returned: " + result);
}
@afterthrowing(
pointcut = "execution(* com.example.service.*.*(..))",
throwing = "error"
)
public void logafterthrowing(joinpoint joinpoint, throwable error) {
system.out.println("method threw exception: " + error);
}
@after("execution(* com.example.service.*.*(..))")
public void logafter(joinpoint joinpoint) {
system.out.println("after method (finally)");
}
@around("execution(* com.example.service.*.*(..))")
public object logaround(proceedingjoinpoint joinpoint) throws throwable {
system.out.println("around before");
object result = joinpoint.proceed();
system.out.println("around after");
return result;
}
}五、代理对象的创建过程
5.1 jdkdynamicaopproxy创建过程
public class jdkdynamicaopproxy implements aopproxy, invocationhandler {
public jdkdynamicaopproxy(advisedsupport config) {
// 1. 获取目标类实现的所有接口
class<?>[] proxiedinterfaces = aopproxyutils.completeproxiedinterfaces(config);
// 2. 额外添加三个接口
list<class<?>> allinterfaces = new arraylist<>(arrays.aslist(proxiedinterfaces));
allinterfaces.add(springproxy.class);
allinterfaces.add(advised.class);
allinterfaces.add(decoratingproxy.class);
// 3. 检查接口中的equals和hashcode方法
finddefinedequalsandhashcodemethods(allinterfaces);
// 4. 创建代理对象
this.proxiedinterfaces = allinterfaces.toarray(new class<?>[0]);
}
@override
public object getproxy(@nullable classloader classloader) {
return proxy.newproxyinstance(
classloader,
this.proxiedinterfaces,
this
);
}
@override
public object invoke(object proxy, method method, object[] args) throws throwable {
// 代理对象的执行逻辑
// ...
}
}5.2 objenesiscglibaopproxy创建过程
public class objenesiscglibaopproxy extends cglibaopproxy {
@override
public object getproxy(@nullable classloader classloader) {
// 1. 创建enhancer对象
enhancer enhancer = createenhancer();
// 2. 设置父类(目标类)
enhancer.setsuperclass(config.gettargetclass());
// 3. 设置接口
enhancer.setinterfaces(aopproxyutils.completeproxiedinterfaces(config));
// 4. 设置回调
enhancer.setcallback(new dynamicadvisedinterceptor(this.advised));
// 5. 创建代理对象
return enhancer.create();
}
}六、代理对象的执行过程
6.1 代理方法执行的核心流程
// 伪代码展示代理对象方法执行过程
public object invoke(method method, object[] args) {
// 1. 获取所有advisor
list<advisor> advisors = getadvisors();
// 2. 筛选与当前方法匹配的advisor
list<advisor> matchedadvisors = filteradvisors(advisors, method);
// 3. 将advisor转换为methodinterceptor
list<methodinterceptor> interceptors =
adaptadvisorstomethodinterceptors(matchedadvisors);
// 4. 创建methodinvocation
methodinvocation invocation = new reflectivemethodinvocation(
target, method, args, interceptors
);
// 5. 执行拦截器链
return invocation.proceed();
}6.2 各注解对应的methodinterceptor执行顺序
| 注解 | 对应interceptor | 执行顺序 |
|---|---|---|
| @before | methodbeforeadviceinterceptor | 先执行通知,后执行目标方法 |
| @afterreturning | afterreturningadviceinterceptor | 先执行目标方法,后执行通知 |
| @afterthrowing | aspectjafterthrowingadvice | 先执行目标方法,异常时执行通知 |
| @after | aspectjafteradvice | 先执行目标方法,后执行通知(finally) |
| @around | aspectjaroundadvice | 完全控制执行流程 |
执行流程示意图:
around.before
↓
before
↓
目标方法执行
↓
afterreturning/afterthrowing
↓
after
↓
around.after
七、abstractadvisorautoproxycreator的工作原理
7.1 核心继承体系
beanpostprocessor
↓
abstractautoproxycreator
↓
abstractadvisorautoproxycreator
↓
aspectjawareadvisorautoproxycreator
↓
annotationawareaspectjautoproxycreator
7.2 关键方法解析
public abstract class abstractadvisorautoproxycreator extends abstractautoproxycreator {
@override
protected object wrapifnecessary(object bean, string beanname, object cachekey) {
// 1. 检查是否已经是代理对象
if (isinfrastructureclass(bean.getclass()) || shouldskip(bean.getclass(), beanname)) {
return bean;
}
// 2. 获取所有advisor
list<advisor> advisors = getadvisors();
// 3. 查找匹配的advisor
list<advisor> matchedadvisors = findadvisorsthatcanapply(advisors, bean.getclass(), beanname);
// 4. 如果有匹配的advisor,创建代理对象
if (!matchedadvisors.isempty()) {
return createproxy(bean.getclass(), beanname, matchedadvisors, bean);
}
return bean;
}
protected list<advisor> getadvisors() {
// 获取所有advisor类型的bean
list<advisor> advisors = new arraylist<>();
string[] advisornames = beanfactoryutils.beannamesfortypeincludingancestors(
this.beanfactory, advisor.class, true, false
);
for (string name : advisornames) {
advisors.add(this.beanfactory.getbean(name, advisor.class));
}
return advisors;
}
}7.3 annotationawareaspectjautoproxycreator的特殊处理
annotationawareaspectjautoproxycreator重写了getadvisors()方法,增加了对@aspect注解的解析:
public class annotationawareaspectjautoproxycreator
extends aspectjawareadvisorautoproxycreator {
@override
protected list<advisor> getadvisors() {
// 调用父类方法获取已注册的advisor
list<advisor> advisors = super.getadvisors();
// 额外解析@aspect注解的bean
advisors.addall(this.aspectjadvisorsbuilder.buildaspectjadvisors());
return advisors;
}
}八、spring aop高级特性
8.1 targetsource:灵活的代理目标源
targetsource允许我们动态控制被代理对象的获取:
targetsource ts = new targetsource() {
@override
public class<?> gettargetclass() {
return userservice.class;
}
@override
public boolean isstatic() {
return false; // 每次调用都获取新的目标对象
}
@override
public object gettarget() {
// 动态创建或获取目标对象
return new userservice();
}
@override
public void releasetarget(object target) {
// 释放目标对象
}
};
proxyfactory pf = new proxyfactory();
pf.settargetsource(ts);应用场景:延迟注入(@lazy)、热替换等
8.2 introduction:引入新接口
introduction允许为被代理对象动态添加新的接口实现:
@aspect
@component
public class introductionaspect {
@declareparents(
value = "com.example.service.*+",
defaultimpl = defaultlockable.class
)
public static lockable mixin;
}
public interface lockable {
void lock();
void unlock();
boolean islocked();
}
public class defaultlockable implements lockable {
private boolean locked;
@override
public void lock() {
this.locked = true;
}
@override
public void unlock() {
this.locked = false;
}
@override
public boolean islocked() {
return this.locked;
}
}8.3 loadtimeweaving:加载时织入
spring aop支持在类加载时进行字节码织入:
@configuration
@enableloadtimeweaving
public class appconfig {
}
// 或使用xml配置
// <context:load-time-weaver/>与运行时织入的区别:
- 运行时织入:通过动态代理在运行时增强
- 加载时织入:在类加载时修改字节码,性能更高
九、spring aop与aspectj的关系
9.1 两者区别
| 特性 | spring aop | aspectj |
|---|---|---|
| 实现方式 | 动态代理(运行时) | 字节码操作(编译时/加载时) |
| 性能 | 相对较慢 | 非常快 |
| 功能 | 有限,仅支持方法级别 | 强大,支持字段、构造器等 |
| 依赖 | 仅需spring | 需要aspectj编译器/织入器 |
| 使用场景 | 大多数企业应用 | 需要高级aop功能的场景 |
9.2 spring如何整合aspectj
spring并没有使用aspectj的编译器或织入器,而是:
- 复用注解:直接使用aspectj定义的注解(@aspect、@before等)
- 自行解析:spring自己解析这些注解并转换为内部表示
- 动态代理实现:通过动态代理实现aop功能
十、性能优化与最佳实践
10.1 性能优化建议
合理选择代理方式:
@configuration
@enableaspectjautoproxy(proxytargetclass = true) // 强制使用cglib
public class appconfig {
}精确指定切点:
// 不推荐:过于宽泛
@before("execution(* *.*(..))")
// 推荐:精确匹配
@before("execution(* com.example.service.userservice.*(..))")避免在advice中做耗时操作:
@around("execution(* com.example.service.*.*(..))")
public object measureperformance(proceedingjoinpoint joinpoint) throws throwable {
long start = system.currenttimemillis();
object result = joinpoint.proceed();
long end = system.currenttimemillis();
log.info("方法执行时间: {}ms", end - start);
return result;
}10.2 常见问题与解决方案
10.2.1 自调用问题
@service
public class userservice {
public void methoda() {
system.out.println("methoda");
this.methodb(); // 自调用,不会触发aop
}
@transactional
public void methodb() {
system.out.println("methodb");
}
}
// 解决方案1:从容器中获取代理对象
@service
public class userservice {
@autowired
private applicationcontext context;
public void methoda() {
system.out.println("methoda");
context.getbean(userservice.class).methodb();
}
}
// 解决方案2:使用aspectj
@configuration
@enableaspectjautoproxy(exposeproxy = true)
public class appconfig {
}
@service
public class userservice {
public void methoda() {
system.out.println("methoda");
((userservice) aopcontext.currentproxy()).methodb();
}
}10.2.2 循环依赖问题
// 当a和b相互依赖且都需要aop时可能出现问题
// 解决方案:使用setter注入而非构造器注入
@service
public class servicea {
private serviceb serviceb;
@autowired
public void setserviceb(serviceb serviceb) {
this.serviceb = serviceb;
}
}十一、总结
spring aop是一个强大而灵活的aop实现框架,其核心机制可以总结如下:
- 动态代理是基础:spring aop基于jdk动态代理和cglib两种技术实现
- 统一抽象层:通过proxyfactory、advisor、advice等概念提供统一api
- 注解驱动:支持使用@aspect、@before等注解声明式配置aop
- 自动代理:通过beanpostprocessor机制自动创建代理对象
- 执行链:通过methodinterceptor链实现多个通知的顺序执行
spring aop的设计体现了以下几个重要原则:
- 开闭原则:通过代理模式实现对目标对象的透明增强
- 单一职责:将横切关注点(日志、事务等)与业务逻辑分离
- 配置优于编码:支持xml、注解等多种配置方式
到此这篇关于spring aop底层源码深度解析之从动态代理到注解实现的完整架构的文章就介绍到这了,更多相关spring aop动态代理到注解内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论