千家信息网

Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法

发表于:2025-02-02 作者:千家信息网编辑
千家信息网最后更新 2025年02月02日,这篇文章主要讲解了"Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法",文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习"
千家信息网最后更新 2025年02月02日Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法

这篇文章主要讲解了"Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法",文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习"Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法"吧!

1、getWrapper方法入口

private void exportLocal(URL url) {    if (!Constants.LOCAL_PROTOCOL.equalsIgnoreCase(url.getProtocol())) {        URL local = URL.valueOf(url.toFullString()).setProtocol(Constants.LOCAL_PROTOCOL).setHost(LOCALHOST).setPort(0);        ServiceClassHolder.getInstance().pushServiceClass(getServiceClass(ref));        // 这里会调用proxyFactory的getInvoker方法,proxyFactory是自适应拓展对象,默认是JavassistProxyFactory        // 所以这里会走到它的getInvoker方法里面        Exporter exporter = protocol.export(proxyFactory.getInvoker(ref, (Class) interfaceClass, local));        exporters.add(exporter);    }}
// 我们先来看一下调用getInvoker时传递进来的几个参数具体是什么,见下图public  Invoker getInvoker(T proxy, Class type, URL url) {    final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);                return new AbstractProxyInvoker(proxy, type, url) {        @Override        protected Object doInvoke(T proxy, String methodName,Class[] parameterTypes,Object[] arguments)                                                                                                     throws Throwable {            return wrapper.invokeMethod(proxy, methodName, parameterTypes, arguments);        }    };}

从图中可以看出,传进来的proxy是DemoServiceImpl的一个实例对象,而type是DemoService接口的class对象,可以猜测下面的Wrapper.getWrapper方法就是为该实例对象生成代理对象。下面具体分析。

2、生成Wrapper类

public static Wrapper getWrapper(Class c) {    while (ClassGenerator.isDynamicClass(c))        c = c.getSuperclass();    if (c == Object.class)        return OBJECT_WRAPPER;    // 缓存作用    Wrapper ret = WRAPPER_MAP.get(c);    if (ret == null) {        // 生成Wrapper类,这边逻辑比较难懂,下面先通过arthas生成具体的Wrapper类观察一下        ret = makeWrapper(c);        WRAPPER_MAP.put(c, ret);    }    return ret;}

上述通过makeWrapper(c)方法会生成具体的Wrapper类,这里面代码比较长,它是通过javassist构建 Class。下面先通过阿里开源的arthas工具查看它生成的Wrapper类到底是什么? Arthas 用户文档。首先启动Provider服务提供者程序,将断点放置到ret = makerWrapper(c)这里,确定这里的c是DemoServiceImpl,然后运行程序至下一步,观察ret的名字。如下图

可以发现生成的Wrapper类是叫Wrapper1,然后放开断点,让程序走完,服务提供者处于运行状态。下图通过Arthas查看生成的Wrapper1到底是什么? 首先下载它的jar包,下载地址。然后打开cmd,执行以下命令。注意2是对应Provider程序的序号,需要和你自己程序对应。输入2后可以发现连上了Arthas。然后使用sc命令查找Wrapper1具体对应的是哪个class文件,最后使用jad命令反编译,查看Wrapper1类对应的Java文件具体是什么?

最后,我们可以得到Wrapper1的Java文件,如下

package com.alibaba.dubbo.common.bytecode;import com.alibaba.dubbo.common.bytecode.ClassGenerator;import com.alibaba.dubbo.common.bytecode.NoSuchMethodException;import com.alibaba.dubbo.common.bytecode.NoSuchPropertyException;import com.alibaba.dubbo.common.bytecode.Wrapper;import com.alibaba.dubbo.demo.provider.DemoServiceImpl;import java.lang.reflect.InvocationTargetException;import java.util.Map;public class Wrapper1 extends Wrapper implements ClassGenerator.DC {    public static String[] pns;    public static Map pts;    public static String[] mns;    public static String[] dmns;    public static Class[] mts0;    public String[] getPropertyNames() {        return pns;    }    public boolean hasProperty(String string) {        return pts.containsKey(string);    }    public Class getPropertyType(String string) {        return (Class)pts.get(string);    }    public String[] getMethodNames() {        return mns;    }    public String[] getDeclaredMethodNames() {        return dmns;    }    public void setPropertyValue(Object object, String string, Object object2) {        try {            DemoServiceImpl demoServiceImpl = (DemoServiceImpl)object;        }        catch (Throwable throwable) {            throw new IllegalArgumentException(throwable);        }        throw new NoSuchPropertyException(new StringBuffer().append("Not found property               \"").append(string).append("\" filed or setter method in class               com.alibaba.dubbo.demo.provider.DemoServiceImpl.").toString());    }    public Object getPropertyValue(Object object, String string) {        try {            DemoServiceImpl demoServiceImpl = (DemoServiceImpl)object;        }        catch (Throwable throwable) {            throw new IllegalArgumentException(throwable);        }        throw new NoSuchPropertyException(new StringBuffer().append("Not found property             \"").append(string).append("\" filed or setter method in class             com.alibaba.dubbo.demo.provider.DemoServiceImpl.").toString());    }    // 这个就是Wrapper对象的invokerMethod方法    public Object invokeMethod(Object object, String string, Class[] arrclass,                                              Object[] arrobject) throws InvocationTargetException {        DemoServiceImpl demoServiceImpl;        try {            demoServiceImpl = (DemoServiceImpl)object;        }        catch (Throwable throwable) {            throw new IllegalArgumentException(throwable);        }        try {            if ("sayHello".equals(string) && arrclass.length == 1) {                // 调用DemoServiceImpl实例对象的sayHello方法,并将结果返回                return demoServiceImpl.sayHello((String)arrobject[0]);            }        }        catch (Throwable throwable) {            throw new InvocationTargetException(throwable);        }        throw new NoSuchMethodException(new StringBuffer().append("Not found method \"")              .append(string)              .append("\" in class com.alibaba.dubbo.demo.provider.DemoServiceImpl.").toString());    }}

现在我们可以再来回顾一下JavassistProxyFactory中的getInvoker方法,它首先生成一个Wrapper实例对象,经过分析得知,它其实就是DemoServiceImpl的一个代理对象,内部还有一个invokeMethod方法。getInvoker方法中生成了一个匿名Invoker实例,当外部调用该Invoker的doInvoke方法时,最终会调用wrapper.invokeMethod方法,而wrapper.invokerMethod里面就是调用的目标对象,即DemoServiceImpl的sayHello方法

public  Invoker getInvoker(T proxy, Class type, URL url) {    final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);                return new AbstractProxyInvoker(proxy, type, url) {        @Override        protected Object doInvoke(T proxy, String methodName,Class[] parameterTypes,Object[] arguments)                                                                                                    throws Throwable {            return wrapper.invokeMethod(proxy, methodName, parameterTypes, arguments);        }    };}

3、makeWrapper方法分析

makeWrapper方法就是创建上述的Wrapper的class文件,阅读代码时可以对照着看,更容易理解,具体就不分析,可以参考 服务导出。

感谢各位的阅读,以上就是"Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法"的内容了,经过本文的学习后,相信大家对Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是,小编将为大家推送更多相关知识点的文章,欢迎关注!

0