一、Eureka簡(jiǎn)介

本文中所有代碼都會(huì)上傳到git上，請(qǐng)放心瀏覽 項(xiàng)目git地址：https://github.com/839022478/Spring-Cloud

在傳統(tǒng)應(yīng)用中，組件之間的調(diào)用，通過(guò)有規(guī)范的約束的接口來(lái)實(shí)現(xiàn)，從而實(shí)現(xiàn)不同模塊間良好的協(xié)作。但是被拆分成微服務(wù)后，每個(gè)微服務(wù)實(shí)例的網(wǎng)絡(luò)地址都可能動(dòng)態(tài)變化，數(shù)量也會(huì)變化，使得原來(lái)硬編碼的地址失去了作用。需要一個(gè)中心化的組件來(lái)進(jìn)行服務(wù)的登記和管理，為了解決上面的問(wèn)題，于是出現(xiàn)了服務(wù)治理，就是管理所有的服務(wù)信息和狀態(tài)，也就是我們所說(shuō)的注冊(cè)中心

1.1 注冊(cè)中心

比如我們?nèi)プ龌疖嚮蛘咂?#xff0c;需要去買票乘車，只看我們有沒(méi)有票(有沒(méi)有服務(wù))，有就去買票(獲取注冊(cè)列表)，然后乘車(調(diào)用)，不用關(guān)心到底有多少車在運(yùn)行

流程圖：使用注冊(cè)中心，我們不需要關(guān)心有多少提供方，只管去調(diào)用就可以了，那么注冊(cè)中心有哪些呢？

注冊(cè)中心：Eureka，Nacos，Consul，Zookeeper

本文中講解的是比較火熱的Spring Cloud微服務(wù)下的Eureka，Eureka是Netflix開發(fā)的服務(wù)發(fā)現(xiàn)框架，是一個(gè)RESTful風(fēng)格的服務(wù)，是一個(gè)用于服務(wù)發(fā)現(xiàn)和注冊(cè)的基礎(chǔ)組件，是搭建Spring Cloud微服務(wù)的前提之一，它屏蔽了Server和client的交互細(xì)節(jié)，使得開發(fā)者將精力放到業(yè)務(wù)上。

服務(wù)注冊(cè)與發(fā)現(xiàn)主要包括兩個(gè)部分：服務(wù)端(EurekaServer)和客戶端(EurekaClient)

• 服務(wù)端(Eureka Server)： 一個(gè)公共服務(wù)，為Client提供服務(wù)注冊(cè)和發(fā)現(xiàn)的功能，維護(hù)注冊(cè)到自身的Client的相關(guān)信息，同時(shí)提供接口給Client獲取注冊(cè)表中其他服務(wù)的信息，使得動(dòng)態(tài)變化的Client能夠進(jìn)行服務(wù)間的相互調(diào)用。

• 客戶端(Eureka Client)： Client將自己的服務(wù)信息通過(guò)一定的方式登記到Server上，并在正常范圍內(nèi)維護(hù)自己信息一致性，方便其他服務(wù)發(fā)現(xiàn)自己，同時(shí)可以通過(guò)Server獲取到自己依賴的其他服務(wù)信息，完成服務(wù)調(diào)用，還內(nèi)置了負(fù)載均衡器，用來(lái)進(jìn)行基本的負(fù)載均衡

Eureka GIt官網(wǎng)：https://github.com/Netflix/Eureka

1.3 服務(wù)注冊(cè)與發(fā)現(xiàn)

服務(wù)注冊(cè)與發(fā)現(xiàn)關(guān)系圖：

1.2 client功能和server功能

1.2.1 client功能

注冊(cè)：每個(gè)微服務(wù)啟動(dòng)時(shí)，將自己的網(wǎng)絡(luò)地址等信息注冊(cè)到注冊(cè)中心，注冊(cè)中心會(huì)存儲(chǔ)(內(nèi)存中)這些信息。

獲取服務(wù)注冊(cè)表：服務(wù)消費(fèi)者從注冊(cè)中心，查詢服務(wù)提供者的網(wǎng)絡(luò)地址，并使用該地址調(diào)用服務(wù)提供者，為了避免每次都查注冊(cè)表信息，所以client會(huì)定時(shí)去server拉取注冊(cè)表信息到緩存到client本地。

心跳：各個(gè)微服務(wù)與注冊(cè)中心通過(guò)某種機(jī)制(心跳)通信，若注冊(cè)中心長(zhǎng)時(shí)間和服務(wù)間沒(méi)有通信，就會(huì)注銷該實(shí)例。

調(diào)用：實(shí)際的服務(wù)調(diào)用，通過(guò)注冊(cè)表，解析服務(wù)名和具體地址的對(duì)應(yīng)關(guān)系，找到具體服務(wù)的地址，進(jìn)行實(shí)際調(diào)用。

1.2.2 server注冊(cè)中心功能

服務(wù)注冊(cè)表：記錄各個(gè)微服務(wù)信息，例如服務(wù)名稱，ip，端口等。注冊(cè)表提供 查詢API(查詢可用的微服務(wù)實(shí)例)和管理API(用于服務(wù)的注冊(cè)和注銷)。

服務(wù)注冊(cè)與發(fā)現(xiàn)：注冊(cè)：將微服務(wù)信息注冊(cè)到注冊(cè)中心。發(fā)現(xiàn)：查詢可用微服務(wù)列表及其網(wǎng)絡(luò)地址。

服務(wù)檢查：定時(shí)檢測(cè)已注冊(cè)的服務(wù)，如發(fā)現(xiàn)某實(shí)例長(zhǎng)時(shí)間無(wú)法訪問(wèn)，就從注冊(cè)表中移除。

二、Eureka單節(jié)點(diǎn)搭建

2.1 pom.xml

在有的教程中，會(huì)引入 spring-boot-starter-web，這個(gè)依賴其實(shí)不用，因?yàn)?spring-cloud-starter-netflix-eureka-server的依賴已經(jīng)包含了它，在pom依賴進(jìn)去，就可以了

<dependency> <groupId>org.springframework.cloudgroupId> <artifactId>spring-cloud-starter-netflix-eureka-serverartifactId>dependency>

2.2 application.yml

server: port: 8500eureka: client: #是否將自己注冊(cè)到Eureka Server,默認(rèn)為true，由于當(dāng)前就是server，故而設(shè)置成false，表明該服務(wù)不會(huì)向eureka注冊(cè)自己的信息 register-with-eureka: false #是否從eureka server獲取注冊(cè)信息，由于單節(jié)點(diǎn)，不需要同步其他節(jié)點(diǎn)數(shù)據(jù)，用false fetch-registry: false #設(shè)置服務(wù)注冊(cè)中心的URL，用于client和server端交流 service-url: defaultZone: http://localhost:8080/eureka/

2.3 服務(wù)端啟動(dòng)類

啟動(dòng)類上添加此注解標(biāo)識(shí)該服務(wù)為配置中心@EnableEurekaServer

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@EnableEurekaServer@SpringBootApplicationpublic class EurekaServerApplication { public static void main(String[] args) { SpringApplication.run(EurekaServerApplication.class, args);????}}

2.4 啟動(dòng)

我們啟動(dòng) EurekaDemoApplication，然后在瀏覽器中輸入地址 http://localhost:8500/，就可以啟動(dòng)我們的 Eureka 了，我們來(lái)看下效果，出現(xiàn)了這個(gè)畫面，就說(shuō)明我們已經(jīng)成功啟動(dòng)~，只是此時(shí)我們的服務(wù)中是還沒(méi)有客戶端進(jìn)行注冊(cè)

三、服務(wù)注冊(cè)

注意：在客戶端pom里面我們需要加上 spring-boot-starter-web，否則服務(wù)是無(wú)法正常啟動(dòng)的

3.1 pom.xml

<dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-webartifactId> dependency> <dependency> <groupId>org.springframework.cloudgroupId> <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId> dependency>

3.2 application.yml

#注冊(cè)中心eureka: client: #設(shè)置服務(wù)注冊(cè)中心的URL service-url: defaultZone: http://localhost:8500/eureka/ #服務(wù)名 instance: appname: mxn

3.3 客戶端啟動(dòng)類

在客戶端啟動(dòng)類中我們需要加上 @EnableDiscoveryClient

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@EnableDiscoveryClient@SpringBootApplicationpublic class EurekaClientApplication { public static void main(String[] args) { SpringApplication.run(EurekaClientApplication.class, args); }}

3.4 查看效果

工程啟動(dòng)后，刷新 http://localhost:8500/頁(yè)面，我們可以發(fā)現(xiàn)服務(wù)注冊(cè)成功了

并且我們可以在idea日志打印中看到

DiscoveryClient_MXN/DESKTOP-5BQ3UK8-registration status:204

說(shuō)明就是注冊(cè)成功了 Eureka Server與Eureka Client之間的聯(lián)系主要通過(guò)心跳的方式實(shí)現(xiàn)。心跳(Heartbeat)即Eureka Client定時(shí)向Eureka Server匯報(bào)本服務(wù)實(shí)例當(dāng)前的狀態(tài)，維護(hù)本服務(wù)實(shí)例在注冊(cè)表中租約的有效性。

Eureka Client將定時(shí)從Eureka Server中拉取注冊(cè)表中的信息，并將這些信息緩存到本地，用于服務(wù)發(fā)現(xiàn)

四、Eureka 端點(diǎn)

官網(wǎng)地址：https://github.com/Netflix/eureka/wiki/Eureka-REST-operations

Eureka服務(wù)器還提供了一個(gè)端點(diǎn) (eureka/apps/{applicaitonName})可以查看所注冊(cè)的服務(wù)詳細(xì)信息 。applicaitonName就是微服務(wù)的名稱，比如這里我們?cè)L問(wèn) http://localhost:8500/eureka/apps/mxn

五、Eureka 原理

5.1 本質(zhì)

存儲(chǔ)了每個(gè)客戶端的注冊(cè)信息。EurekaClient從EurekaServer同步獲取服務(wù)注冊(cè)列表。通過(guò)一定的規(guī)則選擇一個(gè)服務(wù)進(jìn)行調(diào)用

5.2 Eureka架構(gòu)圖

• 服務(wù)提供者：?是一個(gè)eureka client，向Eureka Server注冊(cè)和更新自己的信息，同時(shí)能從Eureka Server注冊(cè)表中獲取到其他服務(wù)的信息。

• 服務(wù)注冊(cè)中心：?提供服務(wù)注冊(cè)和發(fā)現(xiàn)的功能。每個(gè)Eureka Cient向Eureka Server注冊(cè)自己的信息，也可以通過(guò)Eureka Server獲取到其他服務(wù)的信息達(dá)到發(fā)現(xiàn)和調(diào)用其他服務(wù)的目的。

• 服務(wù)消費(fèi)者：?是一個(gè)eureka client，通過(guò)Eureka Server獲取注冊(cè)到其上其他服務(wù)的信息，從而根據(jù)信息找到所需的服務(wù)發(fā)起遠(yuǎn)程調(diào)用。

• 同步復(fù)制：?Eureka Server之間注冊(cè)表信息的同步復(fù)制，使Eureka Server集群中不同注冊(cè)表中服務(wù)實(shí)例信息保持一致。

• 遠(yuǎn)程調(diào)用：?服務(wù)客戶端之間的遠(yuǎn)程調(diào)用。

• 注冊(cè)：?Client端向Server端注冊(cè)自身的元數(shù)據(jù)以供服務(wù)發(fā)現(xiàn)。

• 續(xù)約：?通過(guò)發(fā)送心跳到Server以維持和更新注冊(cè)表中服務(wù)實(shí)例元數(shù)據(jù)的有效性。當(dāng)在一定時(shí)長(zhǎng)內(nèi)，Server沒(méi)有收到Client的心跳信息，將默認(rèn)服務(wù)下線，會(huì)把服務(wù)實(shí)例的信息從注冊(cè)表中刪除。

• 下線：?Client在關(guān)閉時(shí)主動(dòng)向Server注銷服務(wù)實(shí)例元數(shù)據(jù)，這時(shí)Client的服務(wù)實(shí)例數(shù)據(jù)將從Server的注冊(cè)表中刪除。

• 獲取注冊(cè)表：?Client向Server請(qǐng)求注冊(cè)表信息，用于服務(wù)發(fā)現(xiàn)，從而發(fā)起服務(wù)間遠(yuǎn)程調(diào)用。

5.3 Eureka自我保護(hù)

有時(shí)候我們會(huì)看到這樣的提示信息：

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.

這是因?yàn)槟J(rèn)情況下，Eureka Server在一定時(shí)間內(nèi)，沒(méi)有接收到某個(gè)微服務(wù)心跳，會(huì)將某個(gè)微服務(wù)注銷(90S)。但是當(dāng)網(wǎng)絡(luò)故障時(shí)，微服務(wù)與Server之間無(wú)法正常通信，上述行為就非常危險(xiǎn)，因?yàn)槲⒎?wù)正常，不應(yīng)該注銷，它的指導(dǎo)思想就是 寧可保留健康的和不健康的，也不盲目注銷任何健康的服務(wù)我們也可以通過(guò)命令去關(guān)閉自我保護(hù)的功能：

eureka: server: enable-self-preservation: false

那么自我保護(hù)是如何觸發(fā)的呢？

自我保護(hù)機(jī)制的觸發(fā)條件是：當(dāng)每分鐘心跳次數(shù)( renewsLastMin) 小于 numberOfRenewsPerMinThreshold時(shí)，并且開啟自動(dòng)保護(hù)模式開關(guān)( eureka.server.enable-self-preservation=true) 時(shí)觸發(fā)自我保護(hù)機(jī)制，不再自動(dòng)過(guò)期租約 上面我們所有的小于 numberOfRenewsPerMinThreshold，到底是怎么計(jì)算的呢，我們?cè)趀ureka源碼中可以得知：numberOfRenewsPerMinThreshold = expectedNumberOfRenewsPerMin * 續(xù)租百分比(默認(rèn)為0.85)expectedNumberOfRenewsPerMin = 當(dāng)前注冊(cè)的應(yīng)用實(shí)例數(shù) x 2當(dāng)前注冊(cè)的應(yīng)用實(shí)例數(shù) x 2 是因?yàn)?#xff0c;在默認(rèn)情況下，注冊(cè)的應(yīng)用實(shí)例每半分鐘續(xù)租一次，那么一分鐘心跳兩次，因此 x 2

例如：我們有10個(gè)服務(wù)，期望每分鐘續(xù)約數(shù)：10 * 2=20，期望閾值：20*0.85=17，當(dāng)少于17時(shí)，就會(huì)觸發(fā)自我保護(hù)機(jī)制

5.4 健康檢查

由于server和client通過(guò)心跳保持 服務(wù)狀態(tài)，而只有狀態(tài)為UP的服務(wù)才能被訪問(wèn)。看eureka界面中的status。

比如心跳一直正常，服務(wù)一直UP，但是此服務(wù)DB(數(shù)據(jù)庫(kù))連不上了，無(wú)法正常提供服務(wù)。

此時(shí)，我們需要將 微服務(wù)的健康狀態(tài)也同步到server。只需要啟動(dòng)eureka的健康檢查就行。這樣微服務(wù)就會(huì)將自己的健康狀態(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;@Componentpublic 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ù)約/心跳上報(bào)事件:"+event.getAppName()+"---"+event.getServerId()); } @EventListener public void listen(EurekaRegistryAvailableEvent event) { System.out.println(LocalDateTime.now()+"注冊(cè)中心可用事件"); } @EventListener public void listen(EurekaServerStartedEvent event) { System.out.println(LocalDateTime.now()+"注冊(cè)中心啟動(dòng)事件"); }}

5.6 Renew: 服務(wù)續(xù)約

Eureka Client 會(huì)每隔 30 秒發(fā)送一次心跳來(lái)續(xù)約。通過(guò)續(xù)約來(lái)告知 Eureka Server 該 Eureka Client 運(yùn)行正常，沒(méi)有出現(xiàn)問(wèn)題。默認(rèn)情況下，如果 Eureka Server 在 90 秒內(nèi)沒(méi)有收到 Eureka Client 的續(xù)約，Server 端會(huì)將實(shí)例從其注冊(cè)表中刪除，此時(shí)間可配置，一般情況不建議更改。

5.6 服務(wù)剔除

如果Eureka Client在注冊(cè)后，既沒(méi)有續(xù)約，也沒(méi)有下線(服務(wù)崩潰或者網(wǎng)絡(luò)異常等原因)，那么服務(wù)的狀態(tài)就處于不可知的狀態(tài)，不能保證能夠從該服務(wù)實(shí)例中獲取到回饋，所以需要服務(wù)剔除此方法定時(shí)清理這些不穩(wěn)定的服務(wù)，該方法會(huì)批量將注冊(cè)表中所有過(guò)期租約剔除，剔除是定時(shí)任務(wù)，默認(rèn)60秒執(zhí)行一次。延時(shí)60秒，間隔60秒

剔除的限制：1.自我保護(hù)期間不清除。2.分批次清除。

六、Eureka缺陷

由于集群間的同步復(fù)制是通過(guò)HTTP的方式進(jìn)行，基于網(wǎng)絡(luò)的不可靠性，集群中的Eureka Server間的注冊(cè)表信息難免存在不同步的時(shí)間節(jié)點(diǎn)，不滿足CAP中的C(數(shù)據(jù)一致性)

七、總結(jié)

中間我們講解了eureka的節(jié)點(diǎn)搭建，以及原理，對(duì)于現(xiàn)在很火熱的微服務(wù)，我們對(duì)Eureka是非常有必要進(jìn)行了解的，如果覺得文章對(duì)你有幫助，來(lái)個(gè)點(diǎn)贊支持吧，如果對(duì)文章有疑問(wèn)或建議，歡迎討論留言，謝謝大家~

--? End? --

———————

1.原創(chuàng)不易，你的「在看」是我創(chuàng)作的動(dòng)力。

2.歡迎關(guān)注公眾號(hào)?牧小農(nóng)的夏天，「帶你一起學(xué)Java」！

3.疫情期間，勤洗手，戴口罩，做好個(gè)人防護(hù)。

“在看轉(zhuǎn)發(fā)”是最大的支持

總結(jié)

以上是生活随笔為你收集整理的未发现oracle(tm)客户端和网络组件_SpringColud Eureka的服务注册与发现的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。