dubbo服務引用三之建立Invoker的代理對象

一、建立Invoker代理

ReferenceConfig#createProxy方法的結尾處，將FailoverClusterInvoker建立DemoService接口的動態代理。

proxyFactory.getProxy(invoker);

proxyFactory也是一個帶有Adaptive註解方法的SPI類。默認實現JavassistProxyFactory。

@SPI("javassist")
public interface ProxyFactory {

    /**
     * create proxy.
     *
     * @param invoker
     * @return proxy
     */
    @Adaptive({Constants.PROXY_KEY})
    <T> T getProxy(Invoker<T> invoker) throws RpcException;

    /**
     * create invoker.
     *
     * @param <T>
     * @param proxy
     * @param type
     * @param url
     * @return invoker
     */
    @Adaptive({Constants.PROXY_KEY})
    <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) throws RpcException;

}

在JavassistProxyFactory#getProxy中
圖6
這個地方生成代理的方法很是相似Java的原生的動態代理java.lang.reflect.Proxy，你們感興趣的能夠本身去看一下，這個地方暫不繼續寫下去了。
咱們主要看一下InvokerInvocationHandler。
這樣在執行接口的方法時，將方法名與入參構形成一個RpcInvocation做爲入參，傳遞到Invoker的invoke函數中去。

public class InvokerInvocationHandler implements InvocationHandler {

    private final Invoker<?> invoker;

    public InvokerInvocationHandler(Invoker<?> handler) {
        this.invoker = handler;
    }

    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();
    }

}

二、總結

咱們都說，使用RPC框架時，調用外部服務就像調用本地服務同樣方便，那麼如何實現服務接口的注入的呢？本文真是從這個角度出發，講解了dubbo服務引用時，是怎麼注入接口的，並講解了dubbo是經過Invoker調用外部服務的。