1. 程式人生 > >dubbo原始碼之動態代理模式生成Invoker過程

dubbo原始碼之動態代理模式生成Invoker過程

// 原始碼中proxyFactory生成Invoker根據spi機制預設使用JavaassistRpcProxyFactory
   Invoker<?> invoker = proxyFactory.getInvoker(ref, (Class) interfaceClass, registryURL.addParameterAndEncoded(Constants.EXPORT_KEY, url.toFullString()));
/** 
* JavaassistRpcProxyFactory中獲取Invoker動態生成了Wrapper對應類(Wrapper0Wrapper
+數字)和 * wrapper物件,Wrapper0類重點代理生成了invokeMethod方法 * / 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); }
}; }
// Wrapper0類中的invokeMethod方法

    public Object invokeMethod(Object var1, String var2, Class[] var3, Object[] var4) throws InvocationTargetException {
    //代理的服務方實現類,首先把物件強轉為相應的服務方物件
        VersionServiceImpl var5;
        try {
            var5 = (VersionServiceImpl)var1;
        } catch (Throwable var8) {
            throw new IllegalArgumentException(var8);
        }

        try {
        // 服務方實現類中的方法autoLearn
            if("autoLearn".equals(var2) && var3.length == 1) {
                return var5.autoLearn((String)var4[0]);
            }
        // 服務方實現類中的方法sayHello
            if("sayHello".equals(var2) && var3.length == 1) {
                return var5.sayHello((String)var4[0]);
            }
        } catch (Throwable var9) {
            throw new InvocationTargetException(var9);
        }

        throw new NoSuchMethodException("Not found method \"" + var2 + "\" in class com.alibaba.dubbo.examples.version.impl.VersionServiceImpl.");
    }