第java開發(fā)分布式服務(wù)框架Dubbo暴露服務(wù)過(guò)程詳解目錄Dubbo服務(wù)暴露機(jī)制前言服務(wù)暴露流程源碼解析本地暴露遠(yuǎn)程暴露

Dubbo服務(wù)暴露機(jī)制

前言

在進(jìn)行服務(wù)暴露機(jī)制的分析之前，必須談?wù)勈裁词荱RL，在Dubbo服務(wù)暴露過(guò)程中URL是無(wú)處不在的，貫穿了整個(gè)過(guò)程。

一般情況下，URL指的是統(tǒng)一資源定位符，標(biāo)準(zhǔn)格式如下：

protocol://host:port/pathkey1=value1key2=value2

Dubbo就是用這種URL的方式來(lái)作為約定的參數(shù)類型，服務(wù)之間也是用URL來(lái)進(jìn)行交互。

Dubbo用URL作為配置總線，貫穿整個(gè)源碼體系。

URL的具體參數(shù)如下：

protocol：dubbo中的各種協(xié)議，如：dubbo、http、thrift

host/port：主機(jī)/端口號(hào)

path：接口名稱

parameters：參數(shù)鍵值對(duì)

服務(wù)暴露流程

大體流程分為三個(gè)步驟：

檢測(cè)配置，有些配置為空值會(huì)有默認(rèn)值自動(dòng)填充并自動(dòng)組裝為URL暴露服務(wù)，包括暴露到本地和遠(yuǎn)程的服務(wù)注冊(cè)為服務(wù)到服務(wù)注冊(cè)中心

源碼解析

先來(lái)到ServiceBean中

可以看到這個(gè)類實(shí)現(xiàn)了ApplicationListenerContextRefreshedEvent，這樣就會(huì)在SpringIOC容器刷新之后調(diào)用onApplicationEvent方法，這個(gè)方法中做的就是服務(wù)暴露。

從if判斷條件中，我們可以看到如果配置中沒(méi)有設(shè)置延遲暴露、并且沒(méi)有暴露過(guò)、并且支持暴露的情況下就會(huì)執(zhí)行this.export()，最終會(huì)調(diào)用父類ServiceConfig中的export方法。

上述方法中主要就是進(jìn)行配置檢查，然后進(jìn)入this.doExport()進(jìn)行服務(wù)暴露，這個(gè)方法前面的部分都是一些配置檢查，重點(diǎn)放在最后的this.doExportUrls()。

從上述源碼中可以看到Dubbo是支持多注冊(cè)中心的，并且支持多種協(xié)議，一個(gè)服務(wù)如果有多個(gè)協(xié)議那么都需要暴露。this.loadRegistries()是根據(jù)配置組裝成注冊(cè)中心相關(guān)的URL，如下：

registry://:2181/com.alibaba.dubbo.registry.RegistryServiceapplication=user-service-provider-onedubbo=2.6.2pid=29056registry=zookeepertimestamp=1632309180780

接下來(lái)進(jìn)入this.doExportUrlsFor1Protocol()，

構(gòu)建完成之后的URL如下圖所示：

使用的是dubbo協(xié)議，接下來(lái)要做的就是根據(jù)URL來(lái)進(jìn)行服務(wù)暴露

本地暴露

進(jìn)入exportLocal()看一下，這個(gè)方法做的事就是進(jìn)行本地暴露，使用的是injvm協(xié)議，這個(gè)方法中對(duì)URL進(jìn)行修改，將協(xié)議改為injvm。

此處的protocol.export()是標(biāo)注了@Adaptive注解的，設(shè)計(jì)自適應(yīng)拓展，調(diào)用該方法之后會(huì)生成代理類，代理類通過(guò)URL中的參數(shù)得知所使用的協(xié)議，然后通過(guò)DubboSPI機(jī)制實(shí)現(xiàn)拓展，選擇對(duì)應(yīng)的實(shí)現(xiàn)類進(jìn)行export()方法，此處的方法會(huì)選擇InjvmProtocol中的export()進(jìn)行暴露。

經(jīng)過(guò)轉(zhuǎn)化后得到的export如下所示：

如圖所示，具體實(shí)現(xiàn)類被層層包裝。

為什么要封裝成invoker呢？

封裝成invoker是為了屏蔽調(diào)用的細(xì)節(jié)，統(tǒng)一暴露出一個(gè)可執(zhí)行體，使得調(diào)用者調(diào)用時(shí)變得便捷簡(jiǎn)易。

為什么要使用本地暴露呢？

因?yàn)榭赡艽嬖诒镜夭煌?wù)之間相互調(diào)用的情況，因此本地暴露后，內(nèi)部可以直接進(jìn)行調(diào)用，而省去了不必要的網(wǎng)絡(luò)通信。

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

遠(yuǎn)程暴露

此時(shí)本地暴露已經(jīng)完成了，現(xiàn)在開始遠(yuǎn)程暴露。

流程與本地暴露相似，都需要先封裝為invoker然后再進(jìn)一步生成exporter，以下是registryURL.addParameterAndEncoded()方法將URL進(jìn)行拼接后的結(jié)果：

可以看到先是走registry協(xié)議，然后參數(shù)中有一個(gè)export=dubbo://，此時(shí)會(huì)走dubbo協(xié)議，所以我們得知SPI會(huì)先通過(guò)registry協(xié)議找到RegistryPotocol然后執(zhí)行export()，然后再執(zhí)行DubboPotocol中的export()。

現(xiàn)在我們進(jìn)入RegistryPotocol中的export()方法。

上述操作主要是講export轉(zhuǎn)化為exporter，獲取注冊(cè)中心的相關(guān)配置，如果需要注冊(cè)則向注冊(cè)中心進(jìn)行注冊(cè)，并且在ProviderConsumerRegTable中記錄服務(wù)提供者信息，進(jìn)入源碼中，我們發(fā)現(xiàn)實(shí)質(zhì)就是往一個(gè)ConcurrentHashMap中塞入invoker，key是服務(wù)接口全類名，value是一個(gè)set，set中存儲(chǔ)包裝過(guò)的invoker。

然后進(jìn)入doLocalExport方法內(nèi)部

箭頭指向的方法最終會(huì)調(diào)用DubboProtocol中的export()

需要?jiǎng)?chuàng)建server

上述代碼中，主要就是根據(jù)URL創(chuàng)建出key，然后將key和invoker存入exporterMap中關(guān)聯(lián)起來(lái)，如果是初次服務(wù)暴露則需要?jiǎng)?chuàng)建監(jiān)聽(tīng)服務(wù)器，默認(rèn)是NettyServer，并且初始化各種Handler，比如心跳檢測(cè)，解碼等。

至此服務(wù)暴露