2.Spring Cloud Eureka详解

古城微笑少年丶 2022-02-04 06:34 220阅读 0赞

**1.Eureka简介**  
Eureka是Netflix开发的服务发现组件，本身是一个基于REST的服务。Spring Cloud将它集成在其子项目spring-cloud-netflix中，以实现Spring Cloud的服务发现功能。  
本文讲解的Spring Cloud Finchley.SR2所使用的Eureka版本是2.0.2.RELEASE，还是比较新的一个版本。  
**2.Eureka与zookeeper对比**  
在分布式系统领域有个著名的CAP定理（C-数据一致性；A-服务可用性；P-服务对网络分区故障的容错性，这三个特性在任何分布式系统中不能同时满足，最多同时满足两个）；  
ZooKeeper是个CP的，即任何时刻对ZooKeeper的访问请求能得到一致的数据结果，同时系统对网络分割具备容错性；但是它不能保证每次服务请求的可用性，zookeeper的集群一般为3台以上的集群，服务宕机会触发zk的选举机制只有超过2/3时【（>=N/2+1】集群才能正常工作。  
Eureka是个AP的，在设计时就优先保证可用性。Eureka各个节点都是平等的，几个节点挂掉不会影响正常节点的工作，剩余节点依然可以提供注册和查询服务。而Eureka的客户端在向某个Eureka注册或者如果发现链接失败时，则会自动切换至其他节点，只要有一台Eureka还在，就能保证注册服务可用（保证可用），只不过查到的信息可能不是最新的（不保证一致性）。同时Eureka具有客户端缓存功能，即使所有Eureka服务宕机，服务消费者仍然可以通过缓存获取现有服务的注册信息。  
**3.Eureka使用**  
创建Eureka服务端项目  
pom配置如下，这里需要注意的是Finchley版本导入eureka包的同时需要导入hystrix包，否则启动eureka时会提示错误。

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.8.RELEASE</version>
        <relativePath/> 
    </parent>
    <dependencies>
    		 
            <dependency>
                 <groupId>org.springframework.cloud</groupId>
                 <artifactId>spring-cloud-dependencies</artifactId>
                 <version>Finchley.SR2</version>
                 <type>pom</type>
                 <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-netflix-eureka-server</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-security</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

application.yml配置如下，这里我们采用的是eureka集群配置的方式（3台）。

spring:
      application:
        name: microservice-eureka
    ---
    server:
      port: 8101
    spring:
      profiles: dev-8101
      security:
        user:
          name: wxt_eureka
          password: wxt_eureka
          roles:
            - USER
    eureka:
      instance:
        hostname: 10.xxx.xx.43                                 #eureka实例名称
      environment: uat                                         #指定eureka当前环境
      server:
        enable-self-preservation: false                        #禁用自我保护模式(仅测试时使用)
        eviction-interval-timer-in-ms: 30000                   #清理无效节点的时间间隔(ms)
      client:
        register-with-eureka: false                            #是否将自己注册到Eureka Server
        fetch-registry: false                                  #不通过eureka获取注册信息
        service-url:
          defaultZone: http://wxt_eureka:wxt_eureka@10.xxx.xx.44:8102/eureka/,http://wxt_eureka:wxt_eureka@10.xxx.xx54:8103/eureka/
    ---js
    server:
      port: 8102
    spring:
      profiles: dev-8102
      security:
        user:
          name: wxt_eureka
          password: wxt_eureka
          roles:
            - USER
    eureka:
      instance:
        hostname: 10.xxx.xx.44                                 #eureka实例名称
      environment: uat                                         #指定eureka当前环境
      server:
        enable-self-preservation: false                        #禁用自我保护模式(仅测试时使用)
        eviction-interval-timer-in-ms: 30000                   #清理无效节点的时间间隔(ms)
      client:
        register-with-eureka: false                            #是否将自己注册到Eureka Server
        fetch-registry: false                                  #不通过eureka获取注册信息
        service-url:
          defaultZone: http://wxt_eureka:wxt_eureka@10.xxx.xx.43:8101/eureka/,http://wxt_eureka:wxt_eureka@10.xxx.xx.54:8103/eureka/
    ---
    server:
      port: 8103
    spring:
      profiles: dev-8103
      security:
        user:
          name: wxt_eureka
          password: wxt_eureka
          roles:
            - USER
    eureka:
      instance:
        hostname: 10.xxx.xx.54                                 #eureka实例名称
      environment: uat                                         #指定eureka当前环境
      server:
        enable-self-preservation: false                        #禁用自我保护模式(仅测试时使用)
        eviction-interval-timer-in-ms: 30000                   #清理无效节点的时间间隔(ms)
      client:
        register-with-eureka: false                            #是否将自己注册到Eureka Server
        fetch-registry: false                                  #不通过eureka获取注册信息
        service-url:
          defaultZone: http://wxt_eureka:wxt_eureka@10.xxx.xx.43:8101/eureka/,http://wxt_eureka:wxt_eureka@10.xxx.xx.44:8102/eureka/

eureka服务端项目创建完成后我们可以通过如下命令分别启动。

nohup java -jar microservice-eureka.jar --spring.profiles.active=dev-8101 &
    nohup java -jar microservice-eureka.jar --spring.profiles.active=dev-8102 &
    nohup java -jar microservice-eureka.jar --spring.profiles.active=dev-8103 &

创建eureka客户端项目  
pom配置如下：

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

application.yml配置如下：

eureka:
      client:
        service-url:
          defaultZone: http://yrz_eureka:yrz_eureka@10.168.12.43:8101/eureka/,http://yrz_eureka:yrz_eureka@10.168.12.44:8102/eureka/,http://yrz_eureka:yrz_eureka@10.168.12.54:8103/eureka/
      instance:
        metadata-map:                                                     #元数据设置
          gated-launch: true                                              #灰度调用
        lease-renewal-interval-in-seconds: 2                              #设置心跳的时间间隔（默认是30秒）
        lease-expiration-duration-in-seconds: 5                           #上一次收到client的心跳之后,等待下一次心跳的超时时间（默认是90秒）
        instance-id: ${ spring.application.name}:${ random.int}             #在信息列表时显示主机名称
        prefer-ip-address: true                                           #灰度调用

> instance-id:  s p r i n g . a p p l i c a t i o n . n a m e : \{spring.application.name\}: spring.application.name:\{random.int\}，该项配置主要是防止在同一台机器启动多个服务时，eureka注册中心无法发现的问题。  
> lease-renewal-interval-in-seconds: 2 ，每间隔2s，向服务端发送一次心跳，证明自己依然”存活“。  
> lease-expiration-duration-in-seconds: 5 ，告诉服务端，如果我5s之内没有给你发心跳，就代表我“死”了，请将我踢掉。

**4.eureka自我保护模式**  
eureka服务在三种情况下会出现红色加粗的字体提示  
**1).在配置上，自我保护机制关闭**

RENEWALS ARE LESSER THAN THE THRESHOLD. THE SELF PRESERVATION MODE IS TURNED OFF.THIS MAY NOT PROTECT INSTANCE EXPIRY IN CASE OF NETWORK/OTHER PROBLEMS.

**2).自我保护机制开启了**

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.

**3).在配置上，自我保护机制关闭了，但是一分钟内的续约数没有达到85% ， 可能发生了网络分区**

THE SELF PRESERVATION MODE IS TURNED OFF.THIS MAY NOT PROTECT INSTANCE EXPIRY IN CASE OF NETWORK/OTHER PROBLEMS.

当eureka进入自我保护模式时，解决这种情况的方法主要有以下几种方式：  
**1).等待 Eureka Server 自动恢复**  
正常的情况下，等待网络恢复（或者没有频繁的启动与关闭实例）后，等待一段时间 Eureka Server 会自动关闭自我保护模式，  
但是如果它迟迟没有关闭该模式，就需要采用第二种方式。  
**2).重启 Eureka Server**  
通常而言，PRD 环境建议对 Eureka Server 做负载均衡，这样在依次关闭并开启 Eureka Server 后，无效的实例会被清除，并  
且不会对正常的使用照成影响  
**3).关闭 Eureka 的自我保护模式**  
自我保护模式，当出现网络分区故障、频繁的开启关闭客户端、eureka在短时间内丢失过多客户端时，会进入自我保护模式，即一个服务长时间没有发送心跳，eureka也不会将其删除，默认为true

enable-self-preservation: false                        #禁用自我保护模式(仅测试时使用)

> 关闭自我保护模式，会有另外一个可能的问题，即隔一段时间后，可能会发生实例并未关闭，却无法通过网关访问了，此时很可能是由于网络问题，导致实例（或网关）与 Eureka Server 断开了连接，Eureka Server 已经将其注销（网络恢复后，实例并不会再次注册），此时重启 Eureka Server 节点或实例，并等待一小段时间即可。

**4.eureka使用问题**  
**1).注册服务慢**  
默认情况下客户端发送定期心跳，每次默认间隔时间为30秒，在实例，服务器和客户端在其本地缓存中都具有相同的元数据之前，客户端无法发现服务（因此可能需要3次心跳），可以通过设置lease-renewal-interval-in-seconds值来改变注册慢问题。  
**2).解决Eureka Server不踢出已关停的节点的问题**  
server端:

eureka.server.enable-self-preservation=false           #设为false，关闭自我保护模式
    eureka.server.eviction-interval-timer-in-ms =3000      #清理无效节点的时间间隔（单位毫秒，默认是60*1000）

client端：

eureka.instance.lease-renewal-interval-in-seconds =2      #设置心跳的时间间隔（单位秒，默认30秒）
    eureka.instance.lease-expiration-duration-in-seconds =5   #上一次收到client的心跳之后,等待下一次心跳的超时时间（单位秒，默认90秒）

持续更新…