Dubbo服務(wù)引用

大致流程

Provider將服務(wù)暴露出來并且注冊(cè)到注冊(cè)中心，而Consumer通過注冊(cè)中心獲取Provider的信息，之后將自己封裝成一個(gè)調(diào)用類去與Provider進(jìn)行交互。

首先需要將所有調(diào)用轉(zhuǎn)化為Dubbo中我們熟悉的Invoker，再通過代理類去遠(yuǎn)程獲取服務(wù)。

大致流程如下：

---

服務(wù)引用策略

服務(wù)的引用和服務(wù)的暴露原理相似，都是Spring自定義標(biāo)簽機(jī)制解析生成對(duì)應(yīng)的Bean，在之前服務(wù)暴露使用到的Provider Service使用的是ServiceBean，而Comsumer Reference使用的ReferenceBean。

服務(wù)暴露是在SpringIOC容器完成刷新后開始暴露的，而服務(wù)的引入則分為兩種，分別是餓漢式和懶漢式。

餓漢式是通過實(shí)現(xiàn)Spring的InitializingBean接口中的afterPropertiesSet()實(shí)現(xiàn)的，通過上圖中ReferenceBean的實(shí)現(xiàn)也可以獲知，而容器通過調(diào)用ReferenceBean中的afterPropertiesSet()時(shí)引入服務(wù)。

懶漢式是只有某個(gè)服務(wù)被注入到其他類時(shí)才開始啟動(dòng)引入流程。

默認(rèn)情況下，Dubbo會(huì)使用懶漢式引入策略，如果需要使用餓漢式，需要在<dubbo:reference/>中配置init開啟。

并且通過上圖我們還可以看到ReferenceBean還實(shí)現(xiàn)了FactoryBean，Dubbo通過這個(gè)實(shí)現(xiàn)來進(jìn)行懶漢式引用服務(wù)。

---

服務(wù)引用的三種方式

服務(wù)引用分為三種方式：

• 本地引入
• 直接使用連接引入遠(yuǎn)程服務(wù)
• 通過注冊(cè)中心引入遠(yuǎn)程服務(wù)

本地引入的基礎(chǔ)是之前介紹過的本地暴露，某個(gè)服務(wù)端可能同時(shí)是Provider又是Comsumer，并且可能會(huì)自己調(diào)用本地的服務(wù)，這種情況下不需要進(jìn)行網(wǎng)絡(luò)調(diào)用，所以引入了本地引用，來避免不必要的網(wǎng)絡(luò)開銷。

服務(wù)引入時(shí)，第一步做的就是在本地中查找是否有可用的本地服務(wù)。

直連引入服務(wù)，這種方式不需要注冊(cè)中心的支持，繞過了注冊(cè)中心，直接通過Url來引用遠(yuǎn)程服務(wù)，具體實(shí)現(xiàn)是在Comsumer中寫死Provider的具體地址，然后在調(diào)用時(shí)直接連接即可，一般用于測(cè)試，如果大量服務(wù)之間都使用直連引入，那么服務(wù)集群之間的關(guān)系將錯(cuò)綜復(fù)雜，變得那以維護(hù)和管理。

注冊(cè)中心引入服務(wù)，Comsumer通過注冊(cè)中心獲取Provider的相關(guān)信息，然后進(jìn)行服務(wù)的引入，其中還涉及到多注冊(cè)中心，服務(wù)集群時(shí)的負(fù)載均衡，以及容錯(cuò)機(jī)制。

---

服務(wù)引入流程解析

前提：服務(wù)引入選擇默認(rèn)的懶漢式引入策略并且使用注冊(cè)中心引入服務(wù)。

服務(wù)引入的入口是ReferenceBean.getObject()：

然后會(huì)調(diào)用父類ReferenceConfig.get()：

進(jìn)入init()方法，前面的一大串代碼就是做if else判斷的配置檢查并且將配置放入map，構(gòu)建完畢后的map如下：

再進(jìn)入createProxy()方法

如果是本地引入的話，會(huì)構(gòu)建一個(gè)本地引入的URL然后進(jìn)行服務(wù)的引入，即圖示中的refprotocol.refer()

不是本地引入，那么就是遠(yuǎn)程引入了，接下來需要判斷的是點(diǎn)對(duì)點(diǎn)直連provider還是通過注冊(cè)中心拿到provider信息再進(jìn)行連接。

以下是點(diǎn)對(duì)點(diǎn)直連：

以下是通過注冊(cè)中心連接：

最終拼接出來的URL如下圖所示：

方法最后通過代理封裝invoker返回代理實(shí)現(xiàn)。

上圖就是整個(gè)服務(wù)引用流程。

但是還有很多細(xì)節(jié)，比如如何從注冊(cè)中心獲得Provider，invoker內(nèi)部結(jié)構(gòu)是怎么樣的？

在上面URL的截圖中，我們可以看到此時(shí)的協(xié)議是registry，因此會(huì)調(diào)用RegistryPotocol.refer()

獲取注冊(cè)中心實(shí)例，之后調(diào)用doRefer()

RegistryDirectory類是實(shí)現(xiàn)了NotifyListener接口的，注冊(cè)中心的監(jiān)聽功能就此而來。

public class RegistryDirectory<T> extends AbstractDirectory<T> implements NotifyListener {}public interface NotifyListener {void notify(List<URL> var1); }

向注冊(cè)中心注冊(cè)自身信息之后，會(huì)向注冊(cè)中心訂閱providers，configurators，routers節(jié)點(diǎn)信息。訂閱之后RegistryDirectory會(huì)收到這幾個(gè)節(jié)點(diǎn)的信息，并觸發(fā)DubboInvoker的生成，即用于遠(yuǎn)程調(diào)用的invoker。

再通過cluster封裝得到invoker，因此一個(gè)服務(wù)可能有多個(gè)提供者，最終在ProviderConsumerRegTable記錄這些信息，然后返回invoker。

拿到Provider的信息之后就會(huì)通過監(jiān)聽觸發(fā)DubboProtocol.refer()

重點(diǎn)在getClients()方法中，這個(gè)方法是用于獲取客戶端實(shí)例的，實(shí)例類型為ExchangeClient[]，底層依賴Netty進(jìn)行通訊，并且是默認(rèn)共享連接的。

再進(jìn)入initClient()方法中看看初始化客戶端的具體細(xì)節(jié)：

最后返回的(ExchangeClient) client封裝的是NettyClient

最后得到的Invoker如下，其中記錄到了許多信息：

最后調(diào)用return proxyFactory.getProxy(this.invoker);將代理對(duì)象返回。

以下是整個(gè)服務(wù)引用的流程圖：

---

總結(jié)

首先是通過配置構(gòu)建URL，再通過協(xié)議頭自適應(yīng)拓展得到具體的實(shí)現(xiàn)類進(jìn)行服務(wù)引入，之后消費(fèi)者向注冊(cè)中心注冊(cè)自己的信息，然后訂閱相關(guān)信息，得到遠(yuǎn)程服務(wù)提供者的信息，最后通過NettyClient進(jìn)行連接通訊。

還會(huì)通過Directory和Cluster進(jìn)行多個(gè)服務(wù)提供者的合并、屏蔽、容錯(cuò)以及負(fù)載均衡，最終將封裝好的可執(zhí)行體Invoker通過動(dòng)態(tài)代理封裝得到代理對(duì)象返回。

以上。

整理不易，如果對(duì)你有用的話留個(gè)三連吧！

《新程序員》：云原生和全面數(shù)字化實(shí)踐50位技術(shù)專家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的Dubbo服务引用过程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。