dubbo源碼五：服務調用過程

文章目錄

• • • 一、Cluster層
    • 二、Protocol 層
    • • 1.ConsumerContextFilter 的invoke 方法
      • 2.FutureFilter 的invoke 方法
      • 3.MonitorFilter中的invoke方法
      • 4.DubboInvoker中invoke方法

消費端代碼示例（參考incubator-dubbo源碼中dubbo-demo子產品）：

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"META-INF/spring/dubbo-demo-consumer.xml"});
context.start();
DemoService demoService = (DemoService) context.getBean("demoService”);

 // 調用遠端方法
String hello = demoService.sayHello("world");
System.out.println(hello);
           

以dubbo分層概念來了解消費端調用過程：

服務端啟動後，消費端引用服務端的接口類會生成一個代理類，即生成InvokerInvocationHandler(invoker)對象執行個體，是以在調用的時候，會直接調用 InvokerInvocationHandler 的 invoke 方法，

一、Cluster層

Cluster層作用：封裝多個提供者的路由及負載均衡，并橋接注冊中心，以Invoker為中心，擴充接口為Cluster、Directory、Router和LoadBalance。将多個服務提供方組合為一個服務提供方，實作對服務消費方來透明，隻需要與一個服務提供方進行互動。

根據 https://blog.csdn.net/zhuqiuhui/article/details/84075521 分析知這裡的 invoker 是 MockClusterInvoker 執行個體，即會調用 MockClusterInvoker 的invoke方法，該方法首先判斷directory中的url是否含有mock值的設定，若沒有設定預設值false。這裡的directory中的url的變量是：

Debug，如下：

其中 this.invoker變量值如下：

上面會調用FailOverClusterInvoker.invoke()，即會調用其父類AbstractClusterInvoker.invoke()的方法。如下：

Debug-1:

Debug-1 分成以下幾個過程：

1. 檢查RPC Cluster invoker中要執行的接口是否被銷毀，若銷毀，則抛出異常。

2. 在調用提供者之前，會擷取目前線程臨時變量裡的RpcContext對象，再将RpcContext對象裡的參數設定到Invocation對象。

RpcContext 是一個臨時狀态持有者，每當發請求或者收到請求的時候RpcContext都會發生變化。例如A調用B，然後B調用C，在服務B中，在B調用C之前，RpcContext儲存了A調用B的參數。當B調用C的時候，RpcContext儲存了B調用C的參數。從源碼上看RpcContext對象是綁定線上程臨時變量LOCAL上，是以可以通過線程臨時變量來擷取到RpcContext的相關參數值。

3. 列出所有的Invoker

這裡可以看到 directory執行個體是 RegistryDirectory 的執行個體，會調用其父類的list方法，即如下：

上面走到RegistryDirectory的doList方法中，其中RegistryDirectory是在消費端服務啟動過程中自動會生成RegistryDirectory執行個體，對應的屬性也初始化完成了，即在消費端啟動過程時，把方法和對應的invoker關系存放到了RegistryDirectory中的methodInvokerMap屬性中（參考：https://blog.csdn.net/zhuqiuhui/article/details/84075521），是以這裡，如下：

其中傳回的 invokers 清單如上面的變量。

4. 擷取方法上配置的負載均衡政策，若沒有配置，選擇預設的政策

常用的配置方法如下：

<dubbo:reference interloadbalance="roundrobin"/>
           

這裡傳回的 loadbalance 的執行個體是 RandomLoadBalance 的執行個體。

5. 幂等操作，即在異步操作中會預設加上invocation ID，不作分析

6. 方法調用

會走到 FailOverClusterInvoker 中的 doInvoke 方法中，即：

該方法首先使用負載均衡政策選擇合适的invoker（不再分析），然後再進行invoker調用，其中invoker變量如下：

上面變量的第一行可以看出 invoker 執行個體是InvokerDelegate執行個體對象，調用其invoke方法會走到InvokerWrapper的invoke方法，由于InvokerDelegate執行個體對象中的invoker内部屬性是 Invoker 接口的匿名實作，其泛型是ProtocolFilterWrapper類，即如上圖中的”[email protected]”，是以會調用”[email protected]”執行個體invoke方法，看其内部實作：

private static <T> Invoker<T> buildInvokerChain(final Invoker<T> invoker, String key, String group) {
    Invoker<T> last = invoker;
    List<Filter> filters = ExtensionLoader.getExtensionLoader(Filter.class).getActivateExtension(invoker.getUrl(), key, group);
    if (!filters.isEmpty()) {
        for (int i = filters.size() - 1; i >= 0; i--) {
            final Filter filter = filters.get(i);
            final Invoker<T> next = last;
            last = new Invoker<T>() {

                @Override
                public Class<T> getInterface() {
                    return invoker.getInterface();
                }

                @Override
                public URL getUrl() {
                    return invoker.getUrl();
                }

                @Override
                public boolean isAvailable() {
                    return invoker.isAvailable();
                }

                @Override
                public Result invoke(Invocation invocation) throws RpcException {
                    return filter.invoke(next, invocation);
                }

                @Override
                public void destroy() {
                    invoker.destroy();
                }

                @Override
                public String toString() {
                    return invoker.toString();
                }
            };
        }
    }
    return last;
}
           

調用的是filter的invoke方法（其中的filter執行個體是ConsumerContextFilter執行個體），首先會調用 ConsumerContextFilter 的 invoke 方法，在ConsumerContextFilter 的 invoke 方法中再調用 FutureFilter 的invoke方法，最後在 FutureFilter 的invoke方法中調用 MonitorFilter 的 invoke 方法，MonitorFilter 的 invoke 方法中會調用DubboInvoker 的invoke方法。

二、Protocol 層

Protocol層作用：封裝RPC調用，以Invocation和Result為中心，擴充接口為Protocol、Invoker和Exporter。Protocol是服務域，它是Invoker暴露和引用的主功能入口，它負責Invoker的生命周期管理。Invoker是實體域，它是Dubbo的核心模型，其它模型都向它靠擾，或轉換成它，它代表一個可執行體，可向它發起invoke調用，它有可能是一個本地的實作，也可能是一個遠端的實作，也可能一個叢集實作。

1.ConsumerContextFilter 的invoke 方法

這裡首先對 RpcContext 進行資訊設定，其後清空sever上下文，再對調用後的結果進行後處理（即postProcessResult方法，主要設定一些要傳遞的參數），在finally中清空了傳遞的參數（目的為下一次調用做準備）。postProcessResult參數中的invoker調用invoke方法會繼續調用下一個filter中的invoke方法，即FutureFilter中的invoke方法。從上面過程可以看出主要對 RpcContext 内容進行設定。

2.FutureFilter 的invoke 方法

主要做一些異步回調工作，其中 invoker.invoke方法會調用MonitorFilter中的invoke方法

3.MonitorFilter中的invoke方法

MonitorFilter會做下監控的處理。會調用 DubboInvoker中invoke方法。

4.DubboInvoker中invoke方法

走完上述方法就完成整個方法的調用過程。