java開發分布式服務框架Dubbo暴露服務的示例分析

小編給大家分享一下java開發分布式服務框架Dubbo暴露服務的示例分析，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

Dubbo服務暴露機制

前言

在進行服務暴露機制的分析之前，必須談談什么是URL，在Dubbo服務暴露過程中URL是無處不在的，貫穿了整個過程。

一般情況下，URL指的是統一資源定位符，標準格式如下：

protocol://host:port/path?key1=value1&key2=value2

Dubbo就是用這種URL的方式來作為約定的參數類型，服務之間也是用URL來進行交互。

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

URL的具體參數如下：

protocol：dubbo中的各種協議，如：dubbo、http、thrift

host/port：主機/端口號

path：接口名稱

parameters：參數鍵值對

服務暴露流程

大體流程分為三個步驟：

檢測配置，有些配置為空值會有默認值自動填充并自動組裝為URL暴露服務，包括暴露到本地和遠程的服務注冊為服務到服務注冊中心

源碼解析

先來到ServiceBean中

可以看到這個類實現了ApplicationListener<ContextRefreshedEvent>，這樣就會在Spring IOC容器刷新之后調用onApplicationEvent方法，這個方法中做的就是服務暴露。

從if判斷條件中，我們可以看到如果配置中沒有設置延遲暴露、并且沒有暴露過、并且支持暴露的情況下就會執行this.export()，最終會調用父類ServiceConfig中的export方法。

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

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

registry://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?application=user-service-provider-one&dubbo=2.6.2&pid=29056&registry=zookeeper&timestamp=1632309180780

接下來進入this.doExportUrlsFor1Protocol()，

構建完成之后的URL如下圖所示：

使用的是dubbo協議，接下來要做的就是根據URL來進行服務暴露

本地暴露

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

此處的protocol.export()是標注了@Adaptive注解的，設計自適應拓展，調用該方法之后會生成代理類，代理類通過URL中的參數得知所使用的協議，然后通過Dubbo SPI機制實現拓展，選擇對應的實現類進行export()方法，此處的方法會選擇InjvmProtocol中的export()進行暴露。

經過轉化后得到的export如下所示：

如圖所示，具體實現類被層層包裝。

為什么要封裝成invoker呢？

封裝成invoker是為了屏蔽調用的細節，統一暴露出一個可執行體，使得調用者調用時變得便捷簡易。

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

因為可能存在本地不同服務之間相互調用的情況，因此本地暴露后，內部可以直接進行調用，而省去了不必要的網絡通信。

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

遠程暴露

此時本地暴露已經完成了，現在開始遠程暴露。

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

可以看到先是走registry協議，然后參數中有一個export=dubbo://，此時會走dubbo協議，所以我們得知SPI會先通過registry協議找到RegistryPotocol然后執行export()，然后再執行DubboPotocol中的export()。

現在我們進入RegistryPotocol中的export()方法。

上述操作主要是講export轉化為exporter，獲取注冊中心的相關配置，如果需要注冊則向注冊中心進行注冊，并且在ProviderConsumerRegTable中記錄服務提供者信息，進入源碼中，我們發現實質就是往一個ConcurrentHashMap中塞入invoker，key是服務接口全類名，value是一個set，set中存儲包裝過的invoker。

然后進入 doLocalExport 方法內部

箭頭指向的方法最終會調用DubboProtocol中的export()

需要創建server

上述代碼中，主要就是根據URL創建出key，然后將key和invoker存入exporterMap中關聯起來，如果是初次服務暴露則需要創建監聽服務器，默認是NettyServer，并且初始化各種Handler，比如心跳檢測，解碼等。

至此服務暴露流程結束。

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

看完了這篇文章，相信你對“java開發分布式服務框架Dubbo暴露服務的示例分析”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！