“一代“佳人，左右逢源，服務注冊Eureka-有解無憂

1. Eureka服務注冊中心

1.1 關于服務注冊中心

服務注冊中?本質上是為了解耦服務提供者和服務消費者，

對于任何?個微服務，原則上都應存在或者?持多個提供者（一個服務多實體）

服務注冊中?管就是用來理微服務提供者的注冊與發現，

1.2 服務注冊中心一般原理

在這里插入圖片描述

分布式微服務架構中，服務注冊中??于存盤服務提供者地址資訊、服務發布相關的屬性資訊，消費者通過主動查詢和被動通知的?式獲取服務提供者的地址資訊，?不再需要通過硬編碼?式得到提供者的地址資訊，消費者只需要知道當前系統發布了那些服務，?不需要知道服務具體存在于什么位置，這就是透明化路由，

服務提供者啟動
服務提供者將相關服務資訊主動注冊到注冊中?
服務消費者獲取服務注冊資訊：
1. pull模式：服務消費者可以主動拉取可?的服務提供者清單
2. push模式：服務消費者訂閱服務（當服務提供者有變化時，注冊中?也會主動推送更新后的服務清單給消費者
服務消費者直接調?服務提供者

另外，注冊中?也需要完成服務提供者的健康監控，當發現服務提供者失效時需要及時剔除；

1.3 主流服務中心對比

Zookeeper

? Zookeeper它是?個分布式服務框架，是Apache Hadoop 的?個?項?，它主要是?來解決分布式應 ?中經常遇到的?些資料管理問題，如：統?命名服務、狀態同步服務、集群管理、分布式應?配置項的管理等，
簡單來說zookeeper本質=存盤+監聽通知，
? znode
? Zookeeper ?來做服務注冊中?，主要是因為它具有節點變更通知功能，只要客戶端監聽相關服務節點，服務節點的所有變更，都能及時的通知到監聽客戶端，這樣作為調??只要使? Zookeeper 的客戶端就能實作服務節點的訂閱和變更通知功能了，?常?便，

? 另外， Zookeeper 可?性也Ok，因為只要半數以上的選舉節點存活，整個集群就是可?的，集群最小節點數3個，半數以上3個只能掛一個，4個也只能掛一個服務，
Eureka

? 由Netflix開源，并被Pivatal集成到SpringCloud體系中，它是基于 RestfulAPI?格開發的服務注冊與發現組件，
Consul

? Consul是由HashiCorp基于Go語?開發的?持多資料中?分布式?可?的服務發布和注冊服務軟體，采?Raft演算法保證服務的?致性，且?持健康檢查，
Nacos

? Nacos是?個更易于構建云原?應?的動態服務發現、配置管理和服務管理平臺，簡單來說 Nacos 就是 注冊中? + 配置中?的組合，幫助我們解決微服務開發必會涉及到的服務注冊與發現，服務配置，服務管理等問題， Nacos 是Spring Cloud Alibaba 核?組件之?，負責服務注冊與發現，還有配置，

組件名	語言	CAP	對外暴露介面
Eureka	Java	AP（自我保護機制，保證可用）	HTTP
Consul	Go	CP	HTTP/DNS
Zookeeper	Java	CP	客戶端
Nacos	Java	支持AP/CP切換	HTTP

P：磁區容錯性（一定要滿足的）

C：資料一致性

A：高可用

CAP不可能同時滿?三個，要么是AP，要么是CP

2. 服務注冊中心組件Eureka

Eureka基礎架構

在這里插入圖片描述

Eureka 互動流程及原理

下圖是官?描述的?個架構圖

在這里插入圖片描述

Eureka 包含兩個組件： Eureka Server 和 Eureka Client， Eureka Client是?個Java客戶端，?于簡化與Eureka Server的互動； Eureka Server提供服務發現的能?，各個微服務啟動時，會通過Eureka Client向Eureka Server 進?注冊??的資訊（例如?絡資訊）， Eureka Server會存盤該服務的資訊；

1）圖中us-east-1c、 us-east-1d， us-east-1e代表不同的區也就是不同的機房

2）圖中每?個Eureka Server都是?個集群

3）圖中Application Service作為服務提供者向Eureka Server中注冊服務，Eureka Server接受到注冊事件會在集群和磁區中進?資料同步， ApplicationClient作為消費端（服務消費者）可以從Eureka Server中獲取到服務注冊資訊，進?服務調?，

4）微服務啟動后，會周期性地向Eureka Server發送?跳（默認周期為30秒）以續約??的資訊

5） Eureka Server在?定時間內沒有接收到某個微服務節點的?跳， EurekaServer將會注銷該微服務節點（默認90秒）

6）每個Eureka Server同時也是Eureka Client，多個Eureka Server之間通過復制的?式完成服務注冊串列的同步

7） Eureka Client會快取Eureka Server中的資訊，即使所有的Eureka Server節點都宕掉，服務消費者依然可以使?快取中的資訊找到服務提供者

Eureka通過?跳檢測、健康檢查和客戶端快取等機制，提?系統的靈活性、可
伸縮性和可?性，

3.Eureka應?及?可?集群

1）單實體Eureka Server—>訪問管理界?—>Eureka Server集群
2）服務提供者（簡歷微服務注冊到集群）
3）服務消費者（?動投遞微服務注冊到集群/從Eureka Server集群獲取服務資訊）
4）完成調?

3.1 搭建單例Eureka Sserver服務注冊中心

基于Maven構建SpringBoot工程，在SpringBoot工程之上搭建EurekaServer服務

<!--子專案中參考一個依賴而不用顯示的列出版本號,maven會找到一個擁有dependencyManagement元素的專案，然后就會使用在這個元素中指定的版本號，-->
<dependencyManagement>
  <dependencies>
    <!--spring cloud依賴掛你，引入SpringCloud的版本-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Greenwich.RELEASE</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>

引入eureka-server

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  </dependency>
</dependencies>

需要?動引?jaxb的jar，因為Jdk9之后默認沒有加載該模塊， EurekaServer使?到，所以需要?動導?，否則EurekaServer服務?法啟動

<!--引?Jaxb，開始-->
<dependency>
  <groupId>com.sun.xml.bind</groupId>
  <artifactId>jaxb-core</artifactId>
  <version>2.2.11</version>
</dependency>
<dependency>
  <groupId>javax.xml.bind</groupId>
  <artifactId>jaxb-api</artifactId>
</dependency>
<dependency>
  <groupId>com.sun.xml.bind</groupId>
  <artifactId>jaxb-impl</artifactId>
  <version>2.2.11</version>
</dependency>
<dependency>
  <groupId>org.glassfish.jaxb</groupId>
  <artifactId>jaxb-runtime</artifactId>
  <version>2.2.10-b140310.1920</version>
</dependency>
<dependency>
  <groupId>javax.activation</groupId>
  <artifactId>activation</artifactId>
  <version>1.1.1</version>
</dependency>
<!--引?Jaxb，結束-->

配置application.xml

#Eureka server服務端?
server:
  port: 8761
spring:
  application:
    name: spring-cloud-eureka-server # 應?名稱，會在Eureka中作為服務的
#id標識（serviceId）
eureka:
  instance:
    hostname: localhost
  client:
    service-url: # 客戶端與EurekaServer互動的地址，如果是集群，也需要寫其
      # 它Server的地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
    register-with-eureka: false # ??就是服務不需要注冊??
    fetch-registry: false #??就是服務不需要從Eureka Server獲取服務資訊,默認為true，置為false

在SpringBoot啟動類使?@EnableEurekaServer宣告當前項?為EurekaServer服務

@SpringBootApplication
// 宣告當前專案為Eureka專案
@EnableEurekaServer
public class EurekaServerApp8761 {
  public static void main(String[] args) {
    SpringApplication.run(EurekaServerApp8761.class,args);
  }
}

啟動專案，訪問http://127.0.0.1:8761，看到下面界面（Eureka注冊中心后臺），表明布置成功，

3.2 搭建Eureka Server集群服務

接下來我們開啟兩臺EurekaServer 以搭建集群

1. 修改本機host屬性

由于是在個?計算機中進?測驗很難模擬多主機的情況， Eureka配置server集群時需要執?host地址，所以需要修改個?電腦中host地址

127.0.0.1 LagouCloudEurekaServerA
127.0.0.1 LagouCloudEurekaServerB

2. 創建一個新的springBoot專案，復制之前的代碼

3. 修改兩個工程的yml檔案

#Eureka server服務端?
server:
  port: 8761
spring:
  application:
    name: spring-cloud-eureka-server # 應?名稱，會在Eureka中作為服務的
#id標識（serviceId）
eureka:
  instance:
    hostname: MyfCloudEurekaServerA
  client:
    service-url: # 客戶端與EurekaServer互動的地址，如果是集群，也需要寫其
      # 它Server的地址
      defaultZone: http://MyfCloudEurekaServerB:8762/eureka/
    register-with-eureka: true # ??就是服務不需要注冊??
    fetch-registry: true #??就是服務不需要從Eureka Server獲取服務資訊,默認為true，置為false

#Eureka server服務端?
server:
  port: 8762
spring:
  application:
    name: spring-cloud-eureka-server # 應?名稱，會在Eureka中作為服務的
#id標識（serviceId）
eureka:
  instance:
    hostname: MyfCloudEurekaServerB
  client:
    service-url: # 客戶端與EurekaServer互動的地址，如果是集群，也需要寫其
      # 它Server的地址
      defaultZone: http://MyfCloudEurekaServerA:8761/eureka/
    register-with-eureka: true # ??就是服務不需要注冊??
    fetch-registry: true #??就是服務不需要從Eureka Server獲取服務資訊,默認為true，置為false

在 ?個實體中，把另外的實體作為了集群中的鏡像節點，那么這個http://MyfCloudEurekaServerA:8761/eureka/ URL 中的MyfCloudEurekaServerA 就要和其它個profile 中的eureka.instance.hostname 保持?致
register-with-eureka 和 fetch-registry 在單節點時設定為了 false, 因為
只有?臺 Eureka Server，并不需要??注冊??，?現在有了集群，可以在集群的其他節點中注冊本服務

4. 啟動專案就可以看到后臺管理界面了

http://myfcloudeurekaservera:8761/ http://myfcloudeurekaserverb:8762/

在這里插入圖片描述

3.3 微服務提供者—>注冊到Eureka Server集群

首先你應該有一個能夠對外提供http服務的普通SpringBoot專案，

引入spring-cloud-commons依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-commons</artifactId>
</dependency>

引入eureka client的相關坐標

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

配置application.yml?件

在application.yml 中添加Eureka Server?可?集群的地址及相關配置

eureka:
  client:
    service-url:
      defaultZone: http://MyfCloudEurekaServerA:8761/eureka/,http://MyfCloudEurekaServerB:8762/eureka/ #把 eureka 集群中的所有 url 都填寫了進來，也可以只寫?臺，因為各個 eureka server 可以同步注冊表
  instance:
    # 使?ip注冊，否則會使?主機名注冊了（此處考慮到對?版本的兼容，新版本經過實驗都是ip）
    prefer-ip-address: true
    # ?定義實體顯示格式，加上版本號，便于多版本管理，注意是ip-address，早期版本是ipAddress
    instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}:@project.version@

經驗：?定義實體顯示格式，加上版本號，便于多版本管理

啟動類添加注解
```
@EnableEurekaClient
```
從Spring Cloud Edgware版本開始， @EnableDiscoveryClient 或@EnableEurekaClient 可省略，只需加上相關依賴，并進?相應配置，即可將微服務注冊到服務發現組件上，

@EnableDiscoveryClient和@EnableEurekaClient?者的功能是?樣的，但是如果選?的是eureka服務器，那么就推薦@EnableEurekaClient，如果是其他的注冊中?，那么推薦使?@EnableDiscoveryClient，考慮到通?性，后期我們可以使?@EnableDiscoveryClient
啟動成功既可以在注冊中心找到注冊的服務實體，其他服務參照即可，

在這里插入圖片描述

3.4 微服務消費者->注冊到Eureka Server集群

添加eureka client的相關坐標

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-commons</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-netflix-eurekaclient</artifactId>
</dependency>

配置application.yml檔案

server:
  port: 8090 # 后期該微服務多實體，端?從8090遞增（10個以內）
eureka:
  client:
    service-url:
      defaultZone: http://MyfCloudEurekaServerA:8761/eureka/,http://MyfCloudEurekaServerB:8762/eureka/ #把 eureka 集群中的所有 url 都填寫了進來，也可以只寫?臺，因為各個 eureka server 可以同步注冊表
  instance:
    # 使?ip注冊，否則會使?主機名注冊了（此處考慮到對?版本的兼容，新版本經過實驗都是ip）
    prefer-ip-address: true
    # ?定義實體顯示格式，加上版本號，便于多版本管理，注意是ip-address，早期版本是ipAddress
    instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}:@project.version@
spring:
  application:
    name: myf-service-autodeliver

在啟動類添加注解@EnableDiscoveryClient，開啟服務發現

@SpringBootApplication
@EnableDiscoveryClient
public class AutodeliverApplication {
  public static void main(String[] args) {
    SpringApplication.run(AutodeliverApplication.class,args);
  }

  /**
     * 注?RestTemplate
     * @return
     */
  @Bean
  public RestTemplate getRestTemplate() {
    return new RestTemplate();
  }
}

服務消費者調?服務提供者（通過Eureka）

@RestController
@RequestMapping("/autodeliver")
public class AutodeliverController {

  @Autowired
  private RestTemplate restTemplate;

  @Autowired
  private DiscoveryClient discoveryClient;

  @GetMapping("/checkState/{userId}")
  public Integer findResumeOpenState(@PathVariable Long userId){
    // 1. 獲取Eureka中注冊的user-service實體串列
    List<ServiceInstance> instances = discoveryClient.getInstances("MYF-SERVICE-RESUME");
    // 2. 獲取實體（此處我們不考慮負載均衡，就拿第一個）
    ServiceInstance serviceInstance = instances.get(0);
    // 3. 根據實體的資訊拼接請求地址
    int port = serviceInstance.getPort();
    String host = serviceInstance.getHost();
    String url = "http://"+host+":"+port+"/resume/openstate/";
    System.out.println(url);

    Integer forObject = restTemplate.getForObject(url + userId, Integer.class);
    System.out.println("======>>>調?簡歷微服務，獲取到?戶" +
                       userId + "的默認簡歷當前狀態為： " + forObject);
    return forObject;
  }
}

4. Eureka 詳解

4.1 Eureka元資料

Eureka的元資料有兩種：標準元資料和?定義元資料

標準元資料：主機名、 IP地址、端?號等資訊，這些資訊都會被發布在服務注冊表中，?于服務之間的調?，

?定義元資料：可以使?eureka.instance.metadata-map配置，符合KEY/VALUE的存盤格式，這些元資料可以在遠程客戶端中訪問，

示例：

instance:
	prefer-ip-address: true
  metadata-map:
    # ?定義元資料(kv?定義)
    cluster: cl1
    region: rn1

元資料會存放在ServiceInstance中metadata這個map成員變數中

在這里插入圖片描述

4.2 Eureka客戶端詳解

服務提供者（也是Eureka客戶端）要向EurekaServer注冊服務，并完成服務續約等?作

服務注冊詳解

匯入eureka-client依賴坐標，配置Eureka服務注冊中心地址，
服務在啟動時會向注冊中心發起注冊請求，攜帶服務元資料資訊，
Eureka注冊中心會把服務的資訊保存在Map中，

服務續約詳解

服務每隔30秒會向注冊中心續約（心跳）一次，如果沒有續約，租期在90秒后到期，然后服務會被失效，每隔30秒的續約操作我們稱之為心跳檢測，

配置，往往不需要修改

#向Eureka服務中?集群注冊服務
eureka:
	instance:
    # 租約續約間隔時間，默認30秒
    lease-renewal-interval-in-seconds: 30
    # 租約到期，服務時效時間，默認值90秒,服務超過90秒沒有發??跳，EurekaServer會將服務從串列移除
    lease-expiration-duration-in-seconds: 90

獲取服務串列詳解（服務消費者）

每隔30秒會從注冊中心拉取一份服務串列，

配置，往往不需要修改，

#向Eureka服務中?集群注冊服務
eureka:
  client:
    # 每隔多久拉取?次服務串列
    registry-fetch-interval-seconds: 30

服務啟動時，從EureakServer服務串列獲取只讀備份，快取到本地，
每隔30秒，從新獲取并更新資料，

4.3 Eureka服務端詳解

服務下線

當服務正常關閉操作時，會發送服務下線的REST請求給EurekaServer，
服務中心接收到請求后，將該服務置為下線狀態，

失效剔除

EurekaServer會定時（間隔值是eureka.server.eviction-interval-timer-in-ms，默認60s）進?檢查，如果發現實體在在?定時間（此值由客戶端設定的eureka.instance.lease-expiration-duration-in-seconds定義，默認值為90s）內沒有收到?跳，則會注銷此實體，

自我保護

If any time, the renewals falls below the percent configured for that value (below 85% within 15 mins), the server stops expiring instances to protect the current instance registry information.

定期的續約（服務提供者和注冊中心通信），假如服務提供者和注冊中心之間的網路有點問題，不代表服務提供者不可用，不代表消費者無法訪問服務提供者，如果15分鐘內超過85%的客戶端節點都沒有正常的心跳，那么Eureka久認為客戶端與注冊中心出現了網路故障，EurekaServer自動進入自我保護機制，

為什么會有自我保護機制？

默認情況下，如果EurekaServer在一定時間內（默認90秒）沒有接收到某個微服務實體的心跳，EurekaServer將會移除該實體，但是當網路磁區故障發生時，微服務與EurekaServer之間無法正常通信，而微服務本身是正常運行的，此時不應該移除這個微服務，所以引入了自我保護機制，

注冊中心頁面會顯示出如下提示資訊
在這里插入圖片描述

當處于?我保護模式時

不會剔除任何服務實體（可能是服務提供者和EurekaServer之間?絡問題），保證了?多數服務依然可?，
Eureka Server仍然能夠接受新服務的注冊和查詢請求，但是不會被同步到其它節點上，保證當前節點依然可?，當?絡穩定時，當前Eureka Server新的注冊資訊會被同步到其它節點中，
在Eureka Server?程中通過eureka.server.enable-self-preservation配置可?關停?我保護，默認值是打開，

eureka:
  server:
  	enable-self-preservation: false # 關閉?我保護模式（預設為打開）

建議?產環境打開?我保護機制

注：大佬建議看官網，立個flag我會去的

轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/286375.html

標籤：其他

上一篇：云計算中的Server Consolidation

下一篇：2個周末，歷時100+小時，YourBatman新版Blog正式上線