java深入分析Java反射-动态代理 proxy

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java深入分析Java反射-动态代理 proxy相关的知识,希望对你有一定的参考价值。

1.概述

转载:深入分析Java反射(四)-动态代理

【Java】Java 反射机制浅析

【Java】java代理 静态代理 动态代理 proxy

【java】静态代理 proxy

2.动态代理的简介

Java动态代理机制的出现,使得Java开发人员不用手工编写代理类,只要简单地指定一组接口及委托类对象,便能动态地获得代理类。代理类会负责将所有的方法调用分派到委托对象上反射执行,在分派执行的过程中,开发人员还可以按需调整委托类对象及其功能,这是一套非常灵活有弹性的代理框架。Java动态代理实际上通过反射技术,把代理对象和被代理对象(真实对象)的代理关系建立延迟到程序运行之后,动态创建新的代理类去完成对真实对象的代理操作(可以改变原来真实对象的方法行为),这一点成为了当前主流的AOP框架和延迟加载功能的基础。本文在查看和编写动态代理相关的代码使用的是JDK11,不过JDK动态代理相关的功能和接口已经相对稳定,不必担心JDK版本升级带来的兼容性问题,但是需要注意由于JDK9引入了模块概念,动态代理的源码也有不少的改动。下文先介绍设计模式中的代理模式,接着会分析JDK动态代理的核心类库、流程和机制,最后分析其底层源码级别实现。

3.设计模式中的代理模式

代理模式是一种常用的设计模式,其目的就是为其他对象提供一个代理以控制对某个对象的访问。代理类负责为委托类预处理消息,过滤消息并转发消息,以及进行消息被委托类执行后的后续处理。

代理模式主要包括三种角色:

  • Subject抽象主题角色:一般定义为抽象类或者接口,是作为功能的定义,提供一系列抽象的功能方法。

  • RealSubject具体(真实)主题角色:一般称为被委托角色或者被代理角色,它是Subject的一个具体实现。

  • ProxySubject代理主题角色:一般称为委托角色或者代理角色,一般ProxySubject也实现(或者继承)Subject,接收一个具体的Subject实例RealSubject,在RealSubject处理前后做预定义或者后置操作,甚至可以直接忽略RealSubject原来的方法。

把上面的类图编写成代码如下:

public interface Subject 

	void doSomething();


public class RealSubject implements Subject 

	@Override
	public void doSomething() 
		System.out.println("RealSubject doSomething...");
	


public class ProxySubject implements Subject 

	private final Subject subject;

	public ProxySubject(Subject subject) 
		this.subject = subject;
	

	@Override
	public void doSomething() 
		subject.doSomething();
		doOtherThing();
	

	private void doOtherThing() 
		System.out.println("ProxySubject doOtherThing...");
	


public class Client 

	public static void main(String[] args) throws Exception 
		Subject subject = new RealSubject();
		ProxySubject proxySubject = new ProxySubject(subject);
		proxySubject.doSomething();
	

运行Client#main()输出:

RealSubject doSomething...
ProxySubject doOtherThing...

代理模式在日常的场景中也经常碰到,比较常见的一个场景就是游戏代练,套进去上面的代码可以写个比较生动的例子:

public interface Player 

	void playGame();


public class I implements Player 

	@Override
	public void playGame() 
		System.out.println("操作Throwable游戏角色打怪升级");
	


public class ProxyPlayer implements Player 

	private final Player player;

	public ProxyPlayer(Player player) 
		this.player = player;
	

	@Override
	public void playGame() 
		login();
		this.player.playGame();
		logout();
	

	private void login() 
		System.out.println("登录Throwable游戏角色");
	

	private void logout() 
		System.out.println("退出Throwable游戏角色");
	


代理模式有几个比较大的优点:

  • 职责清晰:也就是真实主题角色只需要实现具体的逻辑,不需关注代理类的职责,而代理类也只需要处理预处理和后置的逻辑,类的职责分明。

  • 高扩展性:由于职责分明,也就是真实主题角色可以随时修改实现,这样就能通过更新或者替换真实主题的实现并且不改变代理主题角色的情况下改变具体功能。

  • 高灵活性:主要体现在后面提到的动态代理。

4.JDK动态代理的核心API

JDK动态代理提供外部使用的主要依赖两个类:

java.lang.reflect.Proxy:可以理解为代理类的工厂类(其实也是父类,见下文)java.lang.reflect.InvocationHandler:代理实例需要实现的调用处理器接口。

4.1 Proxy

java.lang.reflect.Proxy是JDK动态代理的核心类,它的核心功能是提供静态方法来为一组接口动态地生成代理类并且返回代理实例对象,类似于代理类实例的工厂类。java.lang.reflect.Proxy主要提供四个public静态方法:

// 方法 1: 该方法用于获取指定代理对象所关联的调用处理器
public static InvocationHandler getInvocationHandler(Object proxy) 
 
// 方法 2:该方法用于获取关联于指定类装载器和一组接口的动态代理类的类对象
public static Class<?> getProxyClass(ClassLoader loader, Class<?>[] interfaces) 
 
// 方法 3:该方法用于判断指定类对象是否是一个动态代理类
public static boolean isProxyClass(Class<?> cl) 
 
// 方法 4:该方法用于为指定类装载器、一组接口及调用处理器生成动态代理类实例
public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler h)

  • InvocationHandler getInvocationHandler(Object proxy):通过制定的代理类实例查找它关联的调用处理器实例。

  • Class<?> getProxyClass(ClassLoader loader, Class<?>[] interfaces):用于获取关联于指定类装载器和一组接口的动态代理类的类对象,也就是获取$ProxyXXX的类型,此方法在JDK9以后标记为过期,原因是:在命名模块中生成的代理类是封闭的,模块外的代码无法访问这些类(违反模块规则调用了会抛异常)。

  • boolean isProxyClass(Class<?> cl):用于判断指定类是否是一个动态代理类。

  • Object newProxyInstance(ClassLoader loader, Class[] interfaces, InvocationHandler h):这个是JDK动态代理最核心的方法,用于为指定类装载器、一组接口及调用处理器生成动态代理类实例,也就是生成$ProxyXXX的实例。此方法需要指定类加载器 java.lang.ClassLoader,Proxy静态方法生成动态代理类同样需要通过类装载器来进行装载才能使用,它与普通类的唯一区别就是其字节码是在运行时动态生成的而非预存在于任何一个.class文件中。interfaces是Class数组,也就是需要使用InvocationHandler进行代理访问的接口类型数组,这里的h参数就是调用处理器的实例。

4.2 InvocationHandler

java.lang.reflect.InvocationHandler是调用处理器接口,它自定义了一个invoke方法,用于集中处理在动态代理类对象上的方法调用,通常在该方法中实现对委托类的代理访问。

public interface InvocationHandler 
    Object invoke(Object proxy, Method method, Object[] args) throws Throwable;


参数说明:

  • proxy:Object类型,此参数即是代理类实例,也就是$ProxyXXX的实例。

  • method:java.lang.reflect.Method类型,被调用的方法的实例。

  • args:Object[]类型,被调用方法的参数数组。

实现java.lang.reflect.InvocationHandler接口,通过实现invoke方法即可添加代理访问的逻辑,在这个逻辑代码块中除了可以调用委托类的方法,还可以织入额外的自定义逻辑,AOP就是这样实现的。

4.3 JDK动态代理的流程

JDK动态代理的使用流程如下:

1、通过实现java.lang.reflect.InvocationHandler接口创建自定义的调用处理器。

2、通过为java.lang.reflect.Proxy类指定ClassLoader对象和一组interface来创建动态代理类。

3、通过反射机制获得动态代理类的构造函数,其唯一参数类型是调用处理器接口类型。

4、通过构造函数创建动态代理类实例,构造时调用处理器对象作为参数被传入。

伪代码如下:

// InvocationHandlerImpl 实现了 InvocationHandler 接口,并能实现方法调用从代理类到委托类的分派转发
// 其内部通常包含指向委托类实例的引用,用于真正执行分派转发过来的方法调用
InvocationHandler handler = new InvocationHandlerImpl(..); 
 
// 通过Proxy为包括Interface接口在内的一组接口动态创建代理类的类对象
Class clazz = Proxy.getProxyClass(classLoader, new Class[]  Interface.class, ... ); 
 
// 通过反射从生成的类对象获得构造函数对象
Constructor constructor = clazz.getConstructor(new Class[]  InvocationHandler.class ); 
 
// 通过构造函数对象创建动态代理类实例
Interface Proxy = (Interface)constructor.newInstance(new Object[]  handler );

上面的过程比较复杂,可以进行精简。简化后的伪代码如下:

JAVA

// InvocationHandlerImpl实现了InvocationHandler 接口,并能实现方法调用从代理类到委托类的分派转发
InvocationHandler handler = new InvocationHandlerImpl(..); 
 
// 通过Proxy直接创建动态代理类实例
Interface proxy = (Interface) Proxy.newProxyInstance(classLoader, new Class[]  Interface.class , handler);

4.4 JDK动态代理的机制

首先是JDK动态代理生成的代理类本身的特点:

1、包(或者JDK9引入的模块):如果所代理的接口都是public的,那么它将被定义在包com.sun.proxy;如果所代理的接口中有非public的接口(因为接口不能被定义为protect或private,所以除public之外就是默认的package访问级别,修饰符为default),那么它将被定义在该接口所在包(假设代理了throwable.club包中的某非public接口A,那么新生成的代理类所在的包就是throwable.club),值得注意的是,如果接口数组中存在非public的接口,那么它们必须在同一个包路径下,否则会抛异常。这样设计的目的是为了最大程度的保证动态代理类不会因为包管理的问题而无法被成功定义并访问。

2、类修饰符:该代理类具有final和public修饰符,意味着它可以被所有的类访问,但是不能被再度继承。

3、类:代理类名称格式是$ProxyN,其中N是一个逐一递增的阿拉伯数字,代表java.lang.reflect.Proxy类第N次生成的动态代理类,值得注意的一点是,并不是每次调用Proxy的静态方法创建动态代理类都会使得N值增加,原因是如果对同一组接口(包括接口排列的顺序相同)试图重复创建动态代理类,它会从缓存中获取先前已经创建好的代理类的类对象,而不会再尝试去创建一个全新的代理类,这样可以节省不必要的代码重复生成,提高了代理类的创建效率。

4、类继承关系:代理类的继承关系图如下:


由图可知,java.lang.reflect.Proxy类是代理类的父类,这个规则适用于所有由java.lang.reflect.Proxy创建的动态代理类。而且该类还实现了其所代理的一组接口,这就是为什么它能够被安全地类型转换到其所代理的某接口的根本原因。

4.5 代理类实例的特点

每个代理类实例都会关联一个调用处理器对象,可以通过java.lang.reflect.Proxy提供的静态方法getInvocationHandler()去获得代理类实例的调用处理器对象。在代理类实例上调用其代理的接口中所声明的方法时,这些方法最终都会由调用处理器的 invoke 方法执行,此外,值得注意的是,代理类的根类java.lang.Object中有三个方法也同样会被分派到调用处理器的invoke方法执行,它们是hashCode、equals和toString,可能的原因有:

一、因为这些方法为public且非final类型,能够被代理类覆盖。

二、因为这些方法往往呈现出一个类的某种特征属性,具有一定的区分度,所以为了保证代理类与委托类对外的一致性,这三个方法也应该被分派到委托类执行。当代理的一组接口有重复声明的方法且该方法被调用时,代理类总是从排在最前面的接口中获取方法对象并分派给调用处理器,而无论代理类实例是否正在以该接口(或继承于该接口的某子接口)的形式被外部引用,因为在代理类内部无法区分其当前的被引用类型。

4.6 被代理的一组接口的特点

首先,要注意不能有重复的接口,以避免动态代理类代码生成时的编译错误。其次,这些接口对于类装载器必须可见否则类装载器将无法链接它们,将会导致类定义失败。再次,需被代理的所有非public的接口必须在同一个包中,否则代理类生成也会失败。最后,接口的数目不能超过65535,这是JVM设定的限制,这一点在代理类生成的时候也做了判断。

4.7 异常处理

从调用处理器接口声明的方法中可以看到理论上它能够抛出任何类型的异常,因为所有的异常都继承于Throwable接口,但事实是否如此呢?答案是否定的,原因是我们必须遵守一个继承原则:即子类覆盖父类或实现父接口的方法时,抛出的异常必须在原方法支持的异常列表之内。所以虽然调用处理器理论上讲能够,但实际上往往受限制,除非父接口中的方法支持抛Throwable异常。那么如果在invoke方法中的确产生了接口方法声明中不支持的异常,那将如何呢?放心,Jdk动态代理类已经为我们设计好了解决方法:它将会抛出UndeclaredThrowableException 异常。这个异常是一个RuntimeException类型,所以不会引起编译错误。通过该异常的getCause方法,还可以获得原来那个不受支持的异常对象,以便于错误诊断。

5. JDK动态代理源码分析

因为JDK动态代理核心逻辑都在java.lang.reflect.Proxy类中,下面简单分析一下这个类的源码。先看Proxy类中的几个重要的静态变量:

// 接口组中接口都为为public时候代理类创建的包路径:com.sun.proxy
private static final String PROXY_PACKAGE_PREFIX = ReflectUtil.PROXY_PACKAGE;

// 代理类的构造方法参数类型数组,可见代理类的构造参数只有InvocationHandler类型
private static final Class<?>[] constructorParams =  InvocationHandler.class ;

// 缓存了所有已经调用过setAccessible(true)的代理类的构造(Constructor)实例
private static final ClassLoaderValue<Constructor<?>> proxyCache = new ClassLoaderValue<>();

这里注意到ClassLoaderValue,下文会调用到它的一个很复杂的调用链:

//intf是Class<?>类型
//loader是类加载器实例
return proxyCache.sub(intf).computeIfAbsent(
    loader,
    (ld, clv) -> new ProxyBuilder(ld, clv.key()).build()
);

public V computeIfAbsent(ClassLoader cl,
                         BiFunction<? super ClassLoader,? super CLV,? extends V> mappingFunction) 
						throws IllegalStateException 

上面的computeIfAbsent中使用了函数式接口和Lambda表达式,如果Lambda表达式玩的比较熟练看起来应该没问题,它的功能可以解读为:通过接口类型和类加载器实例计算通过接口类型和类加载器实例构建ProxyBuilder实例并且调用ProxyBuilder#build()得到的结果,如果结果已经存在则直接返回缓存。其实computeIfAbsent在Map接口中也定义了同样的方法,功能是相似的。

接着看Proxy的构造函数:

protected InvocationHandler h;

private Proxy() 


protected Proxy(InvocationHandler h) 
    Objects.requireNonNull(h);
    this.h = h;

到此可以明确一点,既然所有动态代理类都是java.lang.reflect.Proxy的子类,那么它们一定具备一个包含InvocationHandler参数的构造器。接着查看``方法的源码:

public static Object newProxyInstance(ClassLoader loader,
                                      Class<?>[] interfaces,
                                      InvocationHandler h) 
    // 空判断									  
    Objects.requireNonNull(h);
    // 当前调用类获取
    final Class<?> caller = System.getSecurityManager() == null
                                    ? null
                                    : Reflection.getCallerClass();
    // 获取代理类的构造器实例								
    Constructor<?> cons = getProxyConstructor(caller, loader, interfaces);
    // 生成代理实例
    return newProxyInstance(caller, cons, h);

先看getProxyConstructor方法:

private static Constructor<?> getProxyConstructor(Class<?> caller,
                                                  ClassLoader loader,
                                                  Class<?>... interfaces)
    // 这里需要区分代理接口数组中只有单个接口和多个接口的逻辑				  
    // 而基本的逻辑都是先校验当前调用类的权限,后续获取Constructor实例委托到ProxyBuilder
    if (interfaces.length == 1) 
        Class<?> intf = interfaces[0];
        if (caller != null) 
            checkProxyAccess(caller, loader, intf);
        
        return proxyCache.sub(intf).computeIfAbsent(
            loader,
            (ld, clv) -> new ProxyBuilder(ld, clv.key()).build()
        );
     else 
        // 接口克隆
        final Class<?>[] intfsArray = interfaces.clone();
        if (caller != null) 
            checkProxyAccess(caller, loader, intfsArray);
        
        final List<Class<?>> intfs = Arrays.asList(intfsArray);
        return proxyCache.sub(intfs).computeIfAbsent(
            loader,
            (ld, clv) -> new ProxyBuilder(ld, clv.key()).build()
        );
    

可以明确,核心的逻辑都交给了Proxy的内部类ProxyBuilder完成,先看ProxyBuilder的静态成员变量:

// Unsafe实例
private static final Unsafe UNSAFE = Unsafe.getUnsafe();

// 代理类的简单类名的前置字符串
private static final String proxyClassNamePrefix = "$Proxy";

// 用于生成下一个代理类的数字计数器,记住它是静态的
private static final AtomicLong nextUniqueNumber = new AtomicLong();

// 记录了已经生成的代理类-Boolean的映射,已经生成过对应代理类则记录为true
private static final ClassLoaderValue<Boolean> reverseProxyCache = new ClassLoaderValue<>();
JAVA
// 单个代理接口的情况,其实也是把接口转换为List
ProxyBuilder(ClassLoader loader, Class<?> intf) 
    this(loader, Collections.singletonList(intf));

// 多个代理接口的情况
ProxyBuilder(ClassLoader loader, List<Class<?>> interfaces) 
    // 通过JVM参数强制关闭动态代理功能则抛出异常
    if (!VM.isModuleSystemInited()) 
        throw new InternalError("Proxy is not supported until "
                + "module system is fully initialized");
    
    // 代理接口数量不能超过65535,也就是最多代理65535个接口
    if (interfaces.size() > 65535) 
        throw new IllegalArgumentException("interface limit exceeded: "
                + interfaces.size());
    
    // 收集接口数组中所有接口的非静态方法的返回值类型、共享(shared)参数类型和共享(shared)异常类型,注释说是收集代理接口的方法签名
    Set<Class<?>> refTypes = referencedTypes(loader, interfaces);

    // 确保上一步得到的代理接口方法签名的类型都是"可见(其实就是类型都存在)"的,通过遍历调用Class.forName(type.getName(), false, ld)去判断
    validateProxyInterfaces(loader, interfaces, refTypes);

    this.interfaces = interfaces;
    // 获取代理类最终生成的模块,规则如下:
    // 1、所有代理接口的修饰符都为public,接口所在模块都能公开访问,则返回unnamed模块
    // 2、如果有任意的代理接口是包私有,则返回该包所在的模块		、
    // 3、所有代理接口的修饰符都为public,有任意至少一个接口所在模块不能公开访问,则返回该不能公开访问的模块,
    this.module = mapToModule(loader, interfaces, refTypes);
    assert getLoader(module) == loader;

一个构造器处理的逻辑也是相对复杂,主要是因为引入模块管理的概念,接着看ProxyBuilder#build()的源码:

Constructor<?> build() 
    // 定义代理类,实际上是动态生成代理类字节码和缓存它的类型的过程
    Class<?> proxyClass = defineProxyClass(module, interfaces);
    final Constructor<?> cons;
    try 
    // 返回代理类的构造
        cons = proxyClass.getConstructor(constructorParams);
     catch (NoSuchMethodException e) 
        throw new InternalError(e.toString(), e);
    
    AccessController.doPrivileged(new PrivilegedAction<Void>() 
        public Void run() 
            cons.setAccessible(true);
            return null;
        
    );
    return cons;

最后到逻辑最复杂的代理类的生成过程ProxyBuilder#defineProxyClass():

JAVA
private static Class<?> defineProxyClass(Module m, List<Class<?>> interfaces) 
    String proxyPkg = null;     // package to define proxy class in
    int accessFlags = Modifier.PUBLIC | Modifier.FINAL;
    // 这里就是定义代理类包路径的逻辑,规则如下:
    // 1、代理接口数组所有接口都是public修饰,则代理类包路径为com.sun.proxy
    // 2、代理接口数组有任意接口是包私有的,则代理类包路径为该私有包的路径			
    for (Class<?> intf : interfaces) 
        int flags = intf.getModifiers();
        if (!Modifier.isPublic(flags)) 
            accessFlags = Modifier.FINAL;  // non-public, final
            String pkg = intf.getPackageName();
            if (proxyPkg == null) 
                proxyPkg = pkg;
             else if (!pkg.equals(proxyPkg)) 
                throw new IllegalArgumentException(
                        "non-public interfaces from different packages");
            
        
    
    // 下面几个if都是包路径的合法性判断
    if (proxyPkg == null) 
        // all proxy interfaces are public
        proxyPkg = m.isNamed() ? PROXY_PACKAGE_PREFIX + "." + m.getName()
                               : PROXY_PACKAGE_PREFIX;
     else if (proxyPkg.isEmpty() && m.isNamed()) 以上是关于java深入分析Java反射-动态代理 proxy的主要内容,如果未能解决你的问题,请参考以下文章

Java程序语言的后门-反射机制

java动态代理源码解析

java核心学习(四十) 使用反射生成JDK动态代理

Java提高班反射和动态代理(JDK Proxy和Cglib)

java反射和动态代理有啥关系

Java技术专题「源码分析系列」深入分析JDK动态代理的分析原理机制