中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

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

發布時間:2021-06-26 14:33:51 來源:億速云 閱讀:199 作者:chen 欄目:大數據

這篇文章主要講解了“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 <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) {
    final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);
            
    return new AbstractProxyInvoker<T>(proxy, type, url) {
        @Override
        protected Object doInvoke(T proxy, String methodName,Class<?>[] parameterTypes,Object[] arguments) 
		                                                                                    throws Throwable {
            return wrapper.invokeMethod(proxy, methodName, parameterTypes, arguments);
        }
    };
}

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

從圖中可以看出,傳進來的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的名字。如下圖 Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法

可以發現生成的Wrapper類是叫Wrapper1,然后放開斷點,讓程序走完,服務提供者處于運行狀態。下圖通過Arthas查看生成的Wrapper1到底是什么? 首先下載它的jar包,下載地址。然后打開cmd,執行以下命令。注意2是對應Provider程序的序號,需要和你自己程序對應。輸入2后可以發現連上了Arthas。然后使用sc命令查找Wrapper1具體對應的是哪個class文件,最后使用jad命令反編譯,查看Wrapper1類對應的Java文件具體是什么? Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法

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

最后,我們可以得到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 <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) {
    final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);
            
    return new AbstractProxyInvoker<T>(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生成代理的方法這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關知識點的文章,歡迎關注!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

贡嘎县| 夏邑县| 太仓市| 渝中区| 寻乌县| 明水县| 台山市| 苍南县| 恭城| 板桥市| 女性| 昆明市| 资溪县| 陈巴尔虎旗| 肇州县| 大足县| 安新县| 资兴市| 渭源县| 海安县| 蓬溪县| 芮城县| 祁门县| 华蓥市| 云南省| 延庆县| 怀柔区| 黄浦区| 德安县| 建瓯市| 万安县| 丹东市| 平顺县| 佛学| 雅安市| 双峰县| 瑞安市| 河东区| 恩施市| 孝义市| 千阳县|