一、整體設計
dubbo整體設計以及呼叫用鏈路參照官網 http://dubbo.apache.org/zh-cn/docs/dev/design.html
二、dubbo的注冊中心
1、注冊中心參照官網 http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html
2、zk注冊中心詳解
2.1、目錄結構
+- dubbo
+- com.demo.service.HelloService+- consumers
+- consumer://192.168.1.102/com.demo.service.HelloService?application=dubbo-demo-annotation-consumer&category=consumers&check=false&dubbo=2.0.2&init=false&interface=com.lagou.service.HelloService***
+- providers
+- dubbo://192.168.1.102:20880/com.demo.service.HelloService?anyhost=true&application=dubbo-demo-annotation-provider&deprecated=false&dubbo=2.0.2*** +- configuration +- routers解釋: (1)、在服務啟動的時候dubbo會在zk的根目錄下創建一個dubbo的目錄 (2)、dubbo跟節點下面是當前所擁有的介面名稱,如果有多個介面,則會以多個子節點的形式展開 (3)、每個服務下面又分別有四個配置項 1)、consumers: 當前服務下面所有的消費者串列(URL) 2)、providers: 當前服務下面所有的提供者串列(URL) 3)、confifiguration: 當前服務下面的配置資訊資訊,provider或者consumer會通過讀取這里的配置資訊來獲取配置 4)、routers: 當消費者在進行獲取提供者的時,會通過這里配置好的路由來進行適配匹配規則 2.2、dubbo中的url 從2.1中咱們不難發現,無論是服務提供者還是服務消費者,在注冊中心zk中都是以url的形式進行保存以便進行資源定位,所以咱們來具體看一下dubbo中的url 規則:protocol://host:port/path?key=value&key=value 例子:參考2.1中的目錄結構中的consumer或者producer (1)、對應原始碼(構造方法)
(2)、主要組成部分
1)、protocol: 協議,一般像我們的 provider 或者 consumer 在這里都是人為具體的協議
2)、host: 當前 provider 或者其他協議所具體針對的地址,比較特殊的像 override 協議所指定的host就是 0.0.0.0 代表所有的機器都生效
3)、port: 和上面相同,代表所處理的埠號 4)、path: 服務路徑,在 provider 或者 consumer 等其他中代表著我們真實的業務介面 5)、key=value: 這些則代表具體的引數,這里我們可以理解為對這個地址的配置,比如我們 provider中需要具體機器的服務應用名,就可以是一個配置的方式設定上去 (3)、dubbo中的URL與JAVA中的URL的區別 1)、dubbo中的URL支持引數的動態增減



2.3、服務本地快取


從上面兩張圖我們可以看到,服務提供者在啟動的時候會主動將自己提供的服務注冊到注冊中心中,而服務消費者在啟動的時候也會去注冊中心中獲取自己參考的服務串列到本地并保存到檔案中,而且需要訂閱對應的服務提供者節點,當服務提供者有資訊變更的時候消費者會收到節點變更通知,進而獲取最新服務串列跟新本地快取檔案,
Dubbo在服務參考程序中會創建registry物件并加載本地快取檔案,會優先訂閱注冊中心,訂閱注冊中心失敗后會訪問本地快取檔案內容獲取服務提供資訊 下面我們來看一下具體的原始碼 1)、頂級介面 org.apache.dubbo.registry.Registry
可以看到其中就提供了兩個方法1、注冊;2、注銷,

org.apache.dubbo.registry.RegistryService 這個類主要是對指定的路徑進行注冊,注銷,監聽和取消監聽,查詢操作,也是注冊中心中最為基礎的類
AbstractRegistry 是對注冊中心的封裝,其主要會對本地注冊地址的封裝,主要功能在于遠程注冊中心不可用的時候,可以采用本地的注冊中心來使用
FailbackRegistry 失敗自動恢復,后臺記錄失敗請求,定時重發功能接下來我們來看一下他的實作類org.apache.dubbo.registry.support.AbstractRegistry#AbstractRegistry的構造方法的具體實作







其實這里主要做的就是把url快取到本地檔案中
2.4、服務注冊程序分析
1、服務注冊時序圖

2、服務注冊程序

說明:服務注冊程序大致可以分為兩個程序1、具體某個服務轉換為Invoker,2、invoker轉換成exporter
從上面兩張圖可以看出dubbo先從 ServiceConfig 類拿到對外提供服務的實際類 ref(如:HelloServiceImpl),然后通過ProxyFactory 介面實作類中的 getInvoker 方法使用 ref 生成一個 AbstractProxyInvoker 實體,到這一步就完成具體服務到 Invoker 的轉化,接下來就是 Invoker 轉換到 Exporter 的程序接下來我們重點看一下ServiceConfig中的ProxyFactory 和 Protocol 以及 ref 屬性


接下來我們再看一下協議介面

可以看到協議頂級介面中提供了暴露和參考服務的介面它有很多實作類,而我們注冊使用的是org.apache.dubbo.registry.integration.RegistryProtocol
接下來我們看一下如何將一個ServiceConfig轉換成invoker由于方法較長就不詳細截圖了
org.apache.dubbo.config.ServiceConfig#export
org.apache.dubbo.config.ServiceConfig#doExport
org.apache.dubbo.config.ServiceConfig#doExportUrls
org.apache.dubbo.config.ServiceConfig#doExportUrlsFor1Protocol

接下來我們再回頭看看org.apache.dubbo.registry.integration.RegistryProtocol#export這個方法

這個方法呢主要做了5件事
1、獲取注冊中心的url:zookeeper://127.0.0.1:2181/org.apache.dubbo.registry.RegistryService?application=***
2、獲取服務提供者的url: dubbo://192.168.1.102:20880/com.demo.service.HelloService?anyhost=**
3、獲取注冊中心
4、將服務提供者注冊到注冊中心中
5、回傳暴露的物件
接下來我們再看一下org.apache.dubbo.registry.integration.RegistryProtocol.DestroyableExporter類

他主要提供了一個獲取invoker的方法
我們再看一下注冊方法

可以看到這里使用的是工廠模式獲取的具體工廠,接下來我們再看一下注冊中心的工廠介面

org.apache.dubbo.registry.RegistryFactory 是注冊中心工廠,通過這種方式,也可以保證一個應用中可以使用多個注冊中心,可以看到這里也是通過不同的protocol引數,來選擇不同的協議
接下來我們看一下org.apache.dubbo.registry.support.FailbackRegistry#register


這里主要做了三件事情
1、把當前url放入到已經注冊的串列中
2、處理注冊失敗的url
3、真正處理當前url的注冊
我們再看看真正處理當前url的注冊方法就會發現這是一個模板方法,需要子類去提供具體實作

既然dubbo默認使用zk為注冊中心,那咱們就再看看zk的實作

看到這里,服務注冊的流程就ok了,
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/167851.html
標籤:架構設計
上一篇:【Java設計模式】單例模式
