springcloud-eureka集群-健康检测

朴灿烈づ我的快乐病毒、 2022-05-13 22:03 110阅读 0赞

我们在使用eureka服务的时候，如果其中一个服务提供者挂掉，而客户端并不知道从而继续调用服务，会导致异常的发生。所以eureka在服务中心会调用服务注册者的状态，客户端在向服务中心获取服务状态的时候会知道哪个服务提供者已经下线，从而不再继续调用该服务，这里就用到了eureka的健康检测，非常简单，几个配置搞定。

首先是服务中心的配置-application.yml

server:
      port: 8761
    spring:
      profiles: eureka-colony1
    eureka:
      instance:
        hostname: eureka-colony1
      client:
        registerWithEureka: false
        fetchRegistry: false
        serviceUrl:
          defaultZone: http://eureka-colony2:8762/eureka/
      server:
        # 关闭自我保护
        enable-self-preservation: false
        # 清理服务器
        eviction-interval-timer-in-ms: 5000

其次在服务提供者中加入健康检测依赖 pom.xml

<dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

修改服务提供者的配置文件application.yml

spring:
      application:
        name: eureka-service
    
    # 可访问全部敏感端口
    # /evn 服务的全部环境变量信息
    # /health 当前服务状态
    endpoints:
      sensitive: false
    
    eureka:
      instance:
        #心跳设置，告诉服务器该实例仍在使用
        lease-renewal-interval-in-seconds: 5
        #告诉服务器如果10秒内未发送任何续约请求，则关闭该客户端
        lease-expiration-duration-in-seconds: 10
        metadata-map:
          company-name: in
      client:
        serviceUrl:
          defaultZone: http://127.0.0.1:8761/eureka/, http://127.0.0.1:8762/eureka/
        instance-info-replication-interval-seconds: 10
    
    logging:
      level:
        com.netflix: DEBUG

实现两个状态接口

/**
     * 健康检查处理器
     * 将服务提供者的健康状态传递给eureka服务器
     */
    @Component
    public class MyHealthCheckHandler implements HealthCheckHandler {
    
        @Autowired
        private MyHealthIndicator myHealthIndicator;
    
        @Override
        public InstanceInfo.InstanceStatus getStatus(InstanceInfo.InstanceStatus instanceStatus) {
            Status status = myHealthIndicator.health().getStatus();
            if (status.equals(Status.UP)){
                return InstanceInfo.InstanceStatus.UP;
            } else {
                return InstanceInfo.InstanceStatus.DOWN;
            }
        }
    }

/**
     * 自定义健康指示器
     */
    @Component
    public class MyHealthIndicator implements HealthIndicator {
    
        @Override
        public Health health() {
            if(MyRestController.isDB){
                return new Health.Builder(Status.UP).build();
            } else{
                return new Health.Builder(Status.DOWN).build();
            }
        }
    }

编写一个Controller，用来修改某个服务提供者的状态，这里应该是判断某个DB链接是否有效，这里用一个bool值来演示eureka服务的状态变化。

@RestController
    public class MyRestController {
    
        public static boolean isDB = true;
    
        @GetMapping(value = "/setIsDB/{isDB}", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
        public void setIsDB(@PathVariable boolean isDB) {
            this.isDB = isDB;
        }
    
    }

最后是服务客户端，修改application.yml

server:
      port: 8666
    
    spring:
      application:
        name: eureka-invocation
    
    eureka:
      instance:
        # 心跳设置，告诉服务器该实例仍在使用
        lease-renewal-interval-in-seconds: 5
        # 告诉服务器如果10秒内未发送任何续约请求，则关闭该客户端
        lease-expiration-duration-in-seconds: 10
    
      client:
        serviceUrl:
          defaultZone: http://127.0.0.1:8761/eureka/, http://127.0.0.1:8762/eureka/
        # 抓取服务列表
        registry-fetch-interval-seconds: 30
    
    logging:
      level:
        com.netflix: DEBUG

测试，依次启动服务注册中心，服务提供者和服务客户端，现在的服务提供者默认是可以访问的，调用localhost:8081/setIsDB/false方法，将服务提供者的状态设置为false，这时再访问服务中心的8761端口如下图：

![70][]

此时的服务客户端的logger信息中也只能看到自己，8081的服务提供者在服务中心的状态为DOWN，所以不能为客户端提供服务

![70 1][]

当我们再次将8081的服务状态变为true之后，服务才可以继续使用，调用接口localhost:8081/setIsDB/true，服务客户端的logger文件可以看到，8081端口被再次加入到eureka中心，并再次被服务客户端使用

![70 2][]

[70]: /images/20220514/03a99910b60448f6979e590d2012dacb.png
[70 1]: /images/20220514/0c3c97d84f4b4d23a10536e50c55be73.png
[70 2]: /images/20220514/69100756626140778fe7f37e5a290c37.png