扒一扒Nacos、OpenFeign、Ribbon、loadbalancer組件協調工作的原理

来源:https://www.cnblogs.com/zzyang/archive/2023/04/11/17305903.html
-Advertisement-
Play Games

大家好,我是三友~~ 前幾天有個大兄弟問了我一個問題,註冊中心要集成SpringCloud,想實現SpringCloud的負載均衡,需要實現哪些介面和規範。 既然這個兄弟問到我了,而我又剛好知道,這不得好好寫一篇文章來回答這個問題,雖然在後面的聊天中我已經回答過了。 接下來本文就以探究一下Nacos ...


大家好,我是三友~~

前幾天有個大兄弟問了我一個問題,註冊中心要集成SpringCloud,想實現SpringCloud的負載均衡,需要實現哪些介面和規範。

既然這個兄弟問到我了,而我又剛好知道,這不得好好寫一篇文章來回答這個問題,雖然在後面的聊天中我已經回答過了。

接下來本文就以探究一下Nacos、OpenFeign、Ribbon、loadbalancer等組件協調工作的原理的方式,來講一講應該需要是實現哪些介面了。

再多說一句,本文並沒有詳細地深入剖析各個組件的源碼,如果有感興趣的兄弟可以從微信公眾號三友的java日記後臺菜單欄中的文章分類中查看我之前寫的關於Nacos、OpenFeign、Ribbon源碼剖析的文章。

Nacos

先從Nacos講起。

Nacos是什麼,官網中有這麼一段話

這一段話說的直白點就是Nacos是一個註冊中心和配置中心!

在Nacos中有客戶端和服務端的這個概念

  • 服務端需要單獨部署,用來保存服務實例數據的
  • 客戶端就是用來跟服務端通信的SDK,支持不同語言

當需要向Nacos服務端註冊或者獲取服務實例數據的時候,只需要通過Nacos提供的客戶端SDK就可以了,就像下麵這樣:

引入依賴

<dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>1.4.4</version>
</dependency>

示例代碼

Properties properties = new Properties();
properties.setProperty("serverAddr""localhost");
properties.setProperty("namespace""8848");

NamingService naming = NamingFactory.createNamingService(properties);

//服務註冊,註冊一個order服務,order服務的ip是192.168.2.100,埠8080
naming.registerInstance("order""192.168.2.100"8080);

//服務發現,獲取所有的order服務實例
List<Instance> instanceList = naming.selectInstances("order"true);

當服務註冊到Nacos服務端的時候,在服務端內部會有一個集合去存儲服務的信息

這個集合在註冊中心界中有個響亮的名字,服務註冊表

如何進行服務自動註冊?

用過SpringCloud的小伙伴肯定知道,在項目啟動的時候服務能夠自動註冊到服務註冊中心,並不需要手動寫上面那段代碼,那麼服務自動註冊是如何實現的呢?

服務自動註冊三板斧

SpringCloud本身提供了一套服務自動註冊的機制,或者說是約束,其實就是三個介面,只要註冊中心實現這些介面,就能夠在服務啟動時自動註冊到註冊中心,而這三個介面我稱為服務自動註冊三板斧。

服務實例數據封裝--Registration

Registration是SpringCloud提供的一個介面,繼承了ServiceInstance介面

Registration
Registration
ServiceInstance
ServiceInstance

從ServiceInstance的介面定義可以看出,這是一個服務實例數據的封裝,比如這個服務的ip是多少,埠號是多少。

所以Registration就是當前服務實例數據封裝,封裝了當前服務的所在的機器ip和埠號等信息。

Nacos既然要整合SpringCloud,自然而然也實現了這個介面

NacosRegistration
NacosRegistration

這樣當前服務需要被註冊到註冊中心的信息就封裝好了。

服務註冊--ServiceRegistry

ServiceRegistry也是個介面,泛型就是上面提到的服務實例數據封裝的介面

ServiceRegistry
ServiceRegistry

這個介面的作用就是把上面封裝的當前服務的數據Registration註冊通過register方法註冊到註冊中心中。

Nacos也實現了這個介面。

NacosServiceRegistry
NacosServiceRegistry

並且核心的註冊方法的實現代碼跟前面的demo幾乎一樣

服務自動註冊--AutoServiceRegistration
AutoServiceRegistration
AutoServiceRegistration

AutoServiceRegistration是一個標記介面,所以本身沒有實際的意義,僅僅代表了自動註冊的意思。

AutoServiceRegistration有個抽象實現AbstractAutoServiceRegistration

AbstractAutoServiceRegistration是個抽象類
AbstractAutoServiceRegistration是個抽象類

AbstractAutoServiceRegistration實現了ApplicationListener,監聽了WebServerInitializedEvent事件。

WebServerInitializedEvent這個事件是SpringBoot在項目啟動時,當諸如tomcat這類Web服務啟動之後就會發佈,註意,只有在Web環境才會發佈這個事件。

ServletWebServerInitializedEvent繼承自WebServerInitializedEvent。

所以一旦當SpringBoot項目啟動,tomcat等web伺服器啟動成功之後,就會觸發AbstractAutoServiceRegistration監聽器的執行。

最終就會調用ServiceRegistry註冊Registration,實現服務自動註冊

Nacos自然而然也繼承了AbstractAutoServiceRegistration

NacosAutoServiceRegistration
NacosAutoServiceRegistration

對於Nacos而言,就將當前的服務註冊的ip和埠等信息,就註冊到了Nacos服務註冊中心。

所以整個註冊流程就可以用這麼一張圖概括

當然,不僅僅是Nacos是這麼實現的,常見的比如Eureka,Zookeeper等註冊中心在整合SpringCloud都是實現上面的三板斧。

Ribbon

講完了SpringCloud環境底下是如何自動註冊服務到註冊中心的,下麵來講一講Ribbon。

我們都知道,Ribbon是負載均衡組件,他的作用就是從眾多的服務實例中根據一定的演算法選擇一個服務實例。

但是有個疑問,服務實例的數據都在註冊中心,Ribbon是怎麼知道的呢???

答案其實很簡單,那就是需要註冊中心去主動適配Ribbon,只要註冊中心去適配了Ribbon,那麼Ribbon自然而然就知道服務實例的數據了。

Ribbon提供了一個獲取服務實例的介面,叫ServerList

ServerList
ServerList

介面中提供了兩個方法,這兩個方法在眾多的實現中實際是一樣的,並沒有區別。

當Ribbon通過ServerList獲取到服務實例數據之後,會基於這些數據來做負載均衡的。

Nacos自然而然也實現了ServerList介面,為Ribbon提供Nacos註冊中心中的服務數據。

NacosServerList
NacosServerList

這樣,Ribbon就能獲取到了Nacos服務註冊中心的數據。

同樣地,除了Nacos之外,Eureka、Zookeeper等註冊中心也都實現了這個介面。

到這,其實就明白了Ribbon是如何知道註冊中心的數據了,需要註冊中心來適配。

在這裡插個個人的看法,其實我覺得Ribbon在適配SpringCloud時對獲取服務實例這塊支持封裝的不太好。

因為SpringCloud本身就是一套約束、規範,只要遵守這套規範,那麼就可以實現各個組件的替換,這就是為什麼換個註冊中心只需要換個依賴,改個配置文件就行。

而Ribbon本身是一個具體的負載均衡組件,註冊中心要想整合SpringCloud,還得需要單獨去適配Ribbon,有點違背了SpringCloud約束的意義。

就類似mybatis一樣,mybatis依靠jdbc,但是mybatis根本不關心哪個資料庫實現的jdbc。

真正好的做法是Ribbon去適配SpringCloud時,用SpringCloud提供的api去獲取服務實例,這樣不同的註冊中心只需要適配這個api,無需單獨適配Ribbon了。

而SpringCloud實際上是提供了這麼一個獲取服務實例的api,DiscoveryClient

DiscoveryClient
DiscoveryClient

通過DiscoveryClient就能夠獲取到服務實例,當然也是需要不同註冊中心的適配。

隨著Ribbon等組件停止維護之後,SpringCloud官方自己也搞了一個負載均衡組件loadbalancer,用來平替Ribbon。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
    <version>2.2.5.RELEASE</version>
</dependency>

這個組件底層在獲取服務實例的時候,就是使用的DiscoveryClient。

所以對於loadbalancer這個負載均衡組價來說,註冊中心只需要實現DiscoveryClient之後就自然而然適配了loadbalancer

OpenFeign

OpenFeign是一個rpc框架,當我們需要調用遠程服務的時候,只需要聲明個介面就可以遠程調用了,就像下麵這樣

聽上去很神奇,其實本質上就是後面會為介面創建一個動態代理對象,解析類上,方法上的註解。

當調用方法的時候,會根據方法上面的參數拼接一個http請求地址,這個地址的格式是這樣的http://服務名/介面路徑

比如,上面的例子,當調用saveOrder方法的時候,按照這種規律拼出的地址就是這樣的 http://order/order,第一個order是服務名,第二個order是PostMapping註解上面的。

但是由於只知道需要調用服務的服務名,不知道服務的ip和埠,還是無法調用遠程服務,這咋辦呢?

這時就輪到Ribbon登場了,因為Ribbon這個大兄弟知道服務實例的數據。

於是乎,OpenFeign就對Ribbon說,兄弟,你不是可以從註冊中心獲取到order服務所有服務實例數據麽,幫我從這些服務實例數據中找一個給我。

於是Ribbon就會從註冊中心獲取到的服務實例中根據負載均衡策略選擇一個服務實例返回給OpenFeign。

OpenFeign拿到了服務實例,此時就獲取到了服務所在的ip和埠,接下來就會重新構建請求路徑,將路徑中的服務名替換成ip和埠,代碼如下

reconstructURIWithServer
reconstructURIWithServer
  • Server就是服務實例信息的封裝
  • orignal就是原始的url,就是上面提到的,http://order/order

假設獲取到的orde服務所在的ip和埠分別是192.168.2.1008080,最終重構後的路徑就是http://192.168.2.100:8080/order,之後OpenFeign就可以發送http請求了。

至於前面提到的loadbalancer,其實也是一樣的,他也會根據負載均衡演算法,從DiscoveryClient獲取到的服務實例中選擇一個服務實例給OpenFeign,後面也會根據服務實例重構url,再發送http請求。

loadbalancer組件重構url代碼
loadbalancer組件重構url代碼

總結

到這,就把Nacos、OpenFeign、Ribbon、loadbalancer等組件協調工作的原理講完了,其實就是各個組件會預留一些擴展介面,這也是很多開源框架都會幹的事,當第三方框架去適配的,只要實現這些介面就可以了。

最後畫一張圖來總結一下上述組價的工作的原理。

最後再小小地說一句,Nacos、OpenFeign、Ribbon源碼剖析的文章,可以從微信公眾號三友的java日記後臺菜單欄中的文章分類中查看。

往期熱門文章推薦

RocketMQ重覆消費的7種原因

如何去閱讀源碼,我總結了18條心法

如何實現延遲任務,我總結了11種方法

如何寫出漂亮代碼,我總結了45個小技巧

三萬字盤點Spring/Boot的那些常用擴展點

兩萬字盤點那些被玩爛了的設計模式

掃碼或者搜索關註公眾號 三友的java日記 ,及時乾貨不錯過,公眾號致力於通過畫圖加上通俗易懂的語言講解技術,讓技術更加容易學習,回覆 面試 即可獲得一套面試真題。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Kafka 環境搭建 kafka 安裝、配置、啟動、測試說明: 1. 安裝:直接官網下載安裝包,解壓到指定位置即可(kafka 依賴的 Zookeeper 在文件中已包含) 下載地址:https://kafka.apache.org/downloads 示例版本:kafka_2.13-2.8.0.t ...
  • SpringCloud OpenFeign-服務調用 1.OpenFeign介紹 https://github.com/spring-cloud/spring-cloud-openfeign OpenFeign是一個聲明式WebService客戶端,使用OpenFeign讓編寫Web Service ...
  • 說明 使用 VLD 記憶體泄漏檢測工具輔助開發時整理的學習筆記。本篇介紹使用 VLD 時的註意事項。同系列文章目錄可見 《記憶體泄漏檢測工具》目錄 1. 官網文檔 可以在 Using-Visual-Leak-Detector 官方文檔里看到如何使用 VLD。 2. 註意事項 以 v2.5.1 版本為例, ...
  • 線程池ThreadPoolExecutor ThreadPoolExecutor 繼承結構 繼承結構如圖所示:ThreadPoolExecutor <- AbstractExecutorService <- ExecutorService <- Executor public class Threa ...
  • Map ​ 哈希表是一種巧妙並且實用的數據結構。它是一個無序的key/value對的集合,其中所有的key 都是不同的,然後通過給定的key可以在常數時間複雜度內檢索、更新或刪除對應的value。 ​ 在Go語言中,一個map就是一個哈希表的引用,map類型可以寫為map[K]V,其中K和V分別 對 ...
  • MongoDB索引優化 作者: 博學谷狂野架構師 GitHub:GitHub地址 (有我精心準備的130本電子書PDF) 只分享乾貨、不吹水,讓我們一起加油!😄 索引簡介 索引通常能夠極大的提高查詢的效率,如果沒有索引,MongoDB在讀取數據時必須掃描集合中的每個文件並選取那些符合查詢條件的記錄 ...
  • 面向對象封裝特點之一就是通過實現好的方法來訪問,限制對數據的不合理訪問,把對象狀態私有化,僅供類的內部進行操作 下方示例,Test方法的number屬性類實例的時候傳遞1,number是一個公開屬性,可以在外部任意修改、訪問,沒有對屬性進行進行約束 class Test: def __init__( ...
  • 當前主流編程語言的垃圾收集器基本上都是依靠可達性分析演算法來判定對象是否存活的,可達性分析演算法理論上要求全過程都基於一個能保障一致性的快照中才能夠進行分析,這意味著必須全程凍結用戶線程的運行。 在根節點枚舉這個步驟中,由於 GC Roots 相比起整個 Java 堆中全部的對象畢竟還算是極少數,且在各 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...