前言

在介紹Dubbo之前先了解一下基本概念：

Dubbo是一個(gè)RPC框架，RPC，即Remote Procedure Call（遠(yuǎn)程過程調(diào)用），相對(duì)的就是本地過程調(diào)用，在分布式架構(gòu)之前的單體應(yīng)用架構(gòu)和垂直應(yīng)用架構(gòu)運(yùn)用的都是本地過程調(diào)用。它允許程序調(diào)用另外一個(gè)地址空間（通常是網(wǎng)絡(luò)共享的另外一臺(tái)機(jī)器）的過程或函數(shù)，并且不用程序員顯式編碼這個(gè)遠(yuǎn)程調(diào)用的細(xì)節(jié)。

而分布式架構(gòu)應(yīng)用與應(yīng)用之間的遠(yuǎn)程調(diào)用就需要RPC框架來做，目的就是為了讓遠(yuǎn)程調(diào)用像本地調(diào)用一樣簡(jiǎn)單。

Dubbo框架有以下部件

Consumer

即調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方，消費(fèi)者需要面向接口編程，知道了哪些接口可以調(diào)用了，具體實(shí)現(xiàn)需要框架提供一個(gè)代理類來為接口提供具體實(shí)現(xiàn)，讓消費(fèi)者只管調(diào)用什么接口，而具體實(shí)現(xiàn)的獲取由代理類來處理。

消費(fèi)者還需要提供調(diào)用方法名以及方法的參數(shù)值。

但是代理類此時(shí)還不知道需要調(diào)用哪個(gè)服務(wù)器上的遠(yuǎn)程方法，此時(shí)需要一個(gè)注冊(cè)中心，通過注冊(cè)中心獲取可以調(diào)用的遠(yuǎn)程服務(wù)列表。

遠(yuǎn)程服務(wù)器一般都是集群部署，那么調(diào)用哪個(gè)服務(wù)器則需要通過負(fù)載均衡來選擇一個(gè)最合適的服務(wù)器來調(diào)用。

同時(shí)還需要有集群容錯(cuò)機(jī)制，因?yàn)楦鞣N原因，可能遠(yuǎn)程調(diào)用會(huì)失敗，此時(shí)需要容錯(cuò)機(jī)制來重試調(diào)用，保證遠(yuǎn)程調(diào)用的穩(wěn)定性。

同時(shí)與服務(wù)提供方約定好通信協(xié)議和序列化格式，方便通信以及數(shù)據(jù)傳輸。

Provider

即暴露服務(wù)的服務(wù)提供方，服務(wù)提供方內(nèi)部實(shí)現(xiàn)具體的接口，然后將接口暴露出去，再將服務(wù)注冊(cè)到注冊(cè)中心，服務(wù)消費(fèi)方調(diào)用服務(wù)，提供者接收到調(diào)用請(qǐng)求后，通過約定好的通信協(xié)議來處理該請(qǐng)求，然后做反序列化，完成后，將請(qǐng)求放入線程池中處理，某個(gè)線程接收到這個(gè)請(qǐng)求然后找到對(duì)應(yīng)的接口實(shí)現(xiàn)進(jìn)行調(diào)用，然后將調(diào)用結(jié)果原路返回。

Registry

即服務(wù)注冊(cè)與發(fā)現(xiàn)的注冊(cè)中心，注冊(cè)中心負(fù)責(zé)服務(wù)地址的注冊(cè)與查找，相當(dāng)于服務(wù)目錄，服務(wù)提供者和消費(fèi)者只會(huì)再啟動(dòng)時(shí)與注冊(cè)中心交互，注冊(cè)中心不轉(zhuǎn)發(fā)請(qǐng)求，壓力小。

注冊(cè)中心還可以集中化處理配置以及動(dòng)態(tài)地將變更通知訂閱方。

但是為什么需要注冊(cè)中心呢？沒有注冊(cè)中心不可以嗎？

在沒有注冊(cè)中心，各服務(wù)之間的調(diào)用關(guān)系是這樣的：

當(dāng)服務(wù)越來越多時(shí)，服務(wù)URL配置管理變得非常困難，硬件負(fù)載均衡器的單點(diǎn)壓力也越來越大，而有了注冊(cè)中心之后，就可以實(shí)現(xiàn)服務(wù)的統(tǒng)一管理，并且實(shí)現(xiàn)軟負(fù)載均衡，降低硬件成本，以下為注冊(cè)中心示意圖：

Monitor

即統(tǒng)計(jì)服務(wù)調(diào)用次數(shù)和調(diào)用時(shí)間的監(jiān)控中心，面對(duì)眾多服務(wù)，精細(xì)化的監(jiān)控和方便的運(yùn)維是不可或缺的，對(duì)后期維護(hù)相當(dāng)重要。

Container

即服務(wù)運(yùn)行的容器。

架構(gòu)

圖中的各個(gè)節(jié)點(diǎn)充當(dāng)?shù)慕巧呀?jīng)介紹過了，以下是各節(jié)點(diǎn)之間調(diào)用關(guān)系：

Container服務(wù)容器負(fù)責(zé)啟動(dòng)，加載以及運(yùn)行

Provider服務(wù)提供者Provider服務(wù)提供者啟動(dòng)時(shí)，需要將自身暴露出去讓遠(yuǎn)程服務(wù)器可以發(fā)現(xiàn)，同時(shí)向Registry注冊(cè)中心注冊(cè)自己提供的服務(wù)

Consumer服務(wù)消費(fèi)者啟動(dòng)時(shí)，向Registry注冊(cè)中心訂閱所需要的服務(wù)

Registry注冊(cè)中心返回服務(wù)提供者列表給消費(fèi)者，同時(shí)如果發(fā)生變更，注冊(cè)中心將基于長(zhǎng)連接推送實(shí)時(shí)數(shù)據(jù)給消費(fèi)者

服務(wù)消費(fèi)者需要調(diào)用遠(yuǎn)程服務(wù)時(shí)，會(huì)從提供者的地址列表中，基于負(fù)載均衡算法選出一臺(tái)提供者服務(wù)器進(jìn)行調(diào)用，如果調(diào)用失敗，會(huì)基于集群容錯(cuò)策略進(jìn)行調(diào)用重試

服務(wù)消費(fèi)者與提供者會(huì)在內(nèi)存中統(tǒng)計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間，然后通過定時(shí)任務(wù)將數(shù)據(jù)發(fā)送給Monitor監(jiān)控中心

高可用性

• 監(jiān)控中心宕機(jī)后不會(huì)對(duì)服務(wù)造成影響，只是丟失部分統(tǒng)計(jì)數(shù)據(jù)
• 注冊(cè)中心集群后，任意一臺(tái)宕機(jī)后，將自動(dòng)切換到其他注冊(cè)中心
• 當(dāng)所有注冊(cè)中心均宕機(jī)后，服務(wù)提供者和消費(fèi)者之間仍然能通過本地記錄了彼此信息的緩存進(jìn)行通訊，但是如果一方產(chǎn)生變更，另外一方無法感知
• 服務(wù)提供者無狀態(tài)，任意一臺(tái)服務(wù)器宕機(jī)后不影響使用，會(huì)有其他服務(wù)提供者提供服務(wù)
• 當(dāng)所有服務(wù)提供者宕機(jī)后，服務(wù)消費(fèi)者無法正常使用，將進(jìn)行無限次重連等待服務(wù)提供者重新連線恢復(fù)

框架設(shè)計(jì)

大的分層為Business（業(yè)務(wù)邏輯層）、RPC層和Remoting層。

再細(xì)分下來，Dubbo一共有十層架構(gòu)，作用分別如下：

Service，業(yè)務(wù)層，即日常開發(fā)中的業(yè)務(wù)邏輯層

Config，配置層，對(duì)外配置接口，以ServiceConfig 和ReferenceConfig為中心，可以直接初始化配置類，也可以通過Spring解析配置生成配置類

Proxy，服務(wù)代理層，服務(wù)接口透明代理，生成服務(wù)的客戶端Stub和客戶端Skeleton，負(fù)責(zé)遠(yuǎn)程調(diào)用和返回結(jié)果

Registry，注冊(cè)中心層，封裝服務(wù)地址的注冊(cè)與發(fā)現(xiàn)，以服務(wù)URL為中心，拓展接口為RegistryFactory，Registry，RegistryService

Cluster路由和集群容錯(cuò)層，封裝了多個(gè)提供者的路由、負(fù)載均衡以及集群容錯(cuò)，并橋接注冊(cè)中心，負(fù)責(zé)通過負(fù)載均衡選取調(diào)用具體的節(jié)點(diǎn)，處理特殊調(diào)用請(qǐng)求和負(fù)責(zé)遠(yuǎn)程調(diào)用失敗的容錯(cuò)措施

Monitor，監(jiān)控層，負(fù)責(zé)監(jiān)控統(tǒng)計(jì)RPC調(diào)用次數(shù)和調(diào)用時(shí)間

Portocol，遠(yuǎn)程調(diào)用層，主要封裝RPC遠(yuǎn)程調(diào)用方法

Exchange，信息交換層，用于封裝請(qǐng)求響應(yīng)模型

Transport，網(wǎng)絡(luò)傳輸層，抽象化網(wǎng)絡(luò)傳輸統(tǒng)一接口，有Mina和Netty可供使用

Serialize，序列化層，將數(shù)據(jù)序列化成二進(jìn)制流進(jìn)行傳輸，也可以反序列化接收數(shù)據(jù)

服務(wù)暴露過程

首先Provider啟動(dòng)，Protocal通過Proxy代理將需要暴露的接口封裝成Invoker，是一個(gè)可執(zhí)行體，然后通過Exporter包裝并發(fā)送到注冊(cè)中心完成注冊(cè)，至此服務(wù)就暴露完成。

服務(wù)消費(fèi)過程

注：上圖中藍(lán)色部分為服務(wù)消費(fèi)者，綠色部分為服務(wù)提供者。

服務(wù)消費(fèi)者啟動(dòng)時(shí)會(huì)向注冊(cè)中心訂閱并拉取所需服務(wù)提供者的信息，并保存到本地緩存，由此即使所有注冊(cè)中心宕機(jī)后，服務(wù)提供者和服務(wù)消費(fèi)者也可以通過本地緩存進(jìn)行通訊，只是一方出現(xiàn)了信息變更，另一方無法感知，但并不影響服務(wù)的進(jìn)行。

之后整個(gè)服務(wù)消費(fèi)流程從圖中的Proxy開始，由代理類完成處理，以此到達(dá)透明無感知。

ProxyFactory生成一個(gè)Proxy代理類，Proxy持有一個(gè)Invoker可執(zhí)行對(duì)象，調(diào)用invoke之后需要通過Cluster從Directory中獲取所有可調(diào)用的遠(yuǎn)程服務(wù)Invoker列表，如果配置了某些路由規(guī)則，還需要再過濾一遍Invoker列表。

剩下的Invoker再通過LoadBalance做負(fù)載均衡選取一個(gè)，還需要再通過Filter進(jìn)行一些數(shù)據(jù)統(tǒng)計(jì)，之后將這些數(shù)據(jù)保存下來，定時(shí)發(fā)送給Monitor。

接下來用Client做數(shù)據(jù)傳輸，一般用Netty進(jìn)行傳輸。

傳輸需要通過Codec接口進(jìn)行協(xié)議構(gòu)造，然后再通過Serialization進(jìn)行序列化，最后將序列化后的二進(jìn)制流發(fā)送至給對(duì)應(yīng)的服務(wù)提供者。

服務(wù)提供者接收到二進(jìn)制流后也會(huì)進(jìn)行Codec協(xié)議處理，然后進(jìn)行反序列化（此處的處理與傳輸之前的處理是呈對(duì)稱的）后將請(qǐng)求放入線程池中處理，某個(gè)線程會(huì)根據(jù)請(qǐng)求找到對(duì)應(yīng)的Exporter，然后再通過Filter進(jìn)行層層過濾得到Invoker，最終調(diào)用對(duì)應(yīng)的實(shí)現(xiàn)類然后將結(jié)果原路返回。

如有錯(cuò)誤或不足歡迎評(píng)論指正。

以上就是java開發(fā)分布式服務(wù)框架Dubbo原理機(jī)制詳解的詳細(xì)內(nèi)容，更多關(guān)于Dubbo分布式服務(wù)框架原理機(jī)制的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論