动态代理学习(二)JDK动态代理源码分析_jdk17 proxygenerator-程序员宅基地

技术标签: jdk  proxy  动态代理  源码  

上篇文章我们学习了如何自己实现一个动态代理,这篇文章我们从源码角度来分析下JDK的动态代理

先看一个Demo:

public class MyInvocationHandler implements InvocationHandler {
    

	private MyService target;

	public MyInvocationHandler(MyService target) {
    
		this.target = target;
	}

	@Override
	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    
		Object invoke = method.invoke(target, args);
		System.out.println("proxy invoke");
		if (method.getReturnType().equals(Void.TYPE)) {
    
			return null;
		} else {
    
			System.out.println(invoke);
			return invoke+"proxy";
		}
	}
}

public interface MyService {
    
	void test01();
	void test02(String s);
}

public class MyServiceImpl implements MyService {
    

	@Override
	public void test01() {
    
		System.out.println("test01");
	}

	@Override
	public void test02(String s) {
    
		System.out.println(s);
	}
}

main方法:

public class Main {
    
	public static void main(String[] args) {
    
		MyServiceImpl target = new MyServiceImpl();
		Class<? extends MyServiceImpl> clazz = target.getClass();
		MyService proxyInstance = (MyService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces()
				, new MyInvocationHandler(target));
		proxyInstance.test01();
		proxyInstance.test02("test02");
	}
}

我们运行Debug观察下生成的proxyInstance对象:

在这里插入图片描述

可以得出以下几个结论:

  1. 生成的代理类的类名是$Proxy0
  2. 代理类持有我们的MyInvocationHandler对象

这里我们越过不重要的代码,直接端点到java.lang.reflect.Proxy.ProxyClassFactory#apply这个方法,

我们分段分析这个方法的代码(简单的代码我们就直接跳过了):

 Class<?> interfaceClass = null;
                try {
    
                    interfaceClass = Class.forName(intf.getName(), false, loader);
                } catch (ClassNotFoundException e) {
    
                }
                if (interfaceClass != intf) {
    
                    throw new IllegalArgumentException(
                        intf + " is not visible from class loader");
                }

这段代码主要是为了确保类加载器对这个class文件解析后得到的是同一个对象。如果我们要确保两个对象相等的话,那么它们的类加载器必定是一样的。

for (Class<?> intf : interfaces) {
    
    int flags = intf.getModifiers();
    if (!Modifier.isPublic(flags)) {
    
        accessFlags = Modifier.FINAL;
        String name = intf.getName();
        int n = name.lastIndexOf('.');
        String pkg = ((n == -1) ? "" : name.substring(0, n + 1));
        if (proxyPkg == null) {
    
            proxyPkg = pkg;
        } else if (!pkg.equals(proxyPkg)) {
    
            throw new IllegalArgumentException(
                "non-public interfaces from different packages");
        }
    }
}

 if (proxyPkg == null) {
    
                // if no non-public proxy interfaces, use com.sun.proxy package
                proxyPkg = ReflectUtil.PROXY_PACKAGE + ".";
            }

这段代码主要是在判断接口是否是public的,如果不是public的那么需要将代理类生成在接口同名的包下。否则生成的代理类在com.sun.proxy包下。

这里我们可以做一个验证:

  1. 我们测试接口如果不是public的,代理类会生成在接口的同一个包下,在这种情况下,我们可以在接口的同名包下新建一个类,类名为$Proxy0,如下:
// 接口换为包访问权限
interface MyService {
    
	void test01();
	void test02(String s);
}

新建一个类,类名为$Proxy0

在这里插入图片描述

  1. main函数进行测试
	public static void main(String[] args) {
    
		MyServiceImpl target = new MyServiceImpl();
		Class<? extends MyServiceImpl> clazz = target.getClass();
        // 加载这个类到JVM中
		$Proxy0 proxy0 = new $Proxy0();
		MyService proxyInstance = (MyService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces()
				, new MyInvocationHandler(target));
		proxyInstance.test01();
		proxyInstance.test02("test02");
		}

运行后发现报错:显示有重复的类定义

Exception in thread "main" java.lang.LinkageError: loader (instance of  sun/misc/Launcher$AppClassLoader): attempted  duplicate class definition for name: "com/dmz/proxy/target/$Proxy0"
	at java.lang.reflect.Proxy.defineClass0(Native Method)
	at java.lang.reflect.Proxy.access$300(Proxy.java:228)
	at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:642)
	at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:557)
	at java.lang.reflect.WeakCache$Factory.get(WeakCache.java:230)
	at java.lang.reflect.WeakCache.get(WeakCache.java:127)
	at java.lang.reflect.Proxy.getProxyClass0(Proxy.java:419)
	at java.lang.reflect.Proxy.newProxyInstance(Proxy.java:719)
	at com.dmz.proxy.target.Main.main(Main.java:14)

从上面我们就验证了,如果不是public的那么需要将代理类生成在接口同名的包下

接下来我们验证,正常情况下,代理类会被生成在com.sun.proxy包下

  1. 同理,我们可以创建一个类,全类名为com.sun.proxy.$Proxy0

在这里插入图片描述

  1. 同时我们将接口改为public的,同样的我们会发现会报同一个错。

至此,证明完毕。我们继续看代码

            byte[] proxyClassFile = ProxyGenerator.generateProxyClass(
                proxyName, interfaces, accessFlags);
            try {
    
                return defineClass0(loader, proxyName,
                                    proxyClassFile, 0, proxyClassFile.length);
                // 省略部分代码......

我们可以看到,通过ProxyGenerator.generateProxyClass(proxyName, interfaces, accessFlags)生成一个字节流后,直接调用了defineClass0(…)方法,而且我们跟踪这个方法可以发现,这是一个本地方法。并且它直接返回了一个Class对象。

private static native Class<?> defineClass0(ClassLoader loader, String name,
                                            byte[] b, int off, int len);

回顾我们上一篇文章的实现思路:

在这里插入图片描述

对比后我们可以发现,我们自己实现时,是通过生成java文件,然后进行编译生成class文件,再将其加载到JVM中得到class对象。而对于jdk动态代理,直接通过一个字节流调用本地方法后直接生成class对象。

我们再回过头去看下jdk是如何给我们生成这个字节流的,这里我们主要关注sun.misc.ProxyGenerator#generateClassFile这个方法,这里我就不贴代码了。因为也是一些字符串的拼接动作,然后写入到一个字节流中,我们关注下最后生成的这个字节流是什么样子的,我们将其写入到一个文件中:

		MyServiceImpl target = new MyServiceImpl();
		Class<? extends MyServiceImpl> clazz = target.getClass();
		MyService proxyInstance = (MyService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces()
				, new MyInvocationHandler(target));

		byte[] bytes = ProxyGenerator.generateProxyClass("proxy", clazz.getInterfaces());

		File file = new File("G:\\com\\dmz\\proxy\\proxy.class");
		FileOutputStream outputStream = new FileOutputStream(file);
		outputStream.write(bytes);
		proxyInstance.test01();
		proxyInstance.test02("test02");

我们将得到的这个class文件放入idea反编译:

public final class proxy extends Proxy implements MyService {
    
    private static Method m1;
    private static Method m4;
    private static Method m2;
    private static Method m3;
    private static Method m0;

    public proxy(InvocationHandler var1) throws  {
    
        super(var1);
    }

    public final boolean equals(Object var1) throws  {
    
        try {
    
            return (Boolean)super.h.invoke(this, m1, new Object[]{
    var1});
        } catch (RuntimeException | Error var3) {
    
            throw var3;
        } catch (Throwable var4) {
    
            throw new UndeclaredThrowableException(var4);
        }
    }

    public final void test01() throws  {
    
        try {
    
            super.h.invoke(this, m4, (Object[])null);
        } catch (RuntimeException | Error var2) {
    
            throw var2;
        } catch (Throwable var3) {
    
            throw new UndeclaredThrowableException(var3);
        }
    }

    public final String toString() throws  {
    
        try {
    
            return (String)super.h.invoke(this, m2, (Object[])null);
        } catch (RuntimeException | Error var2) {
    
            throw var2;
        } catch (Throwable var3) {
    
            throw new UndeclaredThrowableException(var3);
        }
    }

    public final void test02(String var1) throws  {
    
        try {
    
            super.h.invoke(this, m3, new Object[]{
    var1});
        } catch (RuntimeException | Error var3) {
    
            throw var3;
        } catch (Throwable var4) {
    
            throw new UndeclaredThrowableException(var4);
        }
    }

    public final int hashCode() throws  {
    
        try {
    
            return (Integer)super.h.invoke(this, m0, (Object[])null);
        } catch (RuntimeException | Error var2) {
    
            throw var2;
        } catch (Throwable var3) {
    
            throw new UndeclaredThrowableException(var3);
        }
    }

    static {
    
        try {
    
            m1 = Class.forName("java.lang.Object").getMethod("equals", Class.forName("java.lang.Object"));
            m4 = Class.forName("com.dmz.proxy.target.MyService").getMethod("test01");
            m2 = Class.forName("java.lang.Object").getMethod("toString");
            m3 = Class.forName("com.dmz.proxy.target.MyService").getMethod("test02", Class.forName("java.lang.String"));
            m0 = Class.forName("java.lang.Object").getMethod("hashCode");
        } catch (NoSuchMethodException var2) {
    
            throw new NoSuchMethodError(var2.getMessage());
        } catch (ClassNotFoundException var3) {
    
            throw new NoClassDefFoundError(var3.getMessage());
        }
    }
}

观察上面代码,我们可以发现以下几点:

  1. 代理类继承了Proxy这个类,正因为如此,所以jdk动态代理只能实现基于接口的代理,而不能实现对整个类进行代理,因为java是单继承的。那么为什么代理类一定要继承Proxy这个类呢?我们可以发现代理类并没有使用Proxy中的什么属性或者方法(虽然使用了InvocationHandler对象,但是也可以在生成class之初就将InvocationHandler放入到代理类中)。所以实际上不进行继承也是没有任何关系的。查了很多资料后发现,找到一个比较合理的解释如下:

    JDK的动态代理只允许动态代理接口是设计使然,因为动态代理一个类存在一些问题。在代理模式中代理类只做一些额外的拦截处理,实际处理是转发到原始类做的。这里存在两个对象,代理对象跟原始对象。如果允许动态代理一个类,那么代理对象也会继承类的字段,而这些字段是实际上是没有使用的,对内存空间是一个浪费。因为代理对象只做转发处理,对象的字段存取都是在原始对象上处理。更为致命的是如果代理的类中有final的方法,动态生成的类是没法覆盖这个方法的,没法代理,而且存取的字段是代理对象上的字段,这显然不是我们希望的结果。spring aop框架就是这种模式。

    总结起来主要两点

    • 我们在进行代理时,实际的方法执行逻辑仍然是交给目标类处理,这个时候代理类持有目标类中的字段只不过是对内存空间的一种浪费,其余没有任何作用。

    • 即使我们能接受对内存空间的浪费,然而如果我们在代理对象中操作代理对象中的字段,目标对象的字段不受任何影响,这显然也是不合理的。

    • 如果是基于继承实现代理,那么有final的方法的情况下,无法完成对final方法的代理。

  2. 代理类实现了我们目标对象实现的接口,所以说JDK动态代理是基于接口实现的。

  3. 代理对象不仅仅是对接口中的方法进行了代理,还对hashCode,equals,toString三个方法进行了代理,这也是为了覆盖目标类中的所有方法

至此,我们就完成对JDK动态代理的学习!喜欢的同学点个赞吧~~~~

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_41907991/article/details/103205350

智能推荐

前端开发之vue-grid-layout的使用和实例-程序员宅基地

文章浏览阅读1.1w次,点赞7次,收藏34次。vue-grid-layout的使用、实例、遇到的问题和解决方案_vue-grid-layout

Power Apps-上传附件控件_powerapps点击按钮上传附件-程序员宅基地

文章浏览阅读218次。然后连接一个数据源,就会在下面自动产生一个添加附件的组件。把这个控件复制粘贴到页面里,就可以单独使用来上传了。插入一个“编辑”窗体。_powerapps点击按钮上传附件

C++ 面向对象(Object-Oriented)的特征 & 构造函数& 析构函数_"object(cnofd[\"ofdrender\"])十条"-程序员宅基地

文章浏览阅读264次。(1) Abstraction (抽象)(2) Polymorphism (多态)(3) Inheritance (继承)(4) Encapsulation (封装)_"object(cnofd[\"ofdrender\"])十条"

修改node_modules源码,并保存,使用patch-package打补丁,git提交代码后,所有人可以用到修改后的_修改 node_modules-程序员宅基地

文章浏览阅读133次。删除node_modules,重新npm install看是否成功。在 package.json 文件中的 scripts 中加入。修改你的第三方库的bug等。然后目录会多出一个目录文件。_修改 node_modules

【】kali--password:su的 Authentication failure问题,&sudo passwd root输入密码时Sorry, try again._password: su: authentication failure-程序员宅基地

文章浏览阅读883次。【代码】【】kali--password:su的 Authentication failure问题,&sudo passwd root输入密码时Sorry, try again._password: su: authentication failure

整理5个优秀的微信小程序开源项目_微信小程序开源模板-程序员宅基地

文章浏览阅读1w次,点赞13次,收藏97次。整理5个优秀的微信小程序开源项目。收集了微信小程序开发过程中会使用到的资料、问题以及第三方组件库。_微信小程序开源模板

随便推点

Centos7最简搭建NFS服务器_centos7 搭建nfs server-程序员宅基地

文章浏览阅读128次。Centos7最简搭建NFS服务器_centos7 搭建nfs server

Springboot整合Mybatis-Plus使用总结(mybatis 坑补充)_mybaitis-plus ruledataobjectattributemapper' and '-程序员宅基地

文章浏览阅读1.2k次,点赞2次,收藏3次。前言mybatis在持久层框架中还是比较火的,一般项目都是基于ssm。虽然mybatis可以直接在xml中通过SQL语句操作数据库,很是灵活。但正其操作都要通过SQL语句进行,就必须写大量的xml文件,很是麻烦。mybatis-plus就很好的解决了这个问题。..._mybaitis-plus ruledataobjectattributemapper' and 'com.picc.rule.management.d

EECE 1080C / Programming for ECESummer 2022 Laboratory 4: Global Functions Practice_eece1080c-程序员宅基地

文章浏览阅读325次。EECE 1080C / Programming for ECESummer 2022Laboratory 4: Global Functions PracticePlagiarism will not be tolerated:Topics covered:function creation and call statements (emphasis on global functions)Objective:To practice program development b_eece1080c

洛谷p4777 【模板】扩展中国剩余定理-程序员宅基地

文章浏览阅读53次。被同机房早就1年前就学过的东西我现在才学,wtcl。设要求的数为\(x\)。设当前处理到第\(k\)个同余式,设\(M = LCM ^ {k - 1} _ {i - 1}\) ,前\(k - 1\)个的通解就是\(x + i * M\)。那么其实第\(k\)个来说,其实就是求一个\(y\)使得\(x + y * M ≡ a_k(mod b_k)\)转化一下就是\(y * M ...

android 退出应用没有走ondestory方法,[Android基础论]为何Activity退出之后,系统没有调用onDestroy方法?...-程序员宅基地

文章浏览阅读1.3k次。首先,问题是如何出现的?晚上复查代码,发现一个activity没有调用自己的ondestroy方法我表示非常的费解,于是我检查了下代码。发现再finish代码之后接了如下代码finish();System.exit(0);//这就是罪魁祸首为什么这样写会出现问题System.exit(0);////看一下函数的原型public static void exit (int code)//Added ..._android 手动杀死app,activity不执行ondestroy

SylixOS快问快答_select函数 导致堆栈溢出 sylixos-程序员宅基地

文章浏览阅读894次。Q: SylixOS 版权是什么形式, 是否分为<开发版税>和<运行时版税>.A: SylixOS 是开源并免费的操作系统, 支持 BSD/GPL 协议(GPL 版本暂未确定). 没有任何的运行时版税. 您可以用她来做任何 您喜欢做的项目. 也可以修改 SylixOS 的源代码, 不需要支付任何费用. 当然笔者希望您可以将使用 SylixOS 开发的项目 (不需要开源)或对 SylixOS 源码的修改及时告知笔者.需要指出: SylixOS 本身仅是笔者用来提升自己水平而开发的_select函数 导致堆栈溢出 sylixos

推荐文章

热门文章

相关标签