快捷導(dǎo)航

SpringCloud中的Eureka注冊中心詳細(xì)解讀

更新時間：2023年11月09日 09:03:35 作者：愛敲代碼的小楚

這篇文章主要介紹了SpringCloud中的Eureka注冊中心詳細(xì)解讀,想要參與服務(wù)注冊發(fā)現(xiàn)的實(shí)例首先需要向Eureka服務(wù)器注冊信息,注冊在第一次心跳發(fā)生時提交,需要的朋友可以參考下

Eureka原理

概念：實(shí)現(xiàn)服務(wù)治理，即管理所有的服務(wù)信息和狀態(tài)。 eureka分為兩部分，Server端和Client端 Client端向Server端定時發(fā)送心跳包。 Server端根據(jù)Clinet端的心跳包，來維護(hù)一個服務(wù)列表（判斷服務(wù)是否在線）。

client功能
1. 注冊：每個微服務(wù)啟動時，將自己的網(wǎng)絡(luò)地址等信息注冊到注冊中心，注冊中心會存儲（內(nèi)存中）這些信息。
2. 獲取服務(wù)注冊表：服務(wù)消費(fèi)者從注冊中心，查詢服務(wù)提供者的網(wǎng)絡(luò)地址，并使用該地址調(diào)用服務(wù)提供者，為了避免每次都查注冊表信息，所以client會定時去server拉取注冊表信息到緩存到client本地。
3. 心跳：各個微服務(wù)與注冊中心通過某種機(jī)制（心跳）通信，若注冊中心長時間和服務(wù)間沒有通信，就會注銷該實(shí)例。
4. 調(diào)用：實(shí)際的服務(wù)調(diào)用，通過注冊表，解析服務(wù)名和具體地址的對應(yīng)關(guān)系，找到具體服務(wù)的地址，進(jìn)行實(shí)際調(diào)用。
server注冊中心功能
1. 服務(wù)注冊表：記錄各個微服務(wù)信息，例如服務(wù)名稱，ip，端口等。注冊表提供查詢API（查詢可用的微服務(wù)實(shí)例）和管理API（用于服務(wù)的注冊和注銷）。
2. 服務(wù)注冊與發(fā)現(xiàn)：注冊：將微服務(wù)信息注冊到注冊中心。發(fā)現(xiàn)：查詢可用微服務(wù)列表及其網(wǎng)絡(luò)地址。
3. 服務(wù)檢查：定時檢測已注冊的服務(wù)，如發(fā)現(xiàn)某實(shí)例長時間無法訪問，就從注冊表中移除。

1.服務(wù)注冊

想要參與服務(wù)注冊發(fā)現(xiàn)的實(shí)例首先需要向Eureka服務(wù)器注冊信息注冊在第一次心跳發(fā)生時提交

Renew:續(xù)租，心跳。Eureka客戶需要每30秒發(fā)送一次心跳來續(xù)租
Fetch Registry：Eureka客戶端拉取注冊表信息，并緩存在本地?？梢?0秒更新一次。
Cancel：Eureka客戶端在關(guān)閉時向Eureka服務(wù)器發(fā)送取消請求。這將從服務(wù)器的實(shí)例注冊表中刪除實(shí)例，從而有效地將實(shí)例從通信量中取出。

客戶端配置選項(xiàng)

#續(xù)約發(fā)送間隔默認(rèn)30秒，心跳間隔
eureka.instance.lease-renewal-interval-in-seconds=5
#表示eureka client間隔多久去拉取服務(wù)注冊信息，默認(rèn)為30秒，對于api-gateway，如果要迅速獲取服務(wù)注冊狀態(tài)，可以縮小該值，比如5秒
eureka.client.registry-fetch-interval-seconds=5
# 續(xù)約到期時間（默認(rèn)90秒）
eureka.instance.lease-expiration-duration-in-seconds=60

服務(wù)器端配置選項(xiàng)

#關(guān)閉自我保護(hù)模式
eureka.server.enable-self-preservation=false
#失效服務(wù)間隔
eureka.server.eviction-interval-timer-in-ms=3000

2.Eureka高可用

高可用：可以通過運(yùn)行多個Eureka server實(shí)例并相互注冊的方式實(shí)現(xiàn)。Server節(jié)點(diǎn)之間會彼此增量地同步信息，從而確保節(jié)點(diǎn)中數(shù)據(jù)一致。

寫一個地址也行（但是server得互相注冊），EurekaServer會自動同步，但為了避免極端情況，還是寫多個。集群中各個server會從其他server同步注冊表信息。

#client配置
eureka: 
  client:
    #設(shè)置服務(wù)注冊中心的URL
    service-url:                      
      defaultZone: http://root:root@eureka-7801:7801/eureka/,http://root:root@eureka-7802:7802/eureka/

3.自我保護(hù)機(jī)制

默認(rèn)情況下，Eureka Server在一定時間內(nèi)（90s），沒有接收到某個微服務(wù)心跳，就會將該服務(wù)注銷。但是當(dāng)網(wǎng)絡(luò)出現(xiàn)問題、故障，微服務(wù)之間無法通信，就不應(yīng)該直接注銷了。所以Eureka Server的自我保護(hù)機(jī)制，是在短時間內(nèi)出現(xiàn)大量客戶端丟失，就不會從注冊表中注銷。
思想：寧可保留健康的和不健康的，也不盲目注銷任何健康的服務(wù)。
關(guān)閉自我保護(hù)

eureka:
  server: 
    enable-self-preservation: false

4.Eureka 健康檢查

server和client通過心跳保持服務(wù)列表，而只有狀態(tài)為UP的服務(wù)才能被訪問?？磂ureka界面中的status。比如心跳一直正常，服務(wù)一直UP，但是此服務(wù)DB連不上了，無法正常提供服務(wù)(有的時候業(yè)務(wù)出現(xiàn)問題catch住異常，也可以手動傳輸DOWN讓服務(wù)下線)。此時，我們需要將微服務(wù)的健康狀態(tài)也同步到server。只需要啟動eureka的健康檢查就行。這樣微服務(wù)就會將自己的健康狀態(tài)同步到eureka。配置如下即可。 開啟手動控制 在client端配置：將自己真正的健康狀態(tài)傳播到server。

eureka:
  client:
    healthcheck:
      enabled: true

Client端配置Actuator

	<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-actuator</artifactId>
	</dependency>

改變健康狀態(tài)的Service

@Service
public class HealthStatusService implements HealthIndicator{

	private Boolean status = true;

	public void setStatus(Boolean status) {
		this.status  = status;
	}

	@Override
	public Health health() {
		// TODO Auto-generated method stub
		if(status)
		return new Health.Builder().up().build();
		return new Health.Builder().down().build();
	}

	public String getStatus() {
		// TODO Auto-generated method stub
		return this.status.toString();
	}

5.Eureka監(jiān)聽事件

EurekaInstanceCanceledEvent 服務(wù)下線事件
EurekaInstanceRegisteredEvent 服務(wù)注冊事件
EurekaInstanceRenewedEvent 服務(wù)續(xù)約事件
EurekaRegistryAvailableEvent 注冊中心可用事件
EurekaServerStartedEvent 注冊中心啟動

import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceCanceledEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class CustomEvent {
	
	@EventListener
	public void listen(EurekaInstanceCanceledEvent e) {
		System.out.println(e.getServerId()+"下線事件");
	}
}

將Eureka Client停止后打印：
api-listen-order:30.136.133.9:port下線事件