注冊中心-Eureka

Spring Cloud 封裝了 Netflix 公司開發的 Eureka 模塊來實現服務注冊和發現。Eureka 采用了 C-S 的設計架構。Eureka Server 作為服務注冊功能的服務器，它是服務注冊中心。而系統中的其他微服務，使用 Eureka 的客戶端連接到 Eureka Server，并維持心跳連接。這樣系統的維護人員就可以通過 Eureka Server 來監控系統中各個微服務是否正常運行。Spring Cloud 的一些其他模塊（比如Zuul）就可以通過 Eureka Server 來發現系統中的其他微服務，并執行相關的邏輯。

 

它主要包括兩個組件：Eureka Server 和 Eureka Client

• Eureka Client：一個Java客戶端，用于簡化與 Eureka Server 的交互（通常就是微服務中的客戶端和服務端）
• Eureka Server：提供服務注冊和發現的能力（通常就是微服務中的注冊中心）

Eureka自我保護模式

如果 Eureka 服務器檢測到超過預期數量的注冊客戶端以一種不優雅的方式終止了連接，并且同時正在等待被驅逐，那么它們將進入自我保護模式。這樣做是為了確保災難性網絡事件不會擦除eureka注冊表數據，并將其向下傳播到所有客戶端。

任何客戶端，如果連續3次心跳更新失敗，那么它將被視為非正常終止，病句將被剔除。當超過當前注冊實例15%的客戶端都處于這種狀態，那么自我保護將被開啟。

當自我保護開啟以后，eureka服務器將停止剔除所有實例，直到：

它看到的心跳續借的數量回到了預期的閾值之上，或者

自我保護被禁用

默認情況下，自我保護是啟用的，并且，默認的閾值是要大于當前注冊數量的15%
 

 

如何使用？

導入依賴

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

主啟動類添加注解

@EnableEurekaServer

 

服務器端的配置

server:
  port: 7001

eureka:
  instance:
    hostname: localhost #eureka服務端的實例名稱
  client:
    #false表示不向注冊中心注冊自己
    register-with-eureka: false
    #false表示自己就是注冊中心。職責是維護服務實例，并不需要去檢索服務
    fetch-registry: false
    service-url:
      #設置與eureka server交互的地址 ，查詢服務和注冊服務都需要依賴于這個地址
      defaultZone: http://localhost:${server.port}/eureka/
        # localhost:7001

 

 

客戶端的配置

創建提供服務的客戶端，并向服務注冊中心注冊自己。

實現一個RESTful API，通過傳入兩個參數a和b，最后返回a + b的結果

這個依賴是專屬于客戶端的

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

yml配置 

eureka:
  client:
    #表示向注冊中心注冊自己，如果false則不會再網頁上看到自己的項目spring.application.name
    register-with-eureka: true
    #是否從EurekaServer抓取已有的注冊信息，默認為true。單節點無所謂，集群必須配置了true才能配合ribbon使用負載均衡
    fetch-registry: true
    service-url:
      #設置與eureka server交互的地址 ，查詢服務和注冊服務都需要依賴于這個地址
      defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: payment8001
    prefer-ip-address: true

 

@RestController
public class ComputeController {

    private final Logger logger = Logger.getLogger(getClass());

    @Autowired
    private DiscoveryClient client;

    @RequestMapping(value = "/add" ,method = RequestMethod.GET)
    public Integer add(@RequestParam Integer a, @RequestParam Integer b) {
        ServiceInstance instance = client.getLocalServiceInstance();
        Integer r = a + b;
        logger.info("/add, host:" + instance.getHost() + ", service_id:" + instance.getServiceId() + ", result:" + r);
        return r;
    }

}

 

啟動類中添加注解，是用于表明是個EurekaClient

@EnableEurekaClient

 

啟動工程后，再次訪問：http://localhost:7001/，可以看到定義的服務被注冊了。