动态代理学习(二)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

智能推荐

class和struct的区别-程序员宅基地

文章浏览阅读101次。4.class可以有⽆参的构造函数,struct不可以,必须是有参的构造函数,⽽且在有参的构造函数必须初始。2.Struct适⽤于作为经常使⽤的⼀些数据组合成的新类型,表示诸如点、矩形等主要⽤来存储数据的轻量。1.Class⽐较适合⼤的和复杂的数据,表现抽象和多级别的对象层次时。2.class允许继承、被继承,struct不允许,只能继承接⼝。3.Struct有性能优势,Class有⾯向对象的扩展优势。3.class可以初始化变量,struct不可以。1.class是引⽤类型,struct是值类型。

android使用json后闪退,应用闪退问题:从json信息的解析开始就会闪退-程序员宅基地

文章浏览阅读586次。想实现的功能是点击顶部按钮之后按关键字进行搜索,已经可以从服务器收到反馈的json信息,但从json信息的解析开始就会闪退,加载listview也不知道行不行public abstract class loadlistview{public ListView plv;public String js;public int listlength;public int listvisit;public..._rton转json为什么会闪退

如何使用wordnet词典,得到英文句子的同义句_get_synonyms wordnet-程序员宅基地

文章浏览阅读219次。如何使用wordnet词典,得到英文句子的同义句_get_synonyms wordnet

系统项目报表导出功能开发_积木报表 多线程-程序员宅基地

文章浏览阅读521次。系统项目报表导出 导出任务队列表 + 定时扫描 + 多线程_积木报表 多线程

ajax 如何从服务器上获取数据?_ajax 获取http数据-程序员宅基地

文章浏览阅读1.1k次,点赞9次,收藏9次。使用AJAX技术的好处之一是它能够提供更好的用户体验,因为它允许在不重新加载整个页面的情况下更新网页的某一部分。另外,AJAX还使得开发人员能够创建更复杂、更动态的Web应用程序,因为它们可以在后台与服务器进行通信,而不需要打断用户的浏览体验。在Web开发中,AJAX(Asynchronous JavaScript and XML)是一种常用的技术,用于在不重新加载整个页面的情况下,从服务器获取数据并更新网页的某一部分。使用AJAX,你可以创建异步请求,从而提供更快的响应和更好的用户体验。_ajax 获取http数据

Linux图形终端与字符终端-程序员宅基地

文章浏览阅读2.8k次。登录退出、修改密码、关机重启_字符终端

随便推点

Python与Arduino绘制超声波雷达扫描_超声波扫描建模 python库-程序员宅基地

文章浏览阅读3.8k次,点赞3次,收藏51次。前段时间看到一位发烧友制作的超声波雷达扫描神器,用到了Arduino和Processing,可惜啊,我不会Processing更看不懂人家的程序,咋办呢?嘿嘿,所以我就换了个思路解决,因为我会一点Python啊,那就动手吧!在做这个案例之前先要搞明白一个问题:怎么将Arduino通过超声波检测到的距离反馈到Python端?这个嘛,我首先想到了串行通信接口。没错!就是串口。只要Arduino将数据发送给COM口,然后Python能从COM口读取到这个数据就可以啦!我先写了一个测试程序试了一下,OK!搞定_超声波扫描建模 python库

凯撒加密方法介绍及实例说明-程序员宅基地

文章浏览阅读4.2k次。端—端加密指信息由发送端自动加密,并且由TCP/IP进行数据包封装,然后作为不可阅读和不可识别的数据穿过互联网,当这些信息到达目的地,将被自动重组、解密,而成为可读的数据。不可逆加密算法的特征是加密过程中不需要使用密钥,输入明文后由系统直接经过加密算法处理成密文,这种加密后的数据是无法被解密的,只有重新输入明文,并再次经过同样不可逆的加密算法处理,得到相同的加密密文并被系统重新识别后,才能真正解密。2.使用时,加密者查找明文字母表中需要加密的消息中的每一个字母所在位置,并且写下密文字母表中对应的字母。_凯撒加密

工控协议--cip--协议解析基本记录_cip协议embedded_service_error-程序员宅基地

文章浏览阅读5.7k次。CIP报文解析常用到的几个字段:普通类型服务类型:[0x00], CIP对象:[0x02 Message Router], ioi segments:[XX]PCCC(带cmd和func)服务类型:[0x00], CIP对象:[0x02 Message Router], cmd:[0x101], fnc:[0x101]..._cip协议embedded_service_error

如何在vs2019及以后版本(如vs2022)上添加 添加ActiveX控件中的MFC类_vs添加mfc库-程序员宅基地

文章浏览阅读2.4k次,点赞9次,收藏13次。有时候我们在MFC项目开发过程中,需要用到一些微软已经提供的功能,如VC++使用EXCEL功能,这时候我们就能直接通过VS2019到如EXCEL.EXE方式,生成对应的OLE头文件,然后直接使用功能,那么,我们上篇文章中介绍了vs2017及以前的版本如何来添加。但由于微软某些方面考虑,这种方式已被放弃。从上图中可以看出,这一功能,在从vs2017版本15.9开始,后续版本已经删除了此功能。那么我们如果仍需要此功能,我们如何在新版本中添加呢。_vs添加mfc库

frame_size (1536) was not respected for a non-last frame_frame_size (1024) was not respected for a non-last-程序员宅基地

文章浏览阅读785次。用ac3编码,执行编码函数时报错入如下:[ac3 @ 0x7fed7800f200] frame_size (1536) was not respected for anon-last frame (avcodec_encode_audio2)用ac3编码时每次送入编码器的音频采样数应该是1536个采样,不然就会报上述错误。这个数字并非刻意固定,而是跟ac3内部的编码算法原理相关。全网找不到,国内音视频之路还有很长的路,音视频人一起加油吧~......_frame_size (1024) was not respected for a non-last frame

Android移动应用开发入门_在安卓移动应用开发中要在活动类文件中声迷你一个复选框变量-程序员宅基地

文章浏览阅读230次,点赞2次,收藏2次。创建Android应用程序一个项目里面可以有很多模块,而每一个模块就对应了一个应用程序。项目结构介绍_在安卓移动应用开发中要在活动类文件中声迷你一个复选框变量

推荐文章

热门文章

相关标签