您好,登錄后才能下訂單哦!
這篇文章主要講解了“Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“Dubbo中JavaAssist的Wrapper.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)); // 這里會(huì)調(diào)用proxyFactory的getInvoker方法,proxyFactory是自適應(yīng)拓展對(duì)象,默認(rèn)是JavassistProxyFactory // 所以這里會(huì)走到它的getInvoker方法里面 Exporter<?> exporter = protocol.export(proxyFactory.getInvoker(ref, (Class) interfaceClass, local)); exporters.add(exporter); } }
// 我們先來看一下調(diào)用getInvoker時(shí)傳遞進(jìn)來的幾個(gè)參數(shù)具體是什么,見下圖 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); } }; }
從圖中可以看出,傳進(jìn)來的proxy是DemoServiceImpl的一個(gè)實(shí)例對(duì)象,而type是DemoService接口的class對(duì)象,可以猜測(cè)下面的Wrapper.getWrapper方法就是為該實(shí)例對(duì)象生成代理對(duì)象
。下面具體分析。
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)方法會(huì)生成具體的Wrapper類,這里面代碼比較長(zhǎng),它是通過javassist構(gòu)建 Class。下面先通過阿里開源的arthas工具查看它生成的Wrapper類到底是什么? Arthas 用戶文檔。首先啟動(dòng)Provider服務(wù)提供者程序,將斷點(diǎn)放置到ret = makerWrapper(c)這里,確定這里的c是DemoServiceImpl,然后運(yùn)行程序至下一步,觀察ret的名字。如下圖
可以發(fā)現(xiàn)生成的Wrapper類是叫Wrapper1,然后放開斷點(diǎn),讓程序走完,服務(wù)提供者處于運(yùn)行狀態(tài)。下圖通過Arthas查看生成的Wrapper1到底是什么? 首先下載它的jar包,下載地址。然后打開cmd,執(zhí)行以下命令。注意2是對(duì)應(yīng)Provider程序的序號(hào),需要和你自己程序?qū)?yīng)。輸入2后可以發(fā)現(xiàn)連上了Arthas。然后使用sc命令查找Wrapper1具體對(duì)應(yīng)的是哪個(gè)class文件,最后使用jad命令反編譯,查看Wrapper1類對(duì)應(yīng)的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()); } // 這個(gè)就是Wrapper對(duì)象的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) { // 調(diào)用DemoServiceImpl實(shí)例對(duì)象的sayHello方法,并將結(jié)果返回 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()); } }
現(xiàn)在我們可以再來回顧一下JavassistProxyFactory中的getInvoker方法,它首先生成一個(gè)Wrapper實(shí)例對(duì)象,經(jīng)過分析得知,它其實(shí)就是DemoServiceImpl的一個(gè)代理對(duì)象,內(nèi)部還有一個(gè)invokeMethod方法。getInvoker方法中生成了一個(gè)匿名Invoker實(shí)例,當(dāng)外部調(diào)用該Invoker的doInvoke方法時(shí),最終會(huì)調(diào)用wrapper.invokeMethod方法,而wrapper.invokerMethod里面就是調(diào)用的目標(biāo)對(duì)象,即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); } }; }
makeWrapper方法就是創(chuàng)建上述的Wrapper的class文件,閱讀代碼時(shí)可以對(duì)照著看,更容易理解,具體就不分析,可以參考 服務(wù)導(dǎo)出。
感謝各位的閱讀,以上就是“Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對(duì)Dubbo中JavaAssist的Wrapper.getWrapper生成代理的方法這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。