Eureka的服務提供者 服務消費者和註冊中心詳解

2021-08-21 10:46:49 字數 2643 閱讀 8433

一 架構圖

二 服務提供者

1 服務註冊

「服務提供者」在啟動的時候會通過rest請求的方式將自己註冊到eureka server上,同時帶上自身服務的一些元資料資訊。eureka server接收到這個rest請求之後,將元資料資訊儲存在乙個雙層結構map中,其中第一層的key是服務名,第二層的key是具體服務的例項名。

在服務註冊時候,需要確認一下eureka.client.register-with-eureka=true引數是否正確,該值預設為true。若設定為false將不會啟動註冊操作。

2 服務同步

如架構圖所示,這裡的兩個微服務提供者分別註冊到兩個不同的服務註冊中心上,也就是說,它們的資訊分別被兩個服務註冊中心所維護。此時由於服務註冊中心之間因互相註冊為服務,當服務提供者傳送註冊請求到乙個服務註冊中心時,它會將該請求**給集群中相連的註冊中心,從而實現註冊中心之間的服務同步。通過服務同步,兩個服務提供者的服務資訊就可以通過這兩台服務註冊中心中的任意一台獲取,

3 服務續約

在註冊完服務之後,服務提供者會維護乙個心跳用來持續告訴eureka server:「我還活著」,以防止eureka server的「剔除任務」將該服務例項從服務列表中排除出去,我們稱該操作為服務續約(renew)。

關於服務續約有兩個重要屬性,我們可以關注並根據需要來進行調整:

eureka.client.registry-fetch-interval-seconds=30

eureka.instance.lease-expiration-duration-in-seconds=90

eureka.client.registry-fetch-interval-seconds引數用來定義服務續約任務的呼叫間隔時間,預設為30秒。

eureka.instance.lease-expiration-duration-in-seconds引數用於定義服務失效時間,預設為90秒。

三 服務消費者

1 獲取服務

到此,在服務註冊中已經註冊了乙個服務,並且該服務有兩個例項。當我們啟動服務消費者的時候,它會傳送乙個rest請求給服務註冊中心,來獲取上面註冊的服務清單。為了效能考慮,eureka server會維護乙份唯讀的服務清單來返回給客戶端,同時該快取清單會每隔30秒更新一次。

獲取服務是服務消費者的基礎,所以必須確保eureka.client.fetch-registry=true引數沒有被修改為false,該值預設為true。eureka.client.registry-fetch-interval-seconds=30表示間隔多久去拉取服務註冊資訊,該引數預設值為30,單位為秒。

2 服務呼叫

服務消費者在獲取服務清單後,通過服務名可以獲得具體提供服務的例項名和該例項的元資料資訊。因為有了這些服務例項詳細資訊,所以客戶端可以根據自己的需要決定具體呼叫哪個例項,在ribbon中預設採用輪詢的方式進行呼叫,從而實現客戶端的負載均衡。

對於訪問例項的選擇,eureka中有region和zone的概念,乙個region中可以包含多個zone,每個服務客戶端需要註冊到乙個zone中,所以每個客戶端對於乙個region和乙個zone。在進行服務呼叫的時候,優先訪問同處乙個zone中服務提供方,若訪問不到,就訪問其他的zone。

3 服務下線

在系統執行過程中必然會面臨關閉或重啟服務的某個例項的情況,在服務關閉期間,我們自然不希望客戶端會繼續呼叫關閉了的例項。所以客戶端程式中,當服務例項進行正常的關閉操作時,它會觸發乙個服務下線的rest請求給eureka server,告訴服務註冊中心:「我要下線了」。服務端在接收到請求之後,將該服務狀態設定為(down),並把該下線事件傳播出去。

四 註冊中心

1 失效剔除

有些時候,我們的服務例項並不一定會正常下線,可能由於記憶體溢位,網路故障等原因使得服務不能正常工作,而服務註冊中心並未收到「服務下線」的請求。為了從服務列表中將這些無法提供服務的例項剔除,eureka server在啟動時候會建立乙個定時任務,預設每隔一段時間(預設60秒)將當前清單中超時(預設為90秒)沒有續約的服務剔除出去。

2 自我保護

當我們在本地除錯基於eureka的程式的時候,基本都會碰到乙個問題,在服務註冊中心的資訊面板中出現紅色警告資訊。

實際上,該警告就是觸發了eureka server的自我保護機制。服務註冊到eureka server之後,會維護乙個心跳連線,告訴eureka server自己還活著。eureka server在執行期間,會統計心跳失敗比例在15分鐘之內是否低於85%,如果出現低於的情況(在單機除錯的時候很容易滿足,實際在生產環境上通常是由於網路不穩定導致),eureka server會將當前的例項註冊資訊包含起來,讓這些例項不會過期,盡可能包含這些註冊資訊。但是,在這段保護期內例項若出現了問題,那麼客戶端很容易拿到實際已經不存在的服務例項,會出現呼叫失敗的情況,所有客戶端必須要有容錯機制,比如可以使用請求重試。斷路器等機制。

由於本地除錯很容易觸發註冊中心的保護機制,這會使得註冊中心維護的服務例項不那麼準確。所以,在本地進行開發的時候,可以使用eureka.server.enable-self-preservation=false引數來關閉保護機制,以確保註冊中心可以將不可用的例項正確剔除。

Eureka服務提供者和消費者

建立專案eureka client user service,作為服務提供者註冊到euraka中。org.springframework.boot groupid spring boot starter web artifactid dependency org.springframework.cl...

Eureka客戶端 服務提供者

1 pom.xml org.springframework.cloud spring cloud starter netflix eureka client org.springframework.boot spring boot starter actuator spring name eurek...

服務提供者 order

本節課我們來實現服務提供者 orde,order 為系統提供訂單相關服務,包括新增訂單 查詢訂單 刪除訂單 處理訂單,具體實現如下所示。1.在父工程下建立乙個 module,命名為 order,pom.xml 新增相關依賴,order 需要訪問資料庫,所以整合 mybatis 相關依賴,配置檔案從 ...