Eureka

Register：服務(wù)注冊(cè)

當(dāng)Eureka客戶(hù)端向Eureka Server注冊(cè)時(shí)，它提供自身的元數(shù)據(jù)，比如IP地址徊都、端口，運(yùn)行狀況指示符URL广辰，主頁(yè)等暇矫。

Renew：服務(wù)續(xù)約

Eureka客戶(hù)會(huì)每隔30秒發(fā)送一次心跳來(lái)續(xù)約。 通過(guò)續(xù)約來(lái)告知Eureka Server該Eureka客戶(hù)仍然存在择吊，沒(méi)有出現(xiàn)問(wèn)題李根。 正常情況下，如果Eureka Server在90秒沒(méi)有收到Eureka客戶(hù)的續(xù)約干发，它會(huì)將實(shí)例從其注冊(cè)表中刪除朱巨。 建議不要更改續(xù)約間隔史翘。

Fetch Registries：獲取注冊(cè)列表信息

Eureka客戶(hù)端從服務(wù)器獲取注冊(cè)表信息枉长，并將其緩存在本地∏矸恚客戶(hù)端會(huì)使用該信息查找其他服務(wù)必峰，從而進(jìn)行遠(yuǎn)程調(diào)用。該注冊(cè)列表信息定期（每30秒鐘）更新一次钻蹬。每次返回注冊(cè)列表信息可能與Eureka客戶(hù)端的緩存信息不同吼蚁， Eureka客戶(hù)端自動(dòng)處理。如果由于某種原因?qū)е伦?cè)列表信息不能及時(shí)匹配问欠，Eureka客戶(hù)端則會(huì)重新獲取整個(gè)注冊(cè)表信息肝匆。 Eureka服務(wù)器緩存注冊(cè)列表信息，整個(gè)注冊(cè)表以及每個(gè)應(yīng)用程序的信息進(jìn)行了壓縮顺献，壓縮內(nèi)容和沒(méi)有壓縮的內(nèi)容完全相同旗国。Eureka客戶(hù)端和Eureka 服務(wù)器可以使用JSON / XML格式進(jìn)行通訊。在默認(rèn)的情況下Eureka客戶(hù)端使用壓縮JSON格式來(lái)獲取注冊(cè)列表的信息注整。

Cancel：服務(wù)下線(xiàn)

Eureka客戶(hù)端在程序關(guān)閉時(shí)向Eureka服務(wù)器發(fā)送取消請(qǐng)求能曾。 發(fā)送請(qǐng)求后，該客戶(hù)端實(shí)例信息將從服務(wù)器的實(shí)例注冊(cè)表中刪除肿轨。該下線(xiàn)請(qǐng)求不會(huì)自動(dòng)完成寿冕，它需要調(diào)用以下內(nèi)容：

DiscoveryManager.getInstance().shutdownComponent()；

Eviction 服務(wù)剔除

在默認(rèn)的情況下椒袍，當(dāng)Eureka客戶(hù)端連續(xù)90秒沒(méi)有向Eureka服務(wù)器發(fā)送服務(wù)續(xù)約驼唱，即心跳，Eureka服務(wù)器會(huì)將該服務(wù)實(shí)例從服務(wù)注冊(cè)列表刪除驹暑，即服務(wù)剔除曙蒸。

Eureka的高可用架構(gòu)

從圖可以看出在這個(gè)體系中捌治，有2個(gè)角色，即Eureka Server和Eureka Client纽窟。而Eureka Client又分為Applicaton Service和Application Client肖油，即服務(wù)提供者何服務(wù)消費(fèi)者。 每個(gè)區(qū)域有一個(gè)Eureka集群臂港，并且每個(gè)區(qū)域至少有一個(gè)eureka服務(wù)器可以處理區(qū)域故障森枪，以防服務(wù)器癱瘓。

Eureka Client向Eureka Serve注冊(cè)审孽，并將自己的一些客戶(hù)端信息發(fā)送Eureka Serve县袱。然后，Eureka Client通過(guò)向Eureka Serve發(fā)送心跳（每30秒）來(lái)續(xù)約服務(wù)的佑力。 如果客戶(hù)端持續(xù)不能續(xù)約式散，那么，它將在大約90秒內(nèi)從服務(wù)器注冊(cè)表中刪除打颤。 注冊(cè)信息和續(xù)訂被復(fù)制到集群中的Eureka Serve所有節(jié)點(diǎn)暴拄。 來(lái)自任何區(qū)域的Eureka Client都可以查找注冊(cè)表信息（每30秒發(fā)生一次）。根據(jù)這些注冊(cè)表信息编饺，Application Client可以遠(yuǎn)程調(diào)用Applicaton Service來(lái)消費(fèi)服務(wù)乖篷。

Register服務(wù)注冊(cè)

服務(wù)注冊(cè)，即Eureka Client向Eureka Server提交自己的服務(wù)信息透且，包括IP地址撕蔼、端口、service ID等信息秽誊。如果Eureka Client沒(méi)有寫(xiě)service ID鲸沮，則默認(rèn)為 ${spring.application.name}。

服務(wù)注冊(cè)其實(shí)很簡(jiǎn)單锅论，在Eureka Client啟動(dòng)的時(shí)候讼溺，將自身的服務(wù)的信息發(fā)送到Eureka Server。現(xiàn)在來(lái)簡(jiǎn)單的閱讀下源碼棍厌。在Maven的依賴(lài)包下肾胯，找到eureka-client-1.6.2.jar包。在com.netflix.discovery包下有個(gè)DiscoveryClient類(lèi)耘纱，該類(lèi)包含了Eureka Client向Eureka Server的相關(guān)方法敬肚。其中DiscoveryClient實(shí)現(xiàn)了EurekaClient接口，并且它是一個(gè)單例模式束析，而EurekaClient繼承了LookupService接口艳馒。它們之間的關(guān)系如圖所示。

在DiscoveryClient類(lèi)有一個(gè)服務(wù)注冊(cè)的方法register()，該方法是通過(guò)Http請(qǐng)求向Eureka Client注冊(cè)弄慰。其代碼如下：

在DiscoveryClient類(lèi)繼續(xù)追蹤register()方法第美，它被InstanceInfoReplicator 類(lèi)的run()方法調(diào)用，其中InstanceInfoReplicator實(shí)現(xiàn)了Runnable接口陆爽，run()方法代碼如下：

而InstanceInfoReplicator類(lèi)是在DiscoveryClient初始化過(guò)程中使用的什往，其中有一個(gè)initScheduledTasks()方法。該方法主要開(kāi)啟了獲取服務(wù)注冊(cè)列表的信息慌闭，如果需要向Eureka Server注冊(cè)别威，則開(kāi)啟注冊(cè)，同時(shí)開(kāi)啟了定時(shí)向Eureka Server服務(wù)續(xù)約的定時(shí)任務(wù)驴剔，具體代碼如下：

然后在來(lái)看Eureka server端的代碼省古，在Maven的eureka-core:1.6.2的jar包下。打開(kāi)com.netflix.eureka包丧失，很輕松的就發(fā)現(xiàn)了又一個(gè)EurekaBootStrap的類(lèi)豺妓，BootStrapContext具有最先初始化的權(quán)限，所以先看這個(gè)類(lèi)布讹。

其中PeerAwareInstanceRegistryImpl和PeerEurekaNodes兩個(gè)類(lèi)看其命名琳拭，應(yīng)該和服務(wù)注冊(cè)以及Eureka Server高可用有關(guān)。先追蹤PeerAwareInstanceRegistryImpl類(lèi)炒事，在該類(lèi)有個(gè)register()方法臀栈，該方法提供了注冊(cè)蔫慧，并且將注冊(cè)后信息同步到其他的Eureka Server服務(wù)挠乳。代碼如下：

其中 super.register(info, leaseDuration, isReplication)方法，點(diǎn)擊進(jìn)去到子類(lèi)AbstractInstanceRegistry可以發(fā)現(xiàn)更多細(xì)節(jié)姑躲，其中注冊(cè)列表的信息被保存在一個(gè)Map中睡扬。replicateToPeers()方法，即同步到其他Eureka Server的其他Peers節(jié)點(diǎn)黍析，追蹤代碼卖怜，發(fā)現(xiàn)它會(huì)遍歷循環(huán)向所有的Peers節(jié)點(diǎn)注冊(cè)，最終執(zhí)行類(lèi)PeerEurekaNodes的register()方法阐枣，該方法通過(guò)執(zhí)行一個(gè)任務(wù)向其他節(jié)點(diǎn)同步該注冊(cè)信息马靠，代碼如下：

經(jīng)過(guò)一系列的源碼追蹤，可以發(fā)現(xiàn)PeerAwareInstanceRegistryImpl的register()方法實(shí)現(xiàn)了服務(wù)的注冊(cè)蔼两，并且向其他Eureka Server的Peer節(jié)點(diǎn)同步了該注冊(cè)信息甩鳄，那么register()方法被誰(shuí)調(diào)用了呢？之前在Eureka Client的分析可以知道额划，Eureka Client是通過(guò) http來(lái)向Eureka Server注冊(cè)的妙啃，那么Eureka Server肯定會(huì)提供一個(gè)注冊(cè)的接口給Eureka Client調(diào)用，那么PeerAwareInstanceRegistryImpl的register()方法肯定最終會(huì)被暴露的Http接口所調(diào)用。在Idea開(kāi)發(fā)工具揖赴，按住alt+鼠標(biāo)左鍵馆匿，可以很快定位到ApplicationResource類(lèi)的addInstance ()方法，即服務(wù)注冊(cè)的接口燥滑，其代碼如下：

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

服務(wù)續(xù)約和服務(wù)注冊(cè)非常類(lèi)似渐北，通過(guò)之前的分析可以知道，服務(wù)注冊(cè)在Eureka Client程序啟動(dòng)之后開(kāi)啟铭拧，并同時(shí)開(kāi)啟服務(wù)續(xù)約的定時(shí)任務(wù)腔稀。在eureka-client-1.6.2.jar的DiscoveryClient的類(lèi)下有renew()方法，其代碼如下：

另外服務(wù)端的續(xù)約接口在eureka-core:1.6.2.jar的 com.netflix.eureka包下的InstanceResource類(lèi)下羽历，接口方法為renewLease()焊虏，它是REST接口。為了減少類(lèi)篇幅秕磷，省略了大部分代碼的展示诵闭。其中有個(gè)registry.renew()方法，即服務(wù)續(xù)約澎嚣，代碼如下:

可以跟蹤registry.renew的代碼一直深入研究疏尿。在這里就不再多講述。另外服務(wù)續(xù)約有2個(gè)參數(shù)是可以配置易桃，即Eureka Client發(fā)送續(xù)約心跳的時(shí)間參數(shù)和Eureka Server在多長(zhǎng)時(shí)間內(nèi)沒(méi)有收到心跳將實(shí)例剔除的時(shí)間參數(shù)褥琐，在默認(rèn)的情況下這兩個(gè)參數(shù)分別為30秒和90秒，官方給的建議是不要修改晤郑，如果有特殊要求還是可以調(diào)整的敌呈，只需要分別在Eureka Client和Eureka Server修改以下參數(shù)

eureka.instance.leaseRenewalIntervalInSeconds

eureka.instance.leaseExpirationDurationInSeconds

最后，服務(wù)注冊(cè)列表的獲取造寝、服務(wù)下線(xiàn)和服務(wù)剔除就不在這里進(jìn)行源碼跟蹤解讀磕洪，因?yàn)楹头?wù)注冊(cè)和續(xù)約類(lèi)似，有興趣的朋友可以自己看下源碼诫龙，深入理解析显。總的來(lái)說(shuō)签赃，通過(guò)讀源碼谷异，可以發(fā)現(xiàn)，整體架構(gòu)與前面小節(jié)的eureka 的高可用架構(gòu)圖完全一致锦聊。

Eureka Client注冊(cè)一個(gè)實(shí)例為什么這么慢

Eureka Client一啟動(dòng)（不是啟動(dòng)完成）歹嘹，不是立即向Eureka Server注冊(cè)，它有一個(gè)延遲向服務(wù)端注冊(cè)的時(shí)間括丁，通過(guò)跟蹤源碼荞下，可以發(fā)現(xiàn)默認(rèn)的延遲時(shí)間為40秒，源碼在eureka-client-1.6.2.jar的DefaultEurekaClientConfig類(lèi)下，代碼如下：

Eureka Server的響應(yīng)緩存

Eureka Server維護(hù)每30秒更新的響應(yīng)緩存,可通過(guò)更改配置eureka.server.responseCacheUpdateIntervalMs來(lái)修改尖昏。 所以即使實(shí)例剛剛注冊(cè)仰税，它也不會(huì)出現(xiàn)在調(diào)用/ eureka / apps REST端點(diǎn)的結(jié)果中。

Eureka Server刷新緩存

Eureka客戶(hù)端保留注冊(cè)表信息的緩存抽诉。 該緩存每30秒更新一次（如前所述）陨簇。 因 此，客戶(hù)端決定刷新其本地緩存并發(fā)現(xiàn)其他新注冊(cè)的實(shí)例可能需要30秒迹淌。

LoadBalancer Refresh

Ribbon的負(fù)載平衡器從本地的Eureka Client獲取服務(wù)注冊(cè)列表信息河绽。Ribbon本身還維護(hù)本地緩存，以避免為每個(gè)請(qǐng)求調(diào)用本地客戶(hù)端唉窃。 此緩存每30秒刷新一次（可由ribbon.ServerListRefreshInterval配置）耙饰。 所以，可能需要30多秒才能使用新注冊(cè)的實(shí)例纹份。

綜上幾個(gè)因素苟跪，一個(gè)新注冊(cè)的實(shí)例，特別是啟動(dòng)較快的實(shí)例（默認(rèn)延遲40秒注冊(cè)）蔓涧，不能馬上被Eureka Server發(fā)現(xiàn)件已。另外，剛注冊(cè)的Eureka Client也不能立即被其他服務(wù)調(diào)用元暴，因?yàn)檎{(diào)用方因?yàn)楦鞣N緩存沒(méi)有及時(shí)的獲取到新的注冊(cè)列表篷扩。

Eureka 的自我保護(hù)模式

當(dāng)一個(gè)新的Eureka Server出現(xiàn)時(shí)，它嘗試從相鄰節(jié)點(diǎn)獲取所有實(shí)例注冊(cè)表信息茉盏。如果從Peer節(jié)點(diǎn)獲取信息時(shí)出現(xiàn)問(wèn)題鉴未，Eureka Serve會(huì)嘗試其他的Peer節(jié)點(diǎn)。如果服務(wù)器能夠成功獲取所有實(shí)例援岩，則根據(jù)該信息設(shè)置應(yīng)該接收的更新閾值歼狼。如果有任何時(shí)間掏导，Eureka Serve接收到的續(xù)約低于為該值配置的百分比（默認(rèn)為15分鐘內(nèi)低于85％）享怀，則服務(wù)器開(kāi)啟自我保護(hù)模式，即不再剔除注冊(cè)列表的信息趟咆。

這樣做的好處就是添瓷，如果是Eureka Server自身的網(wǎng)絡(luò)問(wèn)題，導(dǎo)致Eureka Client的續(xù)約不上值纱，Eureka Client的注冊(cè)列表信息不再被刪除鳞贷，也就是Eureka Client還可以被其他服務(wù)消費(fèi)。