dubbo原始碼之動態代理模式生成Invoker過程
阿新 • • 發佈:2019-02-16
// 原始碼中proxyFactory生成Invoker根據spi機制預設使用JavaassistRpcProxyFactory
Invoker<?> invoker = proxyFactory.getInvoker(ref, (Class) interfaceClass, registryURL.addParameterAndEncoded(Constants.EXPORT_KEY, url.toFullString()));
/**
* JavaassistRpcProxyFactory中獲取Invoker動態生成了Wrapper對應類(Wrapper0,Wrapper +數字)和
* 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.");
}