SpringColud Eureka的服務(wù)注冊與發(fā)現(xiàn)
一、Eureka簡介
本文中所有代碼都會上傳到git上，請放心瀏覽項目git地址：https://github.com/839022478/Spring-Cloud
在傳統(tǒng)應(yīng)用中，組件之間的調(diào)用，通過有規(guī)范的約束的接口來實現(xiàn)，從而實現(xiàn)不同模塊間良好的協(xié)作。但是被拆分成微服務(wù)后，每個微服務(wù)實例的網(wǎng)絡(luò)地址都可能動態(tài)變化，數(shù)量也會變化，使得原來硬編碼的地址失去了作用。需要一個中心化的組件來進行服務(wù)的登記和管理，為了解決上面的問題，于是出現(xiàn)了服務(wù)治理，就是管理所有的服務(wù)信息和狀態(tài)，也就是我們所說的注冊中心
1.1 注冊中心
- 比如我們?nèi)プ龌疖嚮蛘咂?，需要去買票乘車，只看我們有沒有票(有沒有服務(wù))，有就去買票(獲取注冊列表)，然后乘車(調(diào)用)，不用關(guān)心到底有多少車在運行
流程圖：
使用注冊中心，我們不需要關(guān)心有多少提供方，只管去調(diào)用就可以了，那么注冊中心有哪些呢?
注冊中心：Eureka，Nacos，Consul，Zookeeper
本文中講解的是比較火熱的Spring Cloud微服務(wù)下的Eureka，Eureka是Netflix開發(fā)的服務(wù)發(fā)現(xiàn)框架，是一個RESTful風(fēng)格的服務(wù)，是一個用于服務(wù)發(fā)現(xiàn)和注冊的基礎(chǔ)組件，是搭建Spring Cloud微服務(wù)的前提之一，它屏蔽了Server和client的交互細節(jié)，使得開發(fā)者將精力放到業(yè)務(wù)上。
服務(wù)注冊與發(fā)現(xiàn)主要包括兩個部分：服務(wù)端(EurekaServer)和客戶端(EurekaClient)
服務(wù)端(Eureka Server)： 一個公共服務(wù)，為Client提供服務(wù)注冊和發(fā)現(xiàn)的功能，維護注冊到自身的Client的相關(guān)信息，同時提供接口給Client獲取注冊表中其他服務(wù)的信息，使得動態(tài)變化的Client能夠進行服務(wù)間的相互調(diào)用。
客戶端(Eureka Client)： Client將自己的服務(wù)信息通過一定的方式登記到Server上，并在正常范圍內(nèi)維護自己信息一致性，方便其他服務(wù)發(fā)現(xiàn)自己，同時可以通過Server獲取到自己依賴的其他服務(wù)信息，完成服務(wù)調(diào)用，還內(nèi)置了負載均衡器，用來進行基本的負載均衡
Eureka GIt官網(wǎng)：https://github.com/Netflix/Eureka
1.2 服務(wù)注冊與發(fā)現(xiàn)
服務(wù)注冊與發(fā)現(xiàn)關(guān)系圖：
1.3 client功能和server功能
1.3.1 client功能
- 注冊：每個微服務(wù)啟動時，將自己的網(wǎng)絡(luò)地址等信息注冊到注冊中心，注冊中心會存儲(內(nèi)存中)這些信息。
- 獲取服務(wù)注冊表：服務(wù)消費者從注冊中心，查詢服務(wù)提供者的網(wǎng)絡(luò)地址，并使用該地址調(diào)用服務(wù)提供者，為了避免每次都查注冊表信息，所以client會定時去server拉取注冊表信息到緩存到client本地。
- 心跳：各個微服務(wù)與注冊中心通過某種機制(心跳)通信，若注冊中心長時間和服務(wù)間沒有通信，就會注銷該實例。
- 調(diào)用：實際的服務(wù)調(diào)用，通過注冊表，解析服務(wù)名和具體地址的對應(yīng)關(guān)系，找到具體服務(wù)的地址，進行實際調(diào)用。
1.3.2 server注冊中心功能
- 服務(wù)注冊表：記錄各個微服務(wù)信息，例如服務(wù)名稱，ip，端口等。注冊表提供 查詢API(查詢可用的微服務(wù)實例)和管理API(用于服務(wù)的注冊和注銷)。
- 服務(wù)注冊與發(fā)現(xiàn)：注冊：將微服務(wù)信息注冊到注冊中心。發(fā)現(xiàn)：查詢可用微服務(wù)列表及其網(wǎng)絡(luò)地址。
- 服務(wù)檢查：定時檢測已注冊的服務(wù)，如發(fā)現(xiàn)某實例長時間無法訪問，就從注冊表中移除。
二、Eureka單節(jié)點搭建
2.1 pom.xml
在有的教程中，會引入 spring-boot-starter-web，這個依賴其實不用，因為 spring-cloud-starter-netflix-eureka-server的依賴已經(jīng)包含了它，在pom依賴進去，就可以了
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
- </dependency>
2.2 application.yml
- server:
- port: 8500
- eureka:
- client:
- #是否將自己注冊到Eureka Server,默認為true，由于當前就是server，故而設(shè)置成false，表明該服務(wù)不會向eureka注冊自己的信息
- register-with-eureka: false
- #是否從eureka server獲取注冊信息，由于單節(jié)點，不需要同步其他節(jié)點數(shù)據(jù)，用false
- fetch-registry: false
- #設(shè)置服務(wù)注冊中心的URL，用于client和server端交流
- service-url:
- defaultZone: http://localhost:8080/eureka/
2.3 服務(wù)端啟動類
啟動類上添加此注解標識該服務(wù)為配置中心@EnableEurekaServer
- import org.springframework.boot.SpringApplication;
- import org.springframework.boot.autoconfigure.SpringBootApplication;
- import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
- @EnableEurekaServer
- @SpringBootApplication
- public class EurekaServerApplication {
- public static void main(String[] args) {
- SpringApplication.run(EurekaServerApplication.class, args);
- }
- }
2.4 啟動
我們啟動 EurekaDemoApplication，然后在瀏覽器中輸入地址 http://localhost:8500/，就可以啟動我們的 Eureka 了，我們來看下效果，出現(xiàn)了這個畫面，就說明我們已經(jīng)成功啟動~，只是此時我們的服務(wù)中是還沒有客戶端進行注冊
三、服務(wù)注冊
注意：在客戶端pom里面我們需要加上 spring-boot-starter-web，否則服務(wù)是無法正常啟動的
3.1 pom.xml
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-web</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
- </dependency>
3.2 application.yml
- #注冊中心
- eureka:
- client:
- #設(shè)置服務(wù)注冊中心的URL
- service-url:
- defaultZone: http://localhost:8500/eureka/
- #服務(wù)名
- instance:
- appname: mxn
3.3 客戶端啟動類
在客戶端啟動類中我們需要加上 @EnableDiscoveryClient
- import org.springframework.boot.SpringApplication;
- import org.springframework.boot.autoconfigure.SpringBootApplication;
- import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
- @EnableDiscoveryClient
- @SpringBootApplication
- public class EurekaClientApplication {
- public static void main(String[] args) {
- SpringApplication.run(EurekaClientApplication.class, args);
- }
- }
3.4 查看效果
工程啟動后，刷新 http://localhost:8500/頁面，我們可以發(fā)現(xiàn)服務(wù)注冊成功了
并且我們可以在idea日志打印中看到
- DiscoveryClient_MXN/DESKTOP-5BQ3UK8-registration status:204
說明就是注冊成功了 Eureka Server與Eureka Client之間的聯(lián)系主要通過心跳的方式實現(xiàn)。心跳(Heartbeat)即Eureka Client定時向Eureka Server匯報本服務(wù)實例當前的狀態(tài)，維護本服務(wù)實例在注冊表中租約的有效性。
Eureka Client將定時從Eureka Server中拉取注冊表中的信息，并將這些信息緩存到本地，用于服務(wù)發(fā)現(xiàn)
四、Eureka 端點
官網(wǎng)地址：https://github.com/Netflix/eureka/wiki/Eureka-REST-operations
Eureka服務(wù)器還提供了一個端點 (eureka/apps/{applicaitonName})可以查看所注冊的服務(wù)詳細信息 。applicaitonName就是微服務(wù)的名稱，比如這里我們訪問 http://localhost:8500/eureka/apps/mxn
五、Eureka 原理
5.1 本質(zhì)
存儲了每個客戶端的注冊信息。EurekaClient從EurekaServer同步獲取服務(wù)注冊列表。通過一定的規(guī)則選擇一個服務(wù)進行調(diào)用
5.2 Eureka架構(gòu)圖
- 服務(wù)提供者： 是一個eureka client，向Eureka Server注冊和更新自己的信息，同時能從Eureka Server注冊表中獲取到其他服務(wù)的信息。
- 服務(wù)注冊中心： 提供服務(wù)注冊和發(fā)現(xiàn)的功能。每個Eureka Cient向Eureka Server注冊自己的信息，也可以通過Eureka Server獲取到其他服務(wù)的信息達到發(fā)現(xiàn)和調(diào)用其他服務(wù)的目的。
- 服務(wù)消費者： 是一個eureka client，通過Eureka Server獲取注冊到其上其他服務(wù)的信息，從而根據(jù)信息找到所需的服務(wù)發(fā)起遠程調(diào)用。
- 同步復(fù)制： Eureka Server之間注冊表信息的同步復(fù)制，使Eureka Server集群中不同注冊表中服務(wù)實例信息保持一致。
- 遠程調(diào)用： 服務(wù)客戶端之間的遠程調(diào)用。
- 注冊： Client端向Server端注冊自身的元數(shù)據(jù)以供服務(wù)發(fā)現(xiàn)。
- 續(xù)約： 通過發(fā)送心跳到Server以維持和更新注冊表中服務(wù)實例元數(shù)據(jù)的有效性。當在一定時長內(nèi)，Server沒有收到Client的心跳信息，將默認服務(wù)下線，會把服務(wù)實例的信息從注冊表中刪除。
- 下線： Client在關(guān)閉時主動向Server注銷服務(wù)實例元數(shù)據(jù)，這時Client的服務(wù)實例數(shù)據(jù)將從Server的注冊表中刪除。
- 獲取注冊表： Client向Server請求注冊表信息，用于服務(wù)發(fā)現(xiàn)，從而發(fā)起服務(wù)間遠程調(diào)用。
5.3 Eureka自我保護
有時候我們會看到這樣的提示信息：
- EMERGENCY!EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.
這是因為默認情況下，Eureka Server在一定時間內(nèi)，沒有接收到某個微服務(wù)心跳，會將某個微服務(wù)注銷(90S)。但是當網(wǎng)絡(luò)故障時，微服務(wù)與Server之間無法正常通信，上述行為就非常危險，因為微服務(wù)正常，不應(yīng)該注銷，它的指導(dǎo)思想就是 寧可保留健康的和不健康的，也不盲目注銷任何健康的服務(wù)我們也可以通過命令去關(guān)閉自我保護的功能：
- eureka:
- server:
- enable-self-preservation: false
那么自我保護是如何觸發(fā)的呢?
- 自我保護機制的觸發(fā)條件是：
- 當每分鐘心跳次數(shù)( renewsLastMin) 小于 numberOfRenewsPerMinThreshold時，
- 并且開啟自動保護模式開關(guān)( eureka.server.enable-self-preservation=true) 時
- 觸發(fā)自我保護機制，不再自動過期租約 上面我們所有的小于 numberOfRenewsPerMinThreshold，到底是怎么計算的呢，
- 我們在eureka源碼中可以得知：
- numberOfRenewsPerMinThreshold = expectedNumberOfRenewsPerMin * 續(xù)租百分比（默認為0.85）
- expectedNumberOfRenewsPerMin = 當前注冊的應(yīng)用實例數(shù) x 2
- 當前注冊的應(yīng)用實例數(shù) x 2 是因為，在默認情況下，注冊的應(yīng)用實例每半分鐘續(xù)租一次，那么一分鐘心跳兩次，因此 x 2
例如：我們有10個服務(wù)，期望每分鐘續(xù)約數(shù)：10 * 2=20，期望閾值：20*0.85=17，當少于17時，就會觸發(fā)自我保護機制
5.4 健康檢查
由于server和client通過心跳保持 服務(wù)狀態(tài)，而只有狀態(tài)為UP的服務(wù)才能被訪問?？磂ureka界面中的status。
比如心跳一直正常，服務(wù)一直UP，但是此服務(wù)DB(數(shù)據(jù)庫)連不上了，無法正常提供服務(wù)。
此時，我們需要將 微服務(wù)的健康狀態(tài)也同步到server。只需要啟動eureka的健康檢查就行。這樣微服務(wù)就會將自己的健康狀態(tài)同步到eureka。配置如下即可。
在client端配置：將自己的健康狀態(tài)傳播到server。
- eureka:
- client:
- healthcheck:
- enabled: true
5.5 Eureka監(jiān)聽事件
- import com.netflix.appinfo.InstanceInfo;
- import org.springframework.cloud.netflix.eureka.server.event.*;
- import org.springframework.context.event.EventListener;
- import org.springframework.stereotype.Component;
- import java.time.LocalDateTime;
- @Component
- public class CustomEvent {
- @EventListener
- public void listen(EurekaInstanceCanceledEvent event ) {
- System.out.println(LocalDateTime.now()+"服務(wù)下線事件:"+event.getAppName()+"---"+event.getServerId());
- //發(fā)釘釘
- }
- @EventListener
- public void listen(EurekaInstanceRegisteredEvent event) {
- InstanceInfo instanceInfo = event.getInstanceInfo();
- System.out.println(LocalDateTime.now()+"服務(wù)上線事件:"+instanceInfo.getAppName()+"---"+instanceInfo.getInstanceId());
- }
- @EventListener
- public void listen(EurekaInstanceRenewedEvent event) {
- System.out.println(LocalDateTime.now()+"服務(wù)續(xù)約/心跳上報事件:"+event.getAppName()+"---"+event.getServerId());
- }
- @EventListener
- public void listen(EurekaRegistryAvailableEvent event) {
- System.out.println(LocalDateTime.now()+"注冊中心可用事件");
- }
- @EventListener
- public void listen(EurekaServerStartedEvent event) {
- System.out.println(LocalDateTime.now()+"注冊中心啟動事件");
- }
- }
5.6 Renew: 服務(wù)續(xù)約
Eureka Client 會每隔 30 秒發(fā)送一次心跳來續(xù)約。通過續(xù)約來告知 Eureka Server 該 Eureka Client 運行正常，沒有出現(xiàn)問題。默認情況下，如果 Eureka Server 在 90 秒內(nèi)沒有收到 Eureka Client 的續(xù)約，Server 端會將實例從其注冊表中刪除，此時間可配置，一般情況不建議更改。
5.6 服務(wù)剔除
如果Eureka Client在注冊后，既沒有續(xù)約，也沒有下線(服務(wù)崩潰或者網(wǎng)絡(luò)異常等原因)，那么服務(wù)的狀態(tài)就處于不可知的狀態(tài)，不能保證能夠從該服務(wù)實例中獲取到回饋，所以需要服務(wù)剔除此方法定時清理這些不穩(wěn)定的服務(wù)，該方法會批量將注冊表中所有過期租約剔除，剔除是定時任務(wù)，默認60秒執(zhí)行一次。延時60秒，間隔60秒
剔除的限制：1.自我保護期間不清除。2.分批次清除。
六、Eureka缺陷
由于集群間的同步復(fù)制是通過HTTP的方式進行，基于網(wǎng)絡(luò)的不可靠性，集群中的Eureka Server間的注冊表信息難免存在不同步的時間節(jié)點，不滿足CAP中的C(數(shù)據(jù)一致性)
七、總結(jié)
中間我們講解了eureka的節(jié)點搭建，以及原理，對于現(xiàn)在很火熱的微服務(wù)，我們對Eureka是非常有必要進行了解的。
