作者 | 波哥
審校 | 重樓
出品 | 51CTO技術棧（微信號：blog51cto）
在微服務架構(gòu)中，服務發(fā)現(xiàn)和注冊是確保各個微服務之間通信和協(xié)作的核心組件?.NETflix Eureka作為一款開源的服務發(fā)現(xiàn)和注冊工具，在現(xiàn)代分布式系統(tǒng)中扮演著重要角色。本文將從代碼層面深入探討Netflix Eureka的底層實現(xiàn)原理，為讀者詳細呈現(xiàn)其內(nèi)部運行機制。
Netflix Eureka由Eureka服務器和Eureka客戶端兩部分構(gòu)成。它們協(xié)同工作，構(gòu)建了一個完整的服務發(fā)現(xiàn)和注冊系統(tǒng)。
一、Eureka服務器
Eureka服務器負責存儲和管理所有已注冊的服務實例信息，保證服務發(fā)現(xiàn)的準確性。Eureka服務器的核心是InstanceRegistry、LeaseManager和SelfPreservationFilter。下面結(jié)合代碼詳細介紹下這幾個核心組件。
1.InstanceRegistry（實例注冊表）
實例注冊表負責存儲所有已注冊的服務實例信息，包括它們的元數(shù)據(jù)，如實例ID、主機名、端口等。從代碼層面來看，InstanceRegistry是一個包含了實例信息的內(nèi)存數(shù)據(jù)結(jié)構(gòu)，通常使用ConcurrentHashMap來存儲，當一個新的服務實例注冊時，InstanceRegistry 的 register 方法被調(diào)用，將該實例信息添加到注冊表中；當一個服務實例不再可用，需要從Eureka服務器取消注冊時，InstanceRegistry 的 cancel 方法被調(diào)用，從注冊表中移除該實例信息。具體的功能包括：
注冊服務實例：register 方法負責將服務實例注冊到注冊表。
取消注冊服務實例：cancel 方法用于從注冊表中移除不再可用的實例。
獲取服務實例信息：getInstancesById 方法用于獲取特定服務的所有實例信息。
2.LeaseManager（租約管理器）
租約管理器負責管理實例的租約，租約是Eureka服務器中的一個重要概念，用于確保實例的健康狀態(tài)。在代碼層面，LeaseManager維護了一個租約的集合，并提供了操作租約的方法，主要包括：
注冊實例并創(chuàng)建租約：register 方法負責為新注冊的實例創(chuàng)建租約。
續(xù)約租約：renew 方法用于更新租約的到期時間，延長租約的有效期。
移除租約：cancel 方法負責在實例取消注冊時移除租約。
在服務實例注冊時，LeaseManager 的 register 方法被調(diào)用，創(chuàng)建一個新的租約，并將其添加到租約管理器中。在服務實例定期發(fā)送心跳續(xù)約請求時，LeaseManager 的 renew 方法被調(diào)用，更新租約的到期時間，確保租約的有效性。當一個服務實例取消注冊時，LeaseManager 的 cancel 方法被調(diào)用，從租約管理器中移除相應的租約。
下面是具體方法內(nèi)容：
圖片
3.SelfPreservationFilter（自我保護過濾器）
自我保護機制是Netflix Eureka服務器（服務端）中的一項重要功能。它旨在確保在網(wǎng)絡抖動等異常情況下，Eureka服務器不會過早地剔除正常運行的服務實例，從而保持服務的可用性和穩(wěn)定性。
當Eureka服務器開啟自我保護機制時，它會監(jiān)測心跳續(xù)約失敗的實例數(shù)量。如果在某個時間段內(nèi)，心跳續(xù)約失敗的實例數(shù)量超過了預定的閾值，Eureka服務器將進入自我保護模式。在自我保護模式下，Eureka服務器不會剔除任何正常運行的實例，以免影響整個系統(tǒng)的穩(wěn)定性。這是為了避免在網(wǎng)絡抖動等情況下，誤判正常實例失效。
需要注意的是，雖然自我保護機制保護了Eureka服務器上的服務注冊表，但在自我保護模式下，Eureka服務器將不再從已注冊的實例中移除長時間未續(xù)約的實例，這可能會導致注冊表中存在已經(jīng)下線或失效的實例。因此，自我保護機制只是應對短期網(wǎng)絡問題的臨時解決方案，當問題解決后，Eureka服務器會自動退出自我保護模式，重新恢復正常的剔除機制。
在代碼層面，SelfPreservationFilter定期計算心跳續(xù)約失敗的比例，根據(jù)配置啟動或關閉自我保護模式。SelfPreservationFilter 是一個在后臺運行的線程，定期檢查注冊表中的實例健康狀態(tài)。它會周期性地計算心跳續(xù)約失敗的比例，當心跳續(xù)約失敗比例超過一定閾值時，會啟動自我保護模式，以防止錯誤地移除正常的服務實例。如果心跳續(xù)約失敗比例降低到一定程度，會關閉自我保護模式。具體功能包括：
- 統(tǒng)計心跳續(xù)約失敗比例：calculateThresholdBreachCount 方法統(tǒng)計失敗的心跳續(xù)約比例。
- 啟動/關閉自我保護模式：disable 和 enable 方法分別用于啟動和關閉自我保護模式。
圖片
圖片
二、Eureka客戶端
在微服務應用啟動時，Eureka客戶端將自身的實例信息注冊到Eureka服務器，并從服務器獲取其他服務實例信息，實現(xiàn)服務的發(fā)現(xiàn)和負載均衡。它包括DiscoveryClient（服務發(fā)現(xiàn)客戶端）、InstanceInfo（實例信息）、EurekaHttpClient（Eureka HTTP客戶端）三個核心組件，下面詳細介紹每個組件：
1.DiscoveryClient（服務發(fā)現(xiàn)客戶端）
從Eureka服務器獲取服務實例信息，并緩存在本地。它提供了getInstances、getServices等方法，支持負載均衡和服務發(fā)現(xiàn)。
圖片
其中getInstances 方法用于在服務調(diào)用前獲取特定服務的所有實例信息，實現(xiàn)動態(tài)的服務發(fā)現(xiàn)。getNextServerFromEureka 方法在服務調(diào)用時被調(diào)用，實現(xiàn)負載均衡邏輯，選擇要調(diào)用的服務實例；而refreshRegistry 方法定期刷新注冊表信息，以確保實例信息的最新性。
2.InstanceInfo（實例信息）
在應用啟動時，Eureka客戶端創(chuàng)建InstanceInfo對象，包含實例的元數(shù)據(jù)。它在服務實例啟動時創(chuàng)建并初始化，存儲了該實例的基本信息，如實例ID、主機名、端口和狀態(tài)。它通過HTTP請求將元數(shù)據(jù)注冊到Eureka服務器。
圖片
3.EurekaHttpClient（Eureka HTTP客戶端）
它用于客戶端與Eureka服務器的通信，發(fā)送注冊、續(xù)約、取消注冊等HTTP請求，獲取注冊表信息。
圖片
圖片
其中：
- register 方法在服務實例啟動時調(diào)用，向Eureka服務器注冊實例信息。
- renew 方法定期發(fā)送心跳續(xù)約請求，保持實例的健康狀態(tài)。
- cancel 方法在服務實例關閉或取消注冊時調(diào)用，向Eureka服務器發(fā)送取消注冊請求。
- getInstances 方法在服務發(fā)現(xiàn)過程中被調(diào)用，向Eureka服務器請求特定服務的實例信息。
- refreshRegistry 方法周期性地刷新注冊表信息，以保持信息的準確性。
三、流程梳理
下面筆者大概梳理了下幾個主要流程：
1、服務注冊流程
- Eureka客戶端創(chuàng)建InstanceInfo對象，包含實例元數(shù)據(jù)。
- 客戶端通過HTTP請求將InstanceInfo注冊到Eureka服務器的InstanceRegistry。
- LeaseManager創(chuàng)建租約，管理續(xù)約周期和到期時間。
2、心跳續(xù)約流程
- Eureka客戶端定期發(fā)送心跳續(xù)約請求，維持租約有效。
- LeaseManager更新租約到期時間，確保租約不會過期。
- Eureka服務器根據(jù)心跳續(xù)約來監(jiān)測實例的健康狀態(tài)。
3、服務發(fā)現(xiàn)與負載均衡流程
- Eureka客戶端通過DiscoveryClient獲取其他服務實例信息。
- 客戶端根據(jù)負載均衡策略選擇一個實例。
- 客戶端發(fā)起HTTP請求，實現(xiàn)服務調(diào)用和負載均衡。
四、實例演示
現(xiàn)在，讓我們通過實際演示來了解如何使用Eureka服務端和客戶端。
1、Eureka服務端演示：
創(chuàng)建Eureka Server：首先，創(chuàng)建一個Spring Boot項目，并添加Eureka Server依賴。
配置文件：在Application.yml中，進行基本的配置，如端口和Eureka Server配置。
圖片
啟動類：創(chuàng)建啟動類，并添加@EnableEurekaServer注解。
圖片
運行應用：啟動Eureka Server應用，訪問http://localhost:8761，將看到Eureka的控制臺。
2、Eureka客戶端演示：
- 創(chuàng)建Eureka Client：創(chuàng)建另一個Spring Boot項目，并添加Eureka Client依賴。
- 配置文件：在application.yml中，配置Eureka Client信息。
圖片
創(chuàng)建Controller：創(chuàng)建一個簡單的Controller用于演示服務調(diào)用。
圖片
啟動類：創(chuàng)建啟動類，并添加@EnableDiscoveryClient注解。
圖片
- 運行應用：啟動Eureka Client應用，訪問http://localhost:8761，將看到Eureka的控制臺，顯示有一個已注冊的客戶端。
- 服務調(diào)用：在瀏覽器中訪問http://localhost:8080/hello，將會調(diào)用Eureka Client的Controller方法，并得到響應。
Netflix Eureka在微服務架構(gòu)中扮演著重要角色，支持服務發(fā)現(xiàn)和注冊。Eureka的底層實現(xiàn)涵蓋了服務注冊、心跳續(xù)約、自我保護機制、服務發(fā)現(xiàn)和負載均衡等關鍵功能。通過深入代碼層面的分析，我們可以更清晰地理解這些功能是如何在底層實現(xiàn)的。
作者介紹：
波哥，互聯(lián)行業(yè)從業(yè)10余年，先后擔任項目總監(jiān)及架構(gòu)師。目前專攻技術，喜歡研究技術原理。技術全面，主攻JAVA，精通JVM底層機制及Spring全家桶底層框架原理，熟練掌握當前主流的中間件、服務網(wǎng)格等技術原理。
