您好,登錄后才能下訂單哦!
小編給大家分享一下java開發(fā)分布式服務(wù)框架Dubbo暴露服務(wù)的示例分析,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!
在進(jìn)行服務(wù)暴露機(jī)制的分析之前,必須談?wù)勈裁词?code>URL,在Dubbo服務(wù)暴露過程中URL
是無處不在的,貫穿了整個過程。
一般情況下,URL
指的是統(tǒng)一資源定位符,標(biāo)準(zhǔn)格式如下:
protocol://host:port/path?key1=value1&key2=value2
Dubbo就是用這種URL
的方式來作為約定的參數(shù)類型,服務(wù)之間也是用URL
來進(jìn)行交互。
Dubbo用URL
作為配置總線,貫穿整個源碼體系。
URL
的具體參數(shù)如下:
protocol
:dubbo中的各種協(xié)議,如:dubbo、http、thrift
host/port
:主機(jī)/端口號
path
:接口名稱
parameters
:參數(shù)鍵值對
大體流程分為三個步驟:
檢測配置,有些配置為空值會有默認(rèn)值自動填充并自動組裝為URL
暴露服務(wù),包括暴露到本地和遠(yuǎn)程的服務(wù)注冊為服務(wù)到服務(wù)注冊中心
先來到ServiceBean
中
可以看到這個類實(shí)現(xiàn)了ApplicationListener<ContextRefreshedEvent>
,這樣就會在Spring IOC容器刷新之后調(diào)用onApplicationEvent
方法,這個方法中做的就是服務(wù)暴露。
從if
判斷條件中,我們可以看到如果配置中沒有設(shè)置延遲暴露、并且沒有暴露過、并且支持暴露的情況下就會執(zhí)行this.export()
,最終會調(diào)用父類ServiceConfig
中的export
方法。
上述方法中主要就是進(jìn)行配置檢查,然后進(jìn)入this.doExport()
進(jìn)行服務(wù)暴露,這個方法前面的部分都是一些配置檢查,重點(diǎn)放在最后的this.doExportUrls()
。
從上述源碼中可以看到Dubbo是支持多注冊中心的,并且支持多種協(xié)議,一個服務(wù)如果有多個協(xié)議那么都需要暴露。this.loadRegistries()
是根據(jù)配置組裝成注冊中心相關(guān)的URL,如下:
registry://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?application=user-service-provider-one&dubbo=2.6.2&pid=29056®istry=zookeeper×tamp=1632309180780
接下來進(jìn)入this.doExportUrlsFor1Protocol()
,
構(gòu)建完成之后的URL如下圖所示:
使用的是dubbo協(xié)議,接下來要做的就是根據(jù)URL來進(jìn)行服務(wù)暴露
進(jìn)入exportLocal()
看一下,這個方法做的事就是進(jìn)行本地暴露,使用的是injvm
協(xié)議,這個方法中對URL進(jìn)行修改,將協(xié)議改為injvm
。
此處的protocol.export()
是標(biāo)注了@Adaptive
注解的,設(shè)計自適應(yīng)拓展,調(diào)用該方法之后會生成代理類,代理類通過URL中的參數(shù)得知所使用的協(xié)議,然后通過Dubbo SPI機(jī)制實(shí)現(xiàn)拓展,選擇對應(yīng)的實(shí)現(xiàn)類進(jìn)行export()
方法,此處的方法會選擇InjvmProtocol
中的export()
進(jìn)行暴露。
經(jīng)過轉(zhuǎn)化后得到的export
如下所示:
如圖所示,具體實(shí)現(xiàn)類被層層包裝。
為什么要封裝成invoker呢?
封裝成invoker是為了屏蔽調(diào)用的細(xì)節(jié),統(tǒng)一暴露出一個可執(zhí)行體,使得調(diào)用者調(diào)用時變得便捷簡易。
為什么要使用本地暴露呢?
因?yàn)榭赡艽嬖诒镜夭煌?wù)之間相互調(diào)用的情況,因此本地暴露后,內(nèi)部可以直接進(jìn)行調(diào)用,而省去了不必要的網(wǎng)絡(luò)通信。
此處引用一下博主敖丙的文章中的本地暴露流程圖:
此時本地暴露已經(jīng)完成了,現(xiàn)在開始遠(yuǎn)程暴露。
流程與本地暴露相似,都需要先封裝為invoker然后再進(jìn)一步生成exporter,以下是registryURL.addParameterAndEncoded()
方法將URL進(jìn)行拼接后的結(jié)果:
可以看到先是走registry
協(xié)議,然后參數(shù)中有一個export=dubbo://
,此時會走dubbo
協(xié)議,所以我們得知SPI會先通過registry
協(xié)議找到RegistryPotocol
然后執(zhí)行export()
,然后再執(zhí)行DubboPotocol
中的export()
。
現(xiàn)在我們進(jìn)入RegistryPotocol
中的export()
方法。
上述操作主要是講export轉(zhuǎn)化為exporter,獲取注冊中心的相關(guān)配置,如果需要注冊則向注冊中心進(jìn)行注冊,并且在ProviderConsumerRegTable
中記錄服務(wù)提供者信息,進(jìn)入源碼中,我們發(fā)現(xiàn)實(shí)質(zhì)就是往一個ConcurrentHashMap
中塞入invoker,key是服務(wù)接口全類名,value是一個set,set中存儲包裝過的invoker。
然后進(jìn)入 doLocalExport
方法內(nèi)部
箭頭指向的方法最終會調(diào)用DubboProtocol
中的export()
需要創(chuàng)建server
上述代碼中,主要就是根據(jù)URL創(chuàng)建出key,然后將key和invoker存入exporterMap中關(guān)聯(lián)起來,如果是初次服務(wù)暴露則需要創(chuàng)建監(jiān)聽服務(wù)器,默認(rèn)是NettyServer,并且初始化各種Handler,比如心跳檢測,解碼等。
至此服務(wù)暴露流程結(jié)束。
此處引用博主敖丙的文章中的本地暴露流程圖:
看完了這篇文章,相信你對“java開發(fā)分布式服務(wù)框架Dubbo暴露服務(wù)的示例分析”有了一定的了解,如果想了解更多相關(guān)知識,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。