springcloud-eureka集群-健康检测

标签: springcloud

我们在使用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端口如下图:

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

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

版权声明:本文为Keith003原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/Keith003/article/details/82215957

智能推荐

循环

与任何程序设计语言一样Java利用条件语句与循环结构确定流程控制,一下总结一下Java中的循环语句: while do while for switch 对于golang来说: switch非常灵活。从第一个expr为true的case开始执行,如果case带有fallthrough,程序会继续执行下一条case,不会再判断下一条case的expr,如果之后的case都有fallthrough,d...

1638 统计只差一个字符的子串数目(动态规划)

1. 问题描述: 给你两个字符串 s 和 t ,请你找出 s 中的非空子串的数目,这些子串满足替换一个不同字符以后,是 t 串的子串。换言之,请你找到 s 和 t 串中恰好只有一个字符不同的子字符串对的数目。比方说, "computer" 和 "computation"...

websocket基本原理

HTTP中一个request只能有一个response。而且这个response也是被动的,不能主动发起 因此过去的服务端推送信息是通过客户端不停的轮询实现的 websocket是双向通信协议,提供了服务端主动推送信息的能力 需要客户端(浏览器)和服务端同时支持 如果经过代理的话,还需要代理支持,否则有些代理在长时间无通信时会自动切断连接 因此WS为了保证连接不被断掉,会发心跳 WebSocket...

mybatis+ehcache二级缓存

导入jar包 mapper.xml文件开启二级缓存 pojo类实现序列化接口 配置ehcache.xml 测试...

python+opencv实现图像拼接

任务 拍摄两张图片去除相同部分,拼接在一起 原图 结果 步骤 读取两张图片 使用sift检测关键点及描述因子 匹配关键点 处理并保存关键点 得到变换矩阵 图像变换并拼接 代码实现 扩展 这里对右边图像进行变换,右边变得模糊,可以修改代码对左边图像变换 这里只有两张图片拼接,可以封装实现多张图片拼接 可以修改代码实现上下图片的拼接...

猜你喜欢

python_sklearn机器学习算法系列之AdaBoost------人脸识别(PCA,决策树)

          注:在读本文之前建议读一下之前的一片文章python_sklearn机器学习算法系列之PCA(主成分分析)------人脸识别(k-NearestNeighbor,KNN)         本文主要目的是通过一个简单的小...

memmove函数与memcpy函数的模拟实现

memmove函数和memcpy函数都是在内存复制任意类型的,但是它俩也有区别。当源区域和目标区域有重复的,memmove函数会复制缓冲区重叠的部分,而memcpy相反,会报出未知错误。 下面给出两个函数的实现 首先,memmove函数。 实现的基本原理如下图。 具体代码如下: memcpy函数的实现很简单,就直接给出源代码了...

SpringFramework核心 - IOC容器的实现 - 总结

1. 概述 把Spring技术内幕第一章和第二章过了一遍,也做了一些笔记, 对IOC容器的实现有了一定皮毛理解,现在跟着源码再过一遍总结一下IOC容器的初始化,Bean的初始化的过程,做一下总结 ① IOC容器和简单工厂模式 在开始之前,先想想我们平时是怎么使用IOC容器为我们管理Bean的,假设我们要把下面的User类交给IOC容器管理 我们不想关心如何创建一个User对象实例的,仅仅在需要他的...

Python和Django的安装

个人博客导航页(点击右侧链接即可打开个人博客):大牛带你入门技术栈  一、下载并安装Python Python 官方下载地址:http://www.python.org/ftp/python/ 我们这里选择的是 Python 2.7.2 。虽然目前最新版是Python 3.2.2, 但是Django目前还不支持 Python 3.2.2。 安装步骤很简单,双击安装包开...