服務(wù)治理是微服務(wù)架構(gòu)中最為核心和基礎(chǔ)的模塊，它主要用來實(shí)現(xiàn)各個微服務(wù)實(shí)例的自動化注冊和發(fā)現(xiàn)。
Spring Cloud Eureka是Spring Cloud Netflix微服務(wù)套件中的一部分，它基于Netflix Eureka做了二次封裝。主要負(fù)責(zé)完成微服務(wù)架構(gòu)中的服務(wù)治理功能。
?
Eureka服務(wù)治理體系如下：
在服務(wù)治理框架中，通常都會構(gòu)建一個注冊中心，每個服務(wù)單元向注冊中心登記自己提供的服務(wù)，包括服務(wù)的主機(jī)與端口號、服務(wù)版本號、通訊協(xié)議等一些附加信息。注冊中心按照服務(wù)名分類組織服務(wù)清單，同時還需要以心跳檢測的方式去監(jiān)測清單中的服務(wù)是否可用，若不可用需要從服務(wù)清單中剔除，以達(dá)到排除故障服務(wù)的效果。
在服務(wù)治理框架下，服務(wù)間的調(diào)用不再通過指定具體的實(shí)例地址來實(shí)現(xiàn)，而是通過服務(wù)名發(fā)起請求調(diào)用實(shí)現(xiàn)。服務(wù)調(diào)用方通過服務(wù)名從服務(wù)注冊中心的服務(wù)清單中獲取服務(wù)實(shí)例的列表清單，通過指定的負(fù)載均衡策略取出一個服務(wù)實(shí)例位置來進(jìn)行服務(wù)調(diào)用。
Spirng Cloud Eureka使用Netflix Eureka來實(shí)現(xiàn)服務(wù)注冊與發(fā)現(xiàn)。它既包含了服務(wù)端組件，也包含了客戶端組件，并且服務(wù)端與客戶端均采用java編寫，所以Eureka主要適用于通過java實(shí)現(xiàn)的分布式系統(tǒng)，或是JVM兼容語言構(gòu)建的系統(tǒng)。Eureka的服務(wù)端提供了較為完善的REST API，所以Eureka也支持將非java語言實(shí)現(xiàn)的服務(wù)納入到Eureka服務(wù)治理體系中來，只需要其他語言平臺自己實(shí)現(xiàn)Eureka的客戶端程序。目前.Net平臺的Steeltoe、Node.js的eureka-js-client等都已經(jīng)實(shí)現(xiàn)了各自平臺的Ereka客戶端組件。
??? Eureka服務(wù)端，即服務(wù)注冊中心。它同其他服務(wù)注冊中心一樣，支持高可用配置。依托于強(qiáng)一致性提供良好的服務(wù)實(shí)例可用性，可以應(yīng)對多種不同的故障場景。
???Eureka服務(wù)端支持集群模式部署，當(dāng)集群中有分片發(fā)生故障的時候，Eureka會自動轉(zhuǎn)入自我保護(hù)模式。它允許在分片發(fā)生故障的時候繼續(xù)提供服務(wù)的發(fā)現(xiàn)和注冊，當(dāng)故障分配恢復(fù)時，集群中的其他分片會把他們的狀態(tài)再次同步回來。集群中的的不同服務(wù)注冊中心通過異步模式互相復(fù)制各自的狀態(tài)，這也意味著在給定的時間點(diǎn)每個實(shí)例關(guān)于所有服務(wù)的狀態(tài)可能存在不一致的現(xiàn)象。
Eureka客戶端，主要處理服務(wù)的注冊和發(fā)現(xiàn)?？蛻舳朔?wù)通過注冊和參數(shù)配置的方式，嵌入在客戶端應(yīng)用程序的代碼中。在應(yīng)用程序啟動時，Eureka客戶端向服務(wù)注冊中心注冊自身提供的服務(wù)，并周期性的發(fā)送心跳來更新它的服務(wù)租約。同時，他也能從服務(wù)端查詢當(dāng)前注冊的服務(wù)信息并把它們緩存到本地并周期行的刷新服務(wù)狀態(tài)。
在服務(wù)治理框架中，通常都會構(gòu)建一個注冊中心，每個服務(wù)單元向注冊中心登記自己提供的服務(wù)，包括服務(wù)的主機(jī)與端口號、服務(wù)版本號、通訊協(xié)議等一些附加信息。注冊中心按照服務(wù)名分類組織服務(wù)清單，同時還需要以心跳檢測的方式去監(jiān)測清單中的服務(wù)是否可用，若不可用需要從服務(wù)清單中剔除，以達(dá)到排除故障服務(wù)的效果。
?
創(chuàng)建一個Spring Boot工程，命名問Eureka-Server，并在pom文件中引入依賴：
<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>?
?
在默認(rèn)配置下，Eureka Server會將自己也作為客戶端來嘗試注冊自己，我們需要禁用它的客戶端禁用行為。
下面是一個Eureka Server的application.properites的相關(guān)配置：
#服務(wù)注冊中心端口號server.port=1110#服務(wù)注冊中心實(shí)例的主機(jī)名eureka.instance.hostname=localhost#是否向服務(wù)注冊中心注冊自己eureka.client.register-with-eureka=false#是否檢索服務(wù)eureka.client.fetch-registry=false#服務(wù)注冊中心的配置內(nèi)容，指定服務(wù)注冊中心的位置eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
通過@EnableEurekaServer注解啟動服務(wù)注冊中心，如下：
?
import org.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@EnableEurekaServer@SpringBootApplicationpublic class IefopEurekaServerApplication { publicstatic void main(String[] args) { SpringApplication.run(IefopEurekaServerApplication.class,args); }}?
?
考慮到發(fā)生故障的情況，服務(wù)注冊中心發(fā)生故障必將會造成整個系統(tǒng)的癱瘓，因此需要保證服務(wù)注冊中心的高可用。
Eureka Server在設(shè)計的時候就考慮了高可用設(shè)計，在Eureka服務(wù)治理設(shè)計中，所有節(jié)點(diǎn)既是服務(wù)的提供方，也是服務(wù)的消費(fèi)方，服務(wù)注冊中心也不例外。
Eureka Server的高可用實(shí)際上就是將自己做為服務(wù)向其他服務(wù)注冊中心注冊自己，這樣就可以形成一組互相注冊的服務(wù)注冊中心，以實(shí)現(xiàn)服務(wù)清單的互相同步，達(dá)到高可用的效果。
Eureka Server的同步遵循著一個非常簡單的原則：只要有一條邊將節(jié)點(diǎn)連接，就可以進(jìn)行信息傳播與同步?？梢圆捎脙蓛勺缘姆绞綄?shí)現(xiàn)集群中節(jié)點(diǎn)完全對等的效果，實(shí)現(xiàn)最高可用性集群，任何一臺注冊中心故障都不會影響服務(wù)的注冊與發(fā)現(xiàn)
?
（1）創(chuàng)建application-peer1.properties server.port=1111eureka.instance.hostname=mastereureka.client.fetch-registry=falseeureka.instance.preferIpAddress=trueeureka.server.enableSelfPreservation=falseeureka.client.serviceUrl.defaultZone=http://backup1:1112/eureka/,http://backup2:1113/eureka/（2）創(chuàng)建application-peer2.propertiesserver.port=1112eureka.instance.hostname=backup1eureka.client.fetch-registry=falseeureka.instance.preferIpAddress=trueeureka.server.enableSelfPreservation=falseeureka.client.serviceUrl.defaultZone=http://master:1111/eureka/,http://backup2:1113/eureka/（3）創(chuàng)建application-peer3.propertiesserver.port=1113eureka.instance.hostname=backup2eureka.client.register-with-eureka=falseeureka.client.fetch-registry=falseeureka.instance.preferIpAddress=trueeureka.server.enableSelfPreservation=falseeureka.client.serviceUrl.defaultZone=http://master:1111/eureka/,http://backup1:1112/eureka/(4) 在hosts文件中增加如下配置127.0.0.1 master127.0.0.1 backup1127.0.0.1 backup2
?
有些時候，我們的服務(wù)實(shí)例并不一定會正常下線，可能由于內(nèi)存溢出、網(wǎng)絡(luò)故障等原因使服務(wù)不能正常運(yùn)作。而服務(wù)注冊中心并未收到“服務(wù)下線”的請求，為了從服務(wù)列表中將這些無法提供服務(wù)的實(shí)例剔除，Eureka Server在啟動的時候會創(chuàng)建一個定時任務(wù)，默認(rèn)每隔一段時間（默認(rèn)為60秒）將當(dāng)前清單中超時（默認(rèn)為90秒）沒有續(xù)約的服務(wù)剔除出去。
服務(wù)注冊到Eureka Server后，會維護(hù)一個心跳連接，告訴Eureka Server自己還活著。Eureka Server在運(yùn)行期間會統(tǒng)計心跳失敗的比例在15分鐘以之內(nèi)是否低于85%，如果出現(xiàn)低于的情況，Eureka Server會將當(dāng)前實(shí)例注冊信息保護(hù)起來，讓這些實(shí)例不會過期。這樣做會使客戶端很容易拿到實(shí)際已經(jīng)不存在的服務(wù)實(shí)例，會出現(xiàn)調(diào)用失敗的情況。因此客戶端要有容錯機(jī)制，比如請求重試、斷路器。
以下是自我保護(hù)相關(guān)的屬性：
eureka.server.enableSelfPreservation=true. 可以設(shè)置改參數(shù)值為false，以確保注冊中心將不可用的實(shí)例刪除
?
region和zone（或者Availability Zone）均是AWS的概念。在非AWS環(huán)境下，我們可以簡單地將region理解為地域，zone理解成機(jī)房。一個region可以包含多個zone，可以理解為一個地域內(nèi)的多個不同的機(jī)房。不同地域的距離很遠(yuǎn)，一個地域的不同zone間距離往往較近，也可能在同一個機(jī)房內(nèi)。
region可以通過配置文件進(jìn)行配置，如果不配置，會默認(rèn)使用us-east-1。同樣Zone也可以配置，如果不配置，會默認(rèn)使用defaultZone。
Eureka Server通過eureka.client.serviceUrl.defaultZone屬性設(shè)置Eureka的服務(wù)注冊中心的位置。
指定region和zone的屬性如下：
（1）eureka.client.availabilityZones.myregion=myzone# myregion是region
（2）eureka.client.region=myregion
??? ?Ribbon的默認(rèn)策略會優(yōu)先訪問通客戶端處于同一個region中的服務(wù)端實(shí)例，只有當(dāng)同一個zone中沒有可用服務(wù)端實(shí)例的時候才會訪問其他zone中的實(shí)例。所以通過zone屬性的定義，配合實(shí)際部署的物理結(jié)構(gòu)，我們就可以設(shè)計出應(yīng)對區(qū)域性故障的容錯集群。
我們啟動了Eureka Server，然后在瀏覽器中輸入http://localhost:8761/后，直接回車，就進(jìn)入了spring?cloud的服務(wù)治理頁面，這么做在生產(chǎn)環(huán)境是極不安全的，下面，我們就給Eureka Server加上安全的用戶認(rèn)證.
（1）pom文件中引入依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency>
?
?
（2）serviceurl中加入安全校驗(yàn)信息
eureka.client.serviceUrl.defaultZone=http://<username>:<password>@${eureka.instance.hostname}:${server.port}/eureka/ ?
服務(wù)啟動后，訪問http://127.0.0.1:1110/可以看到Eureka的信息面板。如下圖,目前Instancescurrently registered with Eureka一欄顯示注冊到服務(wù)注冊中心內(nèi)的服務(wù)。
?
?
服務(wù)提供者在啟動的時候會通過REST請求的方式將自己注冊到Eureka Server上，同時帶上自身服務(wù)的一些元數(shù)據(jù)信息。Eureka Server接收到這個Rest請求之后，將元數(shù)據(jù)信息存儲在一個雙層結(jié)構(gòu)的Map中，其中第一層的key是服務(wù)名。第二層的key 是具體服務(wù)的實(shí)例名。
在服務(wù)注冊時，需要確認(rèn)一下eureka.client.register-with-eureka=true參數(shù)是否正確，該值默認(rèn)為true。若設(shè)置為fasle將不會啟動注冊操作。
從eureka服務(wù)治理體系架構(gòu)圖中可以看到，不同的服務(wù)提供者可以注冊在不同的服務(wù)注冊中心上，它們的信息被不同的服務(wù)注冊中心維護(hù)。
此時，由于多個服務(wù)注冊中心互相注冊為服務(wù)，當(dāng)服務(wù)提供者發(fā)送注冊請求到一個服務(wù)注冊中心時，它會將該請求轉(zhuǎn)發(fā)給集群中相連的其他注冊中心，從而實(shí)現(xiàn)服務(wù)注冊中心之間的服務(wù)同步。通過服務(wù)同步，提供者的服務(wù)信息就可以通過集群中的任意一個服務(wù)注冊中心獲得。
在注冊服務(wù)之后，服務(wù)提供者會維護(hù)一個心跳用來持續(xù)高速Eureka Server，“我還在持續(xù)提供服務(wù)”，否則Eureka Server的剔除任務(wù)會將該服務(wù)實(shí)例從服務(wù)列表中排除出去。我們稱之為服務(wù)續(xù)約。
下面是服務(wù)續(xù)約的兩個重要屬性：
（1）eureka.instance.lease-expiration-duration-in-seconds
leaseExpirationDurationInSeconds，表示eureka server至上一次收到client的心跳之后，等待下一次心跳的超時時間，在這個時間內(nèi)若沒收到下一次心跳，則將移除該instance。
（2）eureka.instance.lease-renewal-interval-in-seconds
leaseRenewalIntervalInSeconds，表示eureka client發(fā)送心跳給server端的頻率。如果在leaseExpirationDurationInSeconds后，server端沒有收到client的心跳，則將摘除該instance。除此之外，如果該instance實(shí)現(xiàn)了HealthCheckCallback，并決定讓自己unavailable的話，則該instance也不會接收到流量。
?
?
創(chuàng)建一個Spring Boot工程，命名問Eureka-Client，并在pom文件中引入依賴：
<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>?
在Eureka客戶端需要在appilication.properties文件中指定服務(wù)注冊中心的地址
eureka.port=1110
eureka.instance.hostname=localhost
#在此指定服務(wù)注冊中心地址
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${eureka.port}/eureka/
在主類中加入@EnableEurekaClient注解啟動Eureka客戶端，如下：
package com.shl.iefop; importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;@EnableEurekaClient@SpringBootApplicationpublic class IefopEurekaClientApplication { publicstatic void main(String[] args) { SpringApplication.run(IefopEurekaClientApplication.class,args); }} ?
?
消費(fèi)者服務(wù)啟動時，會發(fā)送一個Rest請求給服務(wù)注冊中心，來獲取上面注冊的服務(wù)清單。為了性能考慮，Eureka Server會維護(hù)一份只讀的服務(wù)注冊清單來返回給客戶端，同時該緩存清單默認(rèn)會每隔30秒更新一次。
下面是獲取服務(wù)的兩個重要的屬性：
（1）??????eureka.client.fetch-registry??
是否需要去檢索尋找服務(wù)，默認(rèn)是true
（2）eureka.client.registry-fetch-interval-seconds
表示eureka client間隔多久去拉取服務(wù)注冊信息，默認(rèn)為30秒，對于api-gateway，如果要迅速獲取服務(wù)注冊狀態(tài)，可以縮小該值，比如5秒
服務(wù)消費(fèi)者在獲取服務(wù)清單后，通過服務(wù)名可以獲取具體提供服務(wù)的實(shí)例名和該實(shí)例的元數(shù)據(jù)信息。因?yàn)橛羞@些服務(wù)實(shí)例的詳細(xì)信息，所以客戶端可以根據(jù)自己的需要決定具體調(diào)用哪個實(shí)例，在Ribbon中會默認(rèn)采用輪詢的方式進(jìn)行調(diào)用，從而實(shí)現(xiàn)客戶端的負(fù)載均衡。
在系統(tǒng)運(yùn)行過程中必然會面臨關(guān)閉或重啟服務(wù)的某個實(shí)例的情況，在服務(wù)關(guān)閉操作時，會觸發(fā)一個服務(wù)下線的Rest服務(wù)請求給Eureka Server，告訴服務(wù)注冊中心：“我要下線了?！狈?wù)端在接收到該請求后，將該服務(wù)狀態(tài)置位下線（DOWN），并把該下線事件傳播出去。
?
eureka實(shí)例的狀態(tài)頁面和健康監(jiān)控的url默認(rèn)為spring boot actuator提供的/info端點(diǎn)和/health端點(diǎn)。我們必須確保Eureka客戶端的/health端點(diǎn)在發(fā)送元數(shù)據(jù)的時候，是一個能夠被注冊中心訪問到的地址，否則服務(wù)注冊中心不會根據(jù)應(yīng)用的健康檢查來更改狀態(tài)（僅當(dāng)開啟了healthcheck功能時，以該端點(diǎn)信息作為健康檢查標(biāo)準(zhǔn)）。而如果/info端點(diǎn)不正確的話，會導(dǎo)致在Eureka面板中單擊服務(wù)時，無法訪問到服務(wù)實(shí)例提供的信息接口。
大多數(shù)情況下，我們不需要修改這個幾個url配置。但是當(dāng)應(yīng)用不使用默認(rèn)的上下文(context path或servlet path，比如配置server.servletPath=/test），或者管理終端路徑（比如配置management.contextPath=/admin）時，我們需要修改健康檢查和狀態(tài)頁的url地址信息。
application.yml配置文件如下：
server.context-path=/helloeureka
//下面配置為相對路徑，也支持配置成絕對路徑，例如需要支持https
eureka.instance.health-check-url-path=${server.context-path}/health
eureka.instance.status-page-url-path=${server.context-path}/info
元數(shù)據(jù)是Eureka客戶端在向服務(wù)注冊中心發(fā)送注冊請求時，用來描述自身服務(wù)信息的對象，其中包含了一些標(biāo)準(zhǔn)化的元數(shù)據(jù)，比如服務(wù)名稱、實(shí)例名稱、實(shí)例IP、實(shí)例端口等用于服務(wù)治理的重要信息；以及一些用于負(fù)載均衡策略或是其他特殊用途的自定義元數(shù)據(jù)信息。
我們可以通過eureka.instance.<properties>=<value>的格式對標(biāo)準(zhǔn)化元數(shù)據(jù)直接進(jìn)行配置，其中<properties>就是EurekaInstanceConfigBean對象中的成員變量。而對于自定義元數(shù)據(jù)，可以通過eureka.instance.metadataMap.<key>=<value>的格式來進(jìn)行配置。比如：
eureka.instance.metadataMap.zone=tianjin
//隨機(jī)生成實(shí)例名
eureka.instance.metadataMap.instanceId=${spring.application.name}:${random.value}
默認(rèn)情況下，Eureka中各個服務(wù)實(shí)例的健康檢測并不是通過spring-boot-acturator模塊的/health端點(diǎn)來實(shí)現(xiàn)的，而是依靠客戶端心跳的方式來保持服務(wù)實(shí)例的存活。在Eureka的服務(wù)續(xù)約與剔除機(jī)制下，客戶端的健康狀態(tài)從注冊到注冊中心開始都會處于UP狀態(tài)，除非心跳終止一段時間之后，服務(wù)注冊中心將其剔除。默認(rèn)的心跳實(shí)現(xiàn)方式可以有效檢查客戶端進(jìn)程是否正常運(yùn)作，但卻無法保證客戶端應(yīng)用能夠正常提供服務(wù)。
在Spring Cloud Eureka中，可以把Eureka客戶端的健康檢測交給spring-boot-actuator模塊的health端點(diǎn)，以實(shí)現(xiàn)更加全面的健康狀態(tài)維護(hù)，設(shè)置方式如下：
（1）??????在pom.xml中引入spring-boot-starter-actuator模塊的依賴
（2）??????在application.properties中增加參數(shù)配置eureka.client.healthcheck.enabled=true
??? ??除了上述配置參數(shù)外，下面整理了一些EurekaInstanceConfigBean中定義的配置參數(shù)以及對應(yīng)的說明和默認(rèn)值，這些參數(shù)均以eureka.instance為前綴。
默認(rèn)情況下，Eureka使用Jersey和XStream配合JSON作為Server與Client之間的通訊協(xié)議。也可以選擇實(shí)現(xiàn)自己的協(xié)議來代替。
來源：https://www.icode9.com/content-4-765301.html聯(lián)系客服
