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

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

跟蹤消費方建立代理物件的過程在ReferenceConfig中實現

//在init方法中建立代理物件,init在工廠方法FactoryBean的getObject()中呼叫
ref = createProxy(map);
/**
* 在createProxy(Map<String, String> map) 方法最後一行根據生成的invoker物件生成代理物件,根據dubbo特有的spi自適應擴充套件機制 proxyFactory = 
* ExtensionLoader.getExtensionLoader(ProxyFactory.class).getAdaptiveExtension()預設
* 使用javassist動態位元組碼生生代理類
*/
(T) proxyFactory.getProxy(invoker);
/**
* 最終生成的代理物件程式碼如下,實際上儲存了消費介面的所有方法和invocationHander物件,重寫消費介面所有方法為呼叫handler的invoke方法;VersionService是版本測試程式碼中的消費介面,EchoService是預設增加的展示介面,
*/
public class proxy0 implements DC, EchoService, VersionService {
    public static Method[] methods;
    private InvocationHandler handler;
    //VersionService 中的sayHello方法
public String sayHello(String var1) { Object[] var2 = new Object[]{var1}; Object var3 = this.handler.invoke(this, methods[0], var2); return (String)var3; } public String autoLearn(String var1) { Object[] var2 = new Object[]{var1}; Object var3 = this
.handler.invoke(this, methods[1], var2); return (String)var3; } public Object $echo(Object var1) { Object[] var2 = new Object[]{var1}; Object var3 = this.handler.invoke(this, methods[2], var2); return (Object)var3; } public proxy0() { } public proxy0(InvocationHandler var1) { this.handler = var1; } }
//所有代理物件的handler均為InvokerInvocationHandler,invoke程式碼如下:
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        String methodName = method.getName();
        Class<?>[] parameterTypes = method.getParameterTypes();
        if (method.getDeclaringClass() == Object.class) {
            return method.invoke(invoker, args);
        }
        if ("toString".equals(methodName) && parameterTypes.length == 0) {
            return invoker.toString();
        }
        if ("hashCode".equals(methodName) && parameterTypes.length == 0) {
            return invoker.hashCode();
        }
        if ("equals".equals(methodName) && parameterTypes.length == 1) {
            return invoker.equals(args[0]);
        }
        return invoker.invoke(new RpcInvocation(method, args)).recreate();