一、dubbo的注冊中心以及服務注冊源碼剖析

本文轉載自查看原文 2020-10-11 09:25 733 微服務/ dubbo

一、整體設計

　　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 的過程

那么是什么時候觸發的服務注冊呢？我們先來看一下org.apache.dubbo.config.ServiceConfig 的繼承關系以及他的子類的繼承關系我們就明白了