1. Java代理机制深度解析在Java开发中代理模式就像请了个业务秘书——当你需要找第三方合作但又不愿直接暴露自己时找个中间人帮你处理所有对接细节。这种设计模式在实际开发中应用广泛特别是在需要控制对象访问、增强功能或实现解耦的场景。1.1 为什么需要代理想象你开了一家电商公司当需要与物流公司合作时通常不会直接让物流接触你的核心仓储系统而是通过一个物流对接专员来处理所有交互。这个专员就是现实中的代理在Java中我们通过代理类实现类似效果。典型应用场景包括权限控制如方法调用前校验权限日志记录自动记录方法调用信息性能监控统计方法执行耗时远程调用RPC框架的核心机制事务管理Spring声明式事务的基础1.2 Java代理的两种实现方式Java提供了两种截然不同的代理实现方案就像买车时有原厂改装和第三方改装两种选择1.2.1 JDK动态代理 - 原厂方案public class JdkProxyDemo { interface Service { void doBusiness(); } static class RealService implements Service { public void doBusiness() { System.out.println(实际业务处理); } } static class LoggingHandler implements InvocationHandler { private final Object target; public LoggingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { System.out.println([ new Date() ] 调用方法: method.getName()); return method.invoke(target, args); } } public static void main(String[] args) { Service real new RealService(); Service proxy (Service) Proxy.newProxyInstance( Service.class.getClassLoader(), new Class[]{Service.class}, new LoggingHandler(real) ); proxy.doBusiness(); } }关键点JDK代理要求目标类必须实现接口生成的代理类会实现相同接口。在Java 8及以后版本中Proxy类的性能已经过深度优化反射调用的开销大幅降低。1.2.2 CGLIB字节码增强 - 第三方强力方案public class CglibProxyDemo { static class RealService { public void doBusiness() { System.out.println(实际业务处理); } } static class LoggingInterceptor implements MethodInterceptor { public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable { System.out.println([ new Date() ] 调用方法: method.getName()); return proxy.invokeSuper(obj, args); } } public static void main(String[] args) { Enhancer enhancer new Enhancer(); enhancer.setSuperclass(RealService.class); enhancer.setCallback(new LoggingInterceptor()); RealService proxy (RealService) enhancer.create(); proxy.doBusiness(); } }注意事项CGLIB通过继承方式实现代理因此无法代理final类和final方法。在Spring AOP中默认对接口使用JDK代理对类使用CGLIB代理。1.3 性能对比与选型建议在Java 8环境中两者的性能差距已经不明显。以下是选型参考考量维度JDK动态代理CGLIB依赖要求内置JDK需要引入第三方库目标类要求必须实现接口类不能被final修饰方法过滤基于接口方法可灵活过滤初始化性能较快首次加载稍慢执行性能接近直接调用略慢于JDK代理内存占用较低每个代理类占用PermGen实际项目中如果使用Spring框架通常不需要直接选择Spring会自动根据目标类特征选择最优方案。2. 代理模式的高级应用技巧2.1 多层嵌套代理就像俄罗斯套娃一样代理也可以层层嵌套每个代理处理不同的横切关注点public class MultiLayerProxy { interface PaymentService { void pay(BigDecimal amount); } static class RealPaymentService implements PaymentService { public void pay(BigDecimal amount) { System.out.println(支付处理: amount); } } // 第一层日志记录 static class LoggingHandler implements InvocationHandler { private final Object target; public LoggingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { System.out.println([日志] 进入方法: method.getName()); return method.invoke(target, args); } } // 第二层性能监控 static class TimingHandler implements InvocationHandler { private final Object target; public TimingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { long start System.nanoTime(); Object result method.invoke(target, args); long duration System.nanoTime() - start; System.out.println([监控] 方法执行耗时: duration ns); return result; } } public static void main(String[] args) { PaymentService real new RealPaymentService(); // 创建日志代理 PaymentService loggingProxy (PaymentService) Proxy.newProxyInstance( PaymentService.class.getClassLoader(), new Class[]{PaymentService.class}, new LoggingHandler(real) ); // 在日志代理基础上创建监控代理 PaymentService timingProxy (PaymentService) Proxy.newProxyInstance( PaymentService.class.getClassLoader(), new Class[]{PaymentService.class}, new TimingHandler(loggingProxy) ); timingProxy.pay(new BigDecimal(100.00)); } }2.2 动态代理的线程安全问题代理对象本身是线程安全的但Handler中的状态需要特别注意public class ThreadSafeProxy { interface Counter { void increment(); int getCount(); } static class UnsafeCounter implements Counter { private int count 0; public void increment() { count; } public int getCount() { return count; } } static class SafeInvocationHandler implements InvocationHandler { private final Object target; private final Object lock new Object(); public SafeInvocationHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 只对写方法加锁 if (method.getName().startsWith(set) || method.getName().equals(increment)) { synchronized (lock) { return method.invoke(target, args); } } return method.invoke(target, args); } } }2.3 基于注解的代理方法过滤结合注解实现更精细的代理控制Retention(RetentionPolicy.RUNTIME) Target(ElementType.METHOD) public interface Audited { String value() default ; } public class AnnotationBasedProxy { interface BankService { Audited(开户操作) void openAccount(); void queryBalance(); } static class AuditHandler implements InvocationHandler { private final Object target; public AuditHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { Audited audited method.getAnnotation(Audited.class); if (audited ! null) { System.out.println([审计] 操作类型: audited.value()); } return method.invoke(target, args); } } }3. Spring框架中的代理实战3.1 Spring AOP的代理机制Spring AOP就像个智能代理工厂根据以下规则自动选择代理方式如果目标对象实现了接口 → 使用JDK动态代理如果目标对象没有实现接口 → 使用CGLIB可通过EnableAspectJAutoProxy(proxyTargetClasstrue)强制使用CGLIB配置示例Configuration EnableAspectJAutoProxy public class AppConfig { Bean public LoggingAspect loggingAspect() { return new LoggingAspect(); } } Aspect public class LoggingAspect { Around(execution(* com.example.service.*.*(..))) public Object logMethodCall(ProceedingJoinPoint pjp) throws Throwable { String methodName pjp.getSignature().getName(); System.out.println(进入方法: methodName); try { return pjp.proceed(); } finally { System.out.println(退出方法: methodName); } } }3.2 解决Spring代理的常见坑点3.2.1 自调用问题Service public class OrderService { public void placeOrder() { // 此调用会绕过代理 validateStock(); } Transactional public void validateStock() { // 事务注解不会生效 } }解决方案自我注入推荐Service public class OrderService { Autowired private OrderService self; public void placeOrder() { self.validateStock(); } }通过AopContext获取当前代理需暴露代理EnableAspectJAutoProxy(exposeProxytrue) public class AppConfig {} public void placeOrder() { ((OrderService)AopContext.currentProxy()).validateStock(); }3.2.2 代理对象识别判断对象是否是代理public static boolean isProxy(Object object) { return (object instanceof SpringProxy || AopUtils.isAopProxy(object) || (object ! null AopUtils.isCglibProxy(object))); }获取原始目标对象public static Object getTarget(Object proxy) { if (proxy null) return null; if (AopUtils.isJdkDynamicProxy(proxy)) { try { Field h proxy.getClass().getSuperclass().getDeclaredField(h); h.setAccessible(true); Object handler h.get(proxy); Field target handler.getClass().getDeclaredField(target); target.setAccessible(true); return target.get(handler); } catch (Exception e) { throw new IllegalStateException(e); } } if (AopUtils.isCglibProxy(proxy)) { try { Field h proxy.getClass().getDeclaredField(CGLIB$CALLBACK_0); h.setAccessible(true); Object interceptor h.get(proxy); Field target interceptor.getClass().getDeclaredField(target); target.setAccessible(true); return target.get(interceptor); } catch (Exception e) { throw new IllegalStateException(e); } } return proxy; // 不是代理 }4. 代理模式性能优化4.1 代理类缓存机制高频创建代理实例时使用缓存避免重复生成public class ProxyCache { private static final MapClass?, Object proxyCache new ConcurrentHashMap(); SuppressWarnings(unchecked) public static T T getProxy(ClassT interfaceType, T realInstance) { return (T) proxyCache.computeIfAbsent(interfaceType, clazz - Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new LoggingHandler(realInstance) ) ); } }4.2 方法调用优化技巧缓存Method对象class OptimizedHandler implements InvocationHandler { private final Object target; private final MapMethod, Method methodCache new ConcurrentHashMap(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { Method targetMethod methodCache.computeIfAbsent(method, m - { try { return target.getClass().getMethod( m.getName(), m.getParameterTypes()); } catch (Exception e) { throw new IllegalStateException(e); } }); return targetMethod.invoke(target, args); } }使用MethodHandleJava 7class MethodHandleHandler implements InvocationHandler { private final Object target; private final MapMethod, MethodHandle handleCache new ConcurrentHashMap(); private static final MethodHandles.Lookup lookup MethodHandles.lookup(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { MethodHandle handle handleCache.computeIfAbsent(method, m - { try { return lookup.unreflect(m); } catch (IllegalAccessException e) { throw new IllegalStateException(e); } }); return handle.bindTo(target).invokeWithArguments(args); } }5. 新型代理方案探索5.1 Java Agent字节码增强适用于需要在类加载期修改字节码的场景public class MyAgent { public static void premain(String args, Instrumentation inst) { inst.addTransformer(new ClassFileTransformer() { public byte[] transform(ClassLoader loader, String className, Class? classBeingRedefined, ProtectionDomain protectionDomain, byte[] classfileBuffer) { if (!className.equals(com/example/TargetClass)) { return null; } // 使用ASM或Javassist修改字节码 return enhanceClass(classfileBuffer); } }); } }MANIFEST.MF配置Premain-Class: com.example.MyAgent Can-Redefine-Classes: true Can-Retransform-Classes: true5.2 基于Project Loom的虚拟线程代理Java 19的虚拟线程特性为高并发代理带来新可能public class VirtualThreadProxy { interface AsyncService { CompletableFutureString asyncOperation(); } static class VirtualThreadHandler implements InvocationHandler { private final Object target; private final ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); public Object invoke(Object proxy, Method method, Object[] args) { return CompletableFuture.supplyAsync(() - { try { return method.invoke(target, args); } catch (Exception e) { throw new CompletionException(e); } }, executor); } } }6. 常见问题排查指南6.1 代理异常处理清单异常现象可能原因解决方案NullPointerExceptionInvocationHandler未正确处理null返回值检查invoke方法的所有返回路径ClassCastException代理转换错误确保转换类型与接口类型匹配StackOverflowError代理递归调用检查代理逻辑中的循环调用UndeclaredThrowableException被代理方法抛出了检查异常在接口方法声明中添加throws子句性能明显下降频繁创建代理实例引入代理实例缓存机制6.2 调试技巧查看生成的代理类System.getProperties().put(sun.misc.ProxyGenerator.saveGeneratedFiles, true);分析CGLIB生成的类System.setProperty(DebuggingClassWriter.DEBUG_LOCATION_PROPERTY, /tmp/cglib);使用Arthas诊断代理调用# 查看代理类继承关系 sc -d com.example.ProxyClass # 监控方法调用 watch com.example.ProxyClass * {params, returnObj} -x 37. 设计模式最佳实践7.1 代理与装饰器模式的区别虽然结构相似但两者设计目的不同维度代理模式装饰器模式目的控制访问增强功能关注点对象访问权限对象功能扩展创建时机通常由框架创建通常手动创建对象关系代理知道被代理对象的具体信息装饰器只关心接口典型应用Spring AOP、RPC框架I/O流处理、集合包装7.2 代理模式组合应用结合其他设计模式实现更强大的代理代理工厂模式public class ProxyFactory { private static final MapClass?, Object proxies new ConcurrentHashMap(); SuppressWarnings(unchecked) public static T T getProxy(ClassT interfaceType) { return (T) proxies.computeIfAbsent(interfaceType, clazz - { T realInstance createRealInstance(interfaceType); return Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new CustomHandler(realInstance) ); }); } }代理责任链模式public class ChainableHandler implements InvocationHandler { private final Object target; private final ListInvocationHandler handlers; public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 构建调用链 InvocationChain chain new InvocationChain(target, method, args, handlers); return chain.proceed(); } static class InvocationChain { private final IteratorInvocationHandler iterator; private final Object target; private final Method method; private final Object[] args; public InvocationChain(Object target, Method method, Object[] args, ListInvocationHandler handlers) { this.iterator handlers.iterator(); this.target target; this.method method; this.args args; } public Object proceed() throws Throwable { if (iterator.hasNext()) { return iterator.next().invoke(target, method, args); } return method.invoke(target, args); } } }8. 企业级应用案例8.1 RPC框架中的动态代理以Dubbo为例的远程服务代理实现public class DubboProxyFactory { public static T T getProxy(ClassT interfaceType, String url) { return (T) Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new InvocationHandler() { private final HttpClient client new HttpClient(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { RpcRequest request new RpcRequest(); request.setInterfaceName(interfaceType.getName()); request.setMethodName(method.getName()); request.setParameterTypes(method.getParameterTypes()); request.setParameters(args); // 发送网络请求 String response client.post(url, serialize(request)); return deserialize(response, method.getReturnType()); } } ); } }8.2 数据库访问代理实现一个简易的MyBatis风格Mapper代理public class MapperProxyFactory { private final SqlSession session; public T T createMapper(ClassT mapperInterface) { return (T) Proxy.newProxyInstance( mapperInterface.getClassLoader(), new Class[]{mapperInterface}, new MapperHandler(mapperInterface, session) ); } static class MapperHandler implements InvocationHandler { private final Class? mapperInterface; private final SqlSession session; private final MapMethod, MapperMethod methodCache new ConcurrentHashMap(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { if (Object.class.equals(method.getDeclaringClass())) { return method.invoke(this, args); } MapperMethod mapperMethod methodCache.computeIfAbsent(method, m - new MapperMethod(mapperInterface, m, session.getConfiguration())); return mapperMethod.execute(session, args); } } }9. 未来演进方向9.1 响应式编程中的代理在Reactive编程中代理可以处理背压和异步流控制public class ReactiveProxy { public static T T create(ClassT interfaceType, T target) { return (T) Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new InvocationHandler() { public Object invoke(Object proxy, Method method, Object[] args) { if (isReactiveType(method.getReturnType())) { return handleReactiveCall(method, args); } return handleNormalCall(method, args); } private Object handleReactiveCall(Method method, Object[] args) { return Mono.fromCallable(() - method.invoke(target, args)) .subscribeOn(Schedulers.boundedElastic()) .onErrorMap(this::transformException); } } ); } }9.2 GraalVM原生镜像支持为GraalVM原生镜像编译优化代理代码注册动态代理类到反射配置中// reflect-config.json { name:com.example.$Proxy0, methods:[{name:equals},{name:toString}] }使用native-image构建参数--allow-incomplete-classpath \ --initialize-at-build-timecom.example \ --report-unsupported-elements-at-runtime \ -H:DynamicProxyConfigurationFilesproxy-config.json10. 性能测试与对比10.1 基准测试设计使用JMH进行代理性能测试State(Scope.Thread) BenchmarkMode(Mode.AverageTime) OutputTimeUnit(TimeUnit.NANOSECONDS) public class ProxyBenchmark { private Service realService; private Service jdkProxy; private Service cglibProxy; Setup public void setup() { realService new RealService(); jdkProxy (Service) Proxy.newProxyInstance( Service.class.getClassLoader(), new Class[]{Service.class}, new LoggingHandler(realService) ); Enhancer enhancer new Enhancer(); enhancer.setSuperclass(RealService.class); enhancer.setCallback(new LoggingInterceptor()); cglibProxy (Service) enhancer.create(); } Benchmark public void baseline() { realService.doBusiness(); } Benchmark public void jdkProxyTest() { jdkProxy.doBusiness(); } Benchmark public void cglibProxyTest() { cglibProxy.doBusiness(); } }10.2 典型测试结果在JDK 17环境下的测试数据纳秒/操作测试场景平均耗时相对耗时直接调用15 ns1.0xJDK动态代理42 ns2.8xCGLIB代理38 ns2.5x带方法过滤的代理75 ns5.0x多层嵌套代理210 ns14.0x实际项目中的性能考虑代理调用的开销通常只在方法调用非常频繁100万次/秒时才需要特别关注大多数业务场景中代理带来的额外开销可以忽略不计。
1. Java代理机制深度解析在Java开发中代理模式就像请了个业务秘书——当你需要找第三方合作但又不愿直接暴露自己时找个中间人帮你处理所有对接细节。这种设计模式在实际开发中应用广泛特别是在需要控制对象访问、增强功能或实现解耦的场景。1.1 为什么需要代理想象你开了一家电商公司当需要与物流公司合作时通常不会直接让物流接触你的核心仓储系统而是通过一个物流对接专员来处理所有交互。这个专员就是现实中的代理在Java中我们通过代理类实现类似效果。典型应用场景包括权限控制如方法调用前校验权限日志记录自动记录方法调用信息性能监控统计方法执行耗时远程调用RPC框架的核心机制事务管理Spring声明式事务的基础1.2 Java代理的两种实现方式Java提供了两种截然不同的代理实现方案就像买车时有原厂改装和第三方改装两种选择1.2.1 JDK动态代理 - 原厂方案public class JdkProxyDemo { interface Service { void doBusiness(); } static class RealService implements Service { public void doBusiness() { System.out.println(实际业务处理); } } static class LoggingHandler implements InvocationHandler { private final Object target; public LoggingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { System.out.println([ new Date() ] 调用方法: method.getName()); return method.invoke(target, args); } } public static void main(String[] args) { Service real new RealService(); Service proxy (Service) Proxy.newProxyInstance( Service.class.getClassLoader(), new Class[]{Service.class}, new LoggingHandler(real) ); proxy.doBusiness(); } }关键点JDK代理要求目标类必须实现接口生成的代理类会实现相同接口。在Java 8及以后版本中Proxy类的性能已经过深度优化反射调用的开销大幅降低。1.2.2 CGLIB字节码增强 - 第三方强力方案public class CglibProxyDemo { static class RealService { public void doBusiness() { System.out.println(实际业务处理); } } static class LoggingInterceptor implements MethodInterceptor { public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable { System.out.println([ new Date() ] 调用方法: method.getName()); return proxy.invokeSuper(obj, args); } } public static void main(String[] args) { Enhancer enhancer new Enhancer(); enhancer.setSuperclass(RealService.class); enhancer.setCallback(new LoggingInterceptor()); RealService proxy (RealService) enhancer.create(); proxy.doBusiness(); } }注意事项CGLIB通过继承方式实现代理因此无法代理final类和final方法。在Spring AOP中默认对接口使用JDK代理对类使用CGLIB代理。1.3 性能对比与选型建议在Java 8环境中两者的性能差距已经不明显。以下是选型参考考量维度JDK动态代理CGLIB依赖要求内置JDK需要引入第三方库目标类要求必须实现接口类不能被final修饰方法过滤基于接口方法可灵活过滤初始化性能较快首次加载稍慢执行性能接近直接调用略慢于JDK代理内存占用较低每个代理类占用PermGen实际项目中如果使用Spring框架通常不需要直接选择Spring会自动根据目标类特征选择最优方案。2. 代理模式的高级应用技巧2.1 多层嵌套代理就像俄罗斯套娃一样代理也可以层层嵌套每个代理处理不同的横切关注点public class MultiLayerProxy { interface PaymentService { void pay(BigDecimal amount); } static class RealPaymentService implements PaymentService { public void pay(BigDecimal amount) { System.out.println(支付处理: amount); } } // 第一层日志记录 static class LoggingHandler implements InvocationHandler { private final Object target; public LoggingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { System.out.println([日志] 进入方法: method.getName()); return method.invoke(target, args); } } // 第二层性能监控 static class TimingHandler implements InvocationHandler { private final Object target; public TimingHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { long start System.nanoTime(); Object result method.invoke(target, args); long duration System.nanoTime() - start; System.out.println([监控] 方法执行耗时: duration ns); return result; } } public static void main(String[] args) { PaymentService real new RealPaymentService(); // 创建日志代理 PaymentService loggingProxy (PaymentService) Proxy.newProxyInstance( PaymentService.class.getClassLoader(), new Class[]{PaymentService.class}, new LoggingHandler(real) ); // 在日志代理基础上创建监控代理 PaymentService timingProxy (PaymentService) Proxy.newProxyInstance( PaymentService.class.getClassLoader(), new Class[]{PaymentService.class}, new TimingHandler(loggingProxy) ); timingProxy.pay(new BigDecimal(100.00)); } }2.2 动态代理的线程安全问题代理对象本身是线程安全的但Handler中的状态需要特别注意public class ThreadSafeProxy { interface Counter { void increment(); int getCount(); } static class UnsafeCounter implements Counter { private int count 0; public void increment() { count; } public int getCount() { return count; } } static class SafeInvocationHandler implements InvocationHandler { private final Object target; private final Object lock new Object(); public SafeInvocationHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 只对写方法加锁 if (method.getName().startsWith(set) || method.getName().equals(increment)) { synchronized (lock) { return method.invoke(target, args); } } return method.invoke(target, args); } } }2.3 基于注解的代理方法过滤结合注解实现更精细的代理控制Retention(RetentionPolicy.RUNTIME) Target(ElementType.METHOD) public interface Audited { String value() default ; } public class AnnotationBasedProxy { interface BankService { Audited(开户操作) void openAccount(); void queryBalance(); } static class AuditHandler implements InvocationHandler { private final Object target; public AuditHandler(Object target) { this.target target; } public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { Audited audited method.getAnnotation(Audited.class); if (audited ! null) { System.out.println([审计] 操作类型: audited.value()); } return method.invoke(target, args); } } }3. Spring框架中的代理实战3.1 Spring AOP的代理机制Spring AOP就像个智能代理工厂根据以下规则自动选择代理方式如果目标对象实现了接口 → 使用JDK动态代理如果目标对象没有实现接口 → 使用CGLIB可通过EnableAspectJAutoProxy(proxyTargetClasstrue)强制使用CGLIB配置示例Configuration EnableAspectJAutoProxy public class AppConfig { Bean public LoggingAspect loggingAspect() { return new LoggingAspect(); } } Aspect public class LoggingAspect { Around(execution(* com.example.service.*.*(..))) public Object logMethodCall(ProceedingJoinPoint pjp) throws Throwable { String methodName pjp.getSignature().getName(); System.out.println(进入方法: methodName); try { return pjp.proceed(); } finally { System.out.println(退出方法: methodName); } } }3.2 解决Spring代理的常见坑点3.2.1 自调用问题Service public class OrderService { public void placeOrder() { // 此调用会绕过代理 validateStock(); } Transactional public void validateStock() { // 事务注解不会生效 } }解决方案自我注入推荐Service public class OrderService { Autowired private OrderService self; public void placeOrder() { self.validateStock(); } }通过AopContext获取当前代理需暴露代理EnableAspectJAutoProxy(exposeProxytrue) public class AppConfig {} public void placeOrder() { ((OrderService)AopContext.currentProxy()).validateStock(); }3.2.2 代理对象识别判断对象是否是代理public static boolean isProxy(Object object) { return (object instanceof SpringProxy || AopUtils.isAopProxy(object) || (object ! null AopUtils.isCglibProxy(object))); }获取原始目标对象public static Object getTarget(Object proxy) { if (proxy null) return null; if (AopUtils.isJdkDynamicProxy(proxy)) { try { Field h proxy.getClass().getSuperclass().getDeclaredField(h); h.setAccessible(true); Object handler h.get(proxy); Field target handler.getClass().getDeclaredField(target); target.setAccessible(true); return target.get(handler); } catch (Exception e) { throw new IllegalStateException(e); } } if (AopUtils.isCglibProxy(proxy)) { try { Field h proxy.getClass().getDeclaredField(CGLIB$CALLBACK_0); h.setAccessible(true); Object interceptor h.get(proxy); Field target interceptor.getClass().getDeclaredField(target); target.setAccessible(true); return target.get(interceptor); } catch (Exception e) { throw new IllegalStateException(e); } } return proxy; // 不是代理 }4. 代理模式性能优化4.1 代理类缓存机制高频创建代理实例时使用缓存避免重复生成public class ProxyCache { private static final MapClass?, Object proxyCache new ConcurrentHashMap(); SuppressWarnings(unchecked) public static T T getProxy(ClassT interfaceType, T realInstance) { return (T) proxyCache.computeIfAbsent(interfaceType, clazz - Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new LoggingHandler(realInstance) ) ); } }4.2 方法调用优化技巧缓存Method对象class OptimizedHandler implements InvocationHandler { private final Object target; private final MapMethod, Method methodCache new ConcurrentHashMap(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { Method targetMethod methodCache.computeIfAbsent(method, m - { try { return target.getClass().getMethod( m.getName(), m.getParameterTypes()); } catch (Exception e) { throw new IllegalStateException(e); } }); return targetMethod.invoke(target, args); } }使用MethodHandleJava 7class MethodHandleHandler implements InvocationHandler { private final Object target; private final MapMethod, MethodHandle handleCache new ConcurrentHashMap(); private static final MethodHandles.Lookup lookup MethodHandles.lookup(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { MethodHandle handle handleCache.computeIfAbsent(method, m - { try { return lookup.unreflect(m); } catch (IllegalAccessException e) { throw new IllegalStateException(e); } }); return handle.bindTo(target).invokeWithArguments(args); } }5. 新型代理方案探索5.1 Java Agent字节码增强适用于需要在类加载期修改字节码的场景public class MyAgent { public static void premain(String args, Instrumentation inst) { inst.addTransformer(new ClassFileTransformer() { public byte[] transform(ClassLoader loader, String className, Class? classBeingRedefined, ProtectionDomain protectionDomain, byte[] classfileBuffer) { if (!className.equals(com/example/TargetClass)) { return null; } // 使用ASM或Javassist修改字节码 return enhanceClass(classfileBuffer); } }); } }MANIFEST.MF配置Premain-Class: com.example.MyAgent Can-Redefine-Classes: true Can-Retransform-Classes: true5.2 基于Project Loom的虚拟线程代理Java 19的虚拟线程特性为高并发代理带来新可能public class VirtualThreadProxy { interface AsyncService { CompletableFutureString asyncOperation(); } static class VirtualThreadHandler implements InvocationHandler { private final Object target; private final ExecutorService executor Executors.newVirtualThreadPerTaskExecutor(); public Object invoke(Object proxy, Method method, Object[] args) { return CompletableFuture.supplyAsync(() - { try { return method.invoke(target, args); } catch (Exception e) { throw new CompletionException(e); } }, executor); } } }6. 常见问题排查指南6.1 代理异常处理清单异常现象可能原因解决方案NullPointerExceptionInvocationHandler未正确处理null返回值检查invoke方法的所有返回路径ClassCastException代理转换错误确保转换类型与接口类型匹配StackOverflowError代理递归调用检查代理逻辑中的循环调用UndeclaredThrowableException被代理方法抛出了检查异常在接口方法声明中添加throws子句性能明显下降频繁创建代理实例引入代理实例缓存机制6.2 调试技巧查看生成的代理类System.getProperties().put(sun.misc.ProxyGenerator.saveGeneratedFiles, true);分析CGLIB生成的类System.setProperty(DebuggingClassWriter.DEBUG_LOCATION_PROPERTY, /tmp/cglib);使用Arthas诊断代理调用# 查看代理类继承关系 sc -d com.example.ProxyClass # 监控方法调用 watch com.example.ProxyClass * {params, returnObj} -x 37. 设计模式最佳实践7.1 代理与装饰器模式的区别虽然结构相似但两者设计目的不同维度代理模式装饰器模式目的控制访问增强功能关注点对象访问权限对象功能扩展创建时机通常由框架创建通常手动创建对象关系代理知道被代理对象的具体信息装饰器只关心接口典型应用Spring AOP、RPC框架I/O流处理、集合包装7.2 代理模式组合应用结合其他设计模式实现更强大的代理代理工厂模式public class ProxyFactory { private static final MapClass?, Object proxies new ConcurrentHashMap(); SuppressWarnings(unchecked) public static T T getProxy(ClassT interfaceType) { return (T) proxies.computeIfAbsent(interfaceType, clazz - { T realInstance createRealInstance(interfaceType); return Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new CustomHandler(realInstance) ); }); } }代理责任链模式public class ChainableHandler implements InvocationHandler { private final Object target; private final ListInvocationHandler handlers; public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 构建调用链 InvocationChain chain new InvocationChain(target, method, args, handlers); return chain.proceed(); } static class InvocationChain { private final IteratorInvocationHandler iterator; private final Object target; private final Method method; private final Object[] args; public InvocationChain(Object target, Method method, Object[] args, ListInvocationHandler handlers) { this.iterator handlers.iterator(); this.target target; this.method method; this.args args; } public Object proceed() throws Throwable { if (iterator.hasNext()) { return iterator.next().invoke(target, method, args); } return method.invoke(target, args); } } }8. 企业级应用案例8.1 RPC框架中的动态代理以Dubbo为例的远程服务代理实现public class DubboProxyFactory { public static T T getProxy(ClassT interfaceType, String url) { return (T) Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new InvocationHandler() { private final HttpClient client new HttpClient(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { RpcRequest request new RpcRequest(); request.setInterfaceName(interfaceType.getName()); request.setMethodName(method.getName()); request.setParameterTypes(method.getParameterTypes()); request.setParameters(args); // 发送网络请求 String response client.post(url, serialize(request)); return deserialize(response, method.getReturnType()); } } ); } }8.2 数据库访问代理实现一个简易的MyBatis风格Mapper代理public class MapperProxyFactory { private final SqlSession session; public T T createMapper(ClassT mapperInterface) { return (T) Proxy.newProxyInstance( mapperInterface.getClassLoader(), new Class[]{mapperInterface}, new MapperHandler(mapperInterface, session) ); } static class MapperHandler implements InvocationHandler { private final Class? mapperInterface; private final SqlSession session; private final MapMethod, MapperMethod methodCache new ConcurrentHashMap(); public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { if (Object.class.equals(method.getDeclaringClass())) { return method.invoke(this, args); } MapperMethod mapperMethod methodCache.computeIfAbsent(method, m - new MapperMethod(mapperInterface, m, session.getConfiguration())); return mapperMethod.execute(session, args); } } }9. 未来演进方向9.1 响应式编程中的代理在Reactive编程中代理可以处理背压和异步流控制public class ReactiveProxy { public static T T create(ClassT interfaceType, T target) { return (T) Proxy.newProxyInstance( interfaceType.getClassLoader(), new Class[]{interfaceType}, new InvocationHandler() { public Object invoke(Object proxy, Method method, Object[] args) { if (isReactiveType(method.getReturnType())) { return handleReactiveCall(method, args); } return handleNormalCall(method, args); } private Object handleReactiveCall(Method method, Object[] args) { return Mono.fromCallable(() - method.invoke(target, args)) .subscribeOn(Schedulers.boundedElastic()) .onErrorMap(this::transformException); } } ); } }9.2 GraalVM原生镜像支持为GraalVM原生镜像编译优化代理代码注册动态代理类到反射配置中// reflect-config.json { name:com.example.$Proxy0, methods:[{name:equals},{name:toString}] }使用native-image构建参数--allow-incomplete-classpath \ --initialize-at-build-timecom.example \ --report-unsupported-elements-at-runtime \ -H:DynamicProxyConfigurationFilesproxy-config.json10. 性能测试与对比10.1 基准测试设计使用JMH进行代理性能测试State(Scope.Thread) BenchmarkMode(Mode.AverageTime) OutputTimeUnit(TimeUnit.NANOSECONDS) public class ProxyBenchmark { private Service realService; private Service jdkProxy; private Service cglibProxy; Setup public void setup() { realService new RealService(); jdkProxy (Service) Proxy.newProxyInstance( Service.class.getClassLoader(), new Class[]{Service.class}, new LoggingHandler(realService) ); Enhancer enhancer new Enhancer(); enhancer.setSuperclass(RealService.class); enhancer.setCallback(new LoggingInterceptor()); cglibProxy (Service) enhancer.create(); } Benchmark public void baseline() { realService.doBusiness(); } Benchmark public void jdkProxyTest() { jdkProxy.doBusiness(); } Benchmark public void cglibProxyTest() { cglibProxy.doBusiness(); } }10.2 典型测试结果在JDK 17环境下的测试数据纳秒/操作测试场景平均耗时相对耗时直接调用15 ns1.0xJDK动态代理42 ns2.8xCGLIB代理38 ns2.5x带方法过滤的代理75 ns5.0x多层嵌套代理210 ns14.0x实际项目中的性能考虑代理调用的开销通常只在方法调用非常频繁100万次/秒时才需要特别关注大多数业务场景中代理带来的额外开销可以忽略不计。
