java開發分佈式服務框架Dubbo暴露服務過程詳解

Dubbo服務暴露機制

前言

在進行服務暴露機制的分析之前,必須談談什麼是URL,在Dubbo服務暴露過程中URL是無處不在的,貫穿瞭整個過程。

一般情況下,URL指的是統一資源定位符,標準格式如下:

protocol://host:port/path?key1=value1&key2=value2

Dubbo就是用這種URL的方式來作為約定的參數類型,服務之間也是用URL來進行交互。

Dubbo用URL作為配置總線,貫穿整個源碼體系。

URL的具體參數如下:

protocol:dubbo中的各種協議,如:dubbo、http、thrift

host/port:主機/端口號

path:接口名稱

parameters:參數鍵值對

服務暴露流程

大體流程分為三個步驟:

檢測配置,有些配置為空值會有默認值自動填充並自動組裝為URL暴露服務,包括暴露到本地和遠程的服務註冊為服務到服務註冊中心

源碼解析

先來到ServiceBean

在這裡插入圖片描述

可以看到這個類實現瞭ApplicationListener<ContextRefreshedEvent>,這樣就會在Spring IOC容器刷新之後調用onApplicationEvent方法,這個方法中做的就是服務暴露。

在這裡插入圖片描述

if判斷條件中,我們可以看到如果配置中沒有設置延遲暴露、並且沒有暴露過、並且支持暴露的情況下就會執行this.export(),最終會調用父類ServiceConfig中的export方法。

請添加圖片描述

上述方法中主要就是進行配置檢查,然後進入this.doExport()進行服務暴露,這個方法前面的部分都是一些配置檢查,重點放在最後的this.doExportUrls()

請添加圖片描述

從上述源碼中可以看到Dubbo是支持多註冊中心的,並且支持多種協議,一個服務如果有多個協議那麼都需要暴露。this.loadRegistries()是根據配置組裝成註冊中心相關的URL,如下:

registry://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?application=user-service-provider-one&dubbo=2.6.2&pid=29056&registry=zookeeper&timestamp=1632309180780

接下來進入this.doExportUrlsFor1Protocol()

在這裡插入圖片描述

構建完成之後的URL如下圖所示:

請添加圖片描述

使用的是dubbo協議,接下來要做的就是根據URL來進行服務暴露

在這裡插入圖片描述

本地暴露

進入exportLocal()看一下,這個方法做的事就是進行本地暴露,使用的是injvm協議,這個方法中對URL進行修改,將協議改為injvm

在這裡插入圖片描述

此處的protocol.export()是標註瞭@Adaptive註解的,設計自適應拓展,調用該方法之後會生成代理類,代理類通過URL中的參數得知所使用的協議,然後通過Dubbo SPI機制實現拓展,選擇對應的實現類進行export()方法,此處的方法會選擇InjvmProtocol中的export()進行暴露。

在這裡插入圖片描述

在這裡插入圖片描述

經過轉化後得到的export如下所示:

在這裡插入圖片描述

如圖所示,具體實現類被層層包裝。

為什麼要封裝成invoker呢?

封裝成invoker是為瞭屏蔽調用的細節,統一暴露出一個可執行體,使得調用者調用時變得便捷簡易。

為什麼要使用本地暴露呢?

因為可能存在本地不同服務之間相互調用的情況,因此本地暴露後,內部可以直接進行調用,而省去瞭不必要的網絡通信。

此處引用一下博主敖丙的文章中的本地暴露流程圖:

在這裡插入圖片描述

遠程暴露

此時本地暴露已經完成瞭,現在開始遠程暴露。

在這裡插入圖片描述

流程與本地暴露相似,都需要先封裝為invoker然後再進一步生成exporter,以下是registryURL.addParameterAndEncoded()方法將URL進行拼接後的結果:

在這裡插入圖片描述

可以看到先是走registry協議,然後參數中有一個export=dubbo://,此時會走dubbo協議,所以我們得知SPI會先通過registry協議找到RegistryPotocol然後執行export(),然後再執行DubboPotocol中的export()

現在我們進入RegistryPotocol中的export()方法。

在這裡插入圖片描述

上述操作主要是講export轉化為exporter,獲取註冊中心的相關配置,如果需要註冊則向註冊中心進行註冊,並且在ProviderConsumerRegTable中記錄服務提供者信息,進入源碼中,我們發現實質就是往一個ConcurrentHashMap中塞入invoker,key是服務接口全類名,value是一個set,set中存儲包裝過的invoker。

在這裡插入圖片描述

然後進入 doLocalExport 方法內部

在這裡插入圖片描述

箭頭指向的方法最終會調用DubboProtocol中的export()

在這裡插入圖片描述

在這裡插入圖片描述

需要創建server

在這裡插入圖片描述

上述代碼中,主要就是根據URL創建出key,然後將key和invoker存入exporterMap中關聯起來,如果是初次服務暴露則需要創建監聽服務器,默認是NettyServer,並且初始化各種Handler,比如心跳檢測,解碼等。

至此服務暴露流程結束。

在這裡插入圖片描述

此處引用博主敖丙的文章中的本地暴露流程圖:

在這裡插入圖片描述

如果不足或錯誤歡迎評論指正。

以上就是java開發分佈式服務框架Dubbo暴露服務過程詳解的詳細內容,更多關於Dubbo暴露服務過程詳解的資料請關註WalkonNet其它相關文章!

推薦閱讀: