Nacos 进阶篇---Nacos服务端怎么维护不健康的微服务实例 ？（七）

一、引言

  在 Nacos 后台管理服务列表中，我们可以看到微服务列表，其中有一栏叫“健康实例数”    （如下图），表示对应的客户端实例信息是否可用状态。

 

那Nacos服务端是怎么感知客户端的状态是否可用呢 ？

本章重点：

  • 实例心跳接口做了哪些事情 ？
  • 服务端是怎么维护不健康的实例的，怎么下线不健康实例的，做了哪些操作 ？

二、目录     

目录

一、引言

二、目录        

三、服务端实例心跳接口源码分析

四、服务端实例心跳健康检查定时任务源码分析

五、总结

   

三、服务端实例心跳接口源码分析

主线任务：实例心跳接口做了哪些事情 ？

 在客户端服务发起注册的时候 (在第二章节)，会开启一个心跳任务，每5s发送一次健康心跳检查，告诉服务端我这个服务还活着。（前面已经讲过

public JsonNode sendBeat(BeatInfo beatInfo, boolean lightBeatEnabled) throws NacosException {

    if (NAMING_LOGGER.isDebugEnabled()) {
        NAMING_LOGGER.debug("[BEAT] {} sending beat to server: {}", namespaceId, beatInfo.toString());
    }
    
    // 组装请求参数
    Map<String, String> params = new HashMap<String, String>(8);
    Map<String, String> bodyMap = new HashMap<String, String>(2);
    if (!lightBeatEnabled) {
        bodyMap.put("beat", JacksonUtils.toJson(beatInfo));
    }
    params.put(CommonParams.NAMESPACE_ID, namespaceId);
    params.put(CommonParams.SERVICE_NAME, beatInfo.getServiceName());
    params.put(CommonParams.CLUSTER_NAME, beatInfo.getCluster());
    params.put("ip", beatInfo.getIp());
    params.put("port", String.valueOf(beatInfo.getPort()));
    
    // 发送实例心跳接口请求
    String result = reqApi(UtilAndComs.nacosUrlBase + "/instance/beat", params, bodyMap, HttpMethod.PUT);
    return JacksonUtils.toObj(result);
}

服务端接受到实例心跳接口，会现在内存注册表中找 Instance，如果找不到会重新注册。然后提交一个 clientBeatProcessor 异步任务，更改 lastBeat 属性

@CanDistro
@PutMapping("/beat")
@Secured(parser = NamingResourceParser.class, action = ActionTypes.WRITE)
public ObjectNode beat(HttpServletRequest request) throws Exception {

    // 省略部分代码

    // 获取请求参数namespaceId、serviceName
    String namespaceId = WebUtils.optional(request, CommonParams.NAMESPACE_ID, Constants.DEFAULT_NAMESPACE_ID);
    String serviceName = WebUtils.required(request, CommonParams.SERVICE_NAME);
    NamingUtils.checkServiceNameFormat(serviceName);
    Loggers.SRV_LOG.debug("[CLIENT-BEAT] full arguments: beat: {}, serviceName: {}", clientBeat, serviceName);

    // 通过namespaceId、serviceName、ip、port、clusterName 从内存注册表当中获取对应的 Instance 实例对象
    Instance instance = serviceManager.getInstance(namespaceId, serviceName, clusterName, ip, port);

    // 如果 instance 为空，那么会重新注册
    if (instance == null) {
        if (clientBeat == null) {
            result.put(CommonParams.CODE, NamingResponseCode.RESOURCE_NOT_FOUND);
            return result;
        }

        instance = new Instance();
        instance.setPort(clientBeat.getPort());
        instance.setIp(clientBeat.getIp());
        instance.setWeight(clientBeat.getWeight());
        instance.setMetadata(clientBeat.getMetadata());
        instance.setClusterName(clusterName);
        instance.setServiceName(serviceName);
        instance.setInstanceId(instance.getInstanceId());
        instance.setEphemeral(clientBeat.isEphemeral());

        // 这里调用重新注册的方法
        serviceManager.registerInstance(namespaceId, serviceName, instance);
    }

    // 通过namespaceId、serviceName获取对应的 Service
    Service service = serviceManager.getService(namespaceId, serviceName);

    if (service == null) {
        throw new NacosException(NacosException.SERVER_ERROR,
                "service not found: " + serviceName + "@" + namespaceId);
    }
    if (clientBeat == null) {
        clientBeat = new RsInfo();
        clientBeat.setIp(ip);
        clientBeat.setPort(port);
        clientBeat.setCluster(clusterName);
    }

    // 重点：开启异步任务，更改 lastBeat 属性
    service.processClientBeat(clientBeat);
    
    // 省略部分代码
    return result;
}

接着往下看重点 service.processClientBeat() 任务，这个方法会开启一个异步任务，异步任务的话肯定会有run 方法，那我们直接看 clientBeatProcessor 对象中的 run 方法

public void processClientBeat(final RsInfo rsInfo) {
    ClientBeatProcessor clientBeatProcessor = new ClientBeatProcessor();
    clientBeatProcessor.setService(this);
    clientBeatProcessor.setRsInfo(rsInfo);
    // 立即执行
    HealthCheckReactor.scheduleNow(clientBeatProcessor);
}

在异步任务当中，首先会获取当前节点下所有的临时实例，然后通过 ip+port 找到当前 instance，然后把 instance 中的 lastBeat属性更改为当前时间，并且如果 该 instance 为不健康状态，更改为健康状态

public class ClientBeatProcessor implements Runnable {

    public static final long CLIENT_BEAT_TIMEOUT = TimeUnit.SECONDS.toMillis(15);

    private RsInfo rsInfo;

    private Service service;

    @JsonIgnore
    public PushService getPushService() {
        return ApplicationUtils.getBean(PushService.class);
    }

    public RsInfo getRsInfo() {
        return rsInfo;
    }

    public void setRsInfo(RsInfo rsInfo) {
        this.rsInfo = rsInfo;
    }

    public Service getService() {
        return service;
    }

    public void setService(Service service) {
        this.service = service;
    }

    @Override
    public void run() {
        Service service = this.service;
        if (Loggers.EVT_LOG.isDebugEnabled()) {
            Loggers.EVT_LOG.debug("[CLIENT-BEAT] processing beat: {}", rsInfo.toString());
        }

        // 本小节重点方法
        // 获取当前 ip、clusterName
        String ip = rsInfo.getIp();
        String clusterName = rsInfo.getCluster();
        int port = rsInfo.getPort();
        Cluster cluster = service.getClusterMap().get(clusterName);
        // 获取当前 cluster 下所有的临时实例
        List<Instance> instances = cluster.allIPs(true);

        // 遍历临时实例
        for (Instance instance : instances) {
            // 通过判断ip、port，确认是否是当前 instance 的实例
            if (instance.getIp().equals(ip) && instance.getPort() == port) {
                if (Loggers.EVT_LOG.isDebugEnabled()) {
                    Loggers.EVT_LOG.debug("[CLIENT-BEAT] refresh beat: {}", rsInfo.toString());
                }
                // 把 lastBeat属性更改为当前时间
                instance.setLastBeat(System.currentTimeMillis());
                if (!instance.isMarked()) {
                    // 如果 instance 为不健康状态，更改为健康状态
                    if (!instance.isHealthy()) {
                        instance.setHealthy(true);
                        Loggers.EVT_LOG
                                .info("service: {} {POS} {IP-ENABLED} valid: {}:{}@{}, region: {}, msg: client beat ok",
                                        cluster.getService().getName(), ip, port, cluster.getName(),
                                        UtilsAndCommons.LOCALHOST_SITE);
                        getPushService().serviceChanged(service);
                    }
                }
            }
        }
    }
}

小结：

     首先在 客户端服务发起注册的时候 (在第二章节)，会开启一个心跳任务，每5s发送一次健康心跳检查，告诉服务端我这个服务还活着。（前面已经讲过）

    那么服务端接受到了 实例心跳接口的请求，会现在内存注册表中找 Instance，如果找不到会重新注册。然后提交一个 clientBeatProcessor 异步任务，在异步任务当中，首先会找到当前集群下的所有临时实例，然后通过 ip +port 找到当前instance 实例，把当前instance 中的 lastBeat属性更改为当前时间，如果 instance 为不健康状态，更改为健康状态，到此实例心跳接口就结束了。

四、服务端实例心跳健康检查定时任务源码分析

主线任务：服务端是怎么维护不健康的实例的，怎么下线不健康实例的，做了哪些操作 ？

     这块代码是在服务端 register（注册）接口当中的，之前分析过 register 注册逻辑，因为这块是分支代码，前面没细看。

   我们来看下 createEmptyService 这个方法了，里面有个异步任务，作用就是：检查有哪些客户端是不健康的状态，如果不健康就需要对它进行处理

public void registerInstance(String namespaceId, String serviceName, Instance instance) throws NacosException {

    // 不知道是创建了一个什么服务
    createEmptyService(namespaceId, serviceName, instance.isEphemeral());

    // 根据namespaceId、serviceName获取 Service服务
    Service service = getService(namespaceId, serviceName);

    // service为空就抛出异常
    if (service == null) {
        throw new NacosException(NacosException.INVALID_PARAM,
                "service not found, namespace: " + namespaceId + ", service: " + serviceName);
    }

    // 上面都是分支代码
    // 主线任务:添加服务实例
    addInstance(namespaceId, serviceName, instance.isEphemeral(), instance);
}

我们直接看重点代码，直接跳到开启异步任务这里。上面的代码流程：createEmptyService()-> createServiceIfAbsent()-> putServiceAndInit(service) -> service.init();

public void init() {
    // 开启异步延时任务 clientBeatCheckTask ，每5s执行一次
    HealthCheckReactor.scheduleCheck(clientBeatCheckTask);
    for (Map.Entry<String, Cluster> entry : clusterMap.entrySet()) {
        entry.getValue().setService(this);
        entry.getValue().init();
    }
}

本章重点，开启了一个 clientBeatCheckTask 异步任务。

@Override
public void run() {
    try {
        // 本章重点
        // 获取全部临时实例
        List<Instance> instances = service.allIPs(true);

        for (Instance instance : instances) {
            // 当前时间 - instance中 lastBeat属性时间  > 15s
            if (System.currentTimeMillis() - instance.getLastBeat() > instance.getInstanceHeartBeatTimeOut()) {
                if (!instance.isMarked()) {
                    if (instance.isHealthy()) {
                        // 如果这个 instance 实例还是健康状态，就更改为 "不健康状态"！
                        instance.setHealthy(false);
                        Loggers.EVT_LOG
                                .info("{POS} {IP-DISABLED} valid: {}:{}@{}@{}, region: {}, msg: client timeout after {}, last beat: {}",
                                        instance.getIp(), instance.getPort(), instance.getClusterName(),
                                        service.getName(), UtilsAndCommons.LOCALHOST_SITE,
                                        instance.getInstanceHeartBeatTimeOut(), instance.getLastBeat());
                        // 事件发布监听事件，通过 upd 协议发送通知
                        getPushService().serviceChanged(service);
                        ApplicationUtils.publishEvent(new InstanceHeartbeatTimeoutEvent(this, instance));
                    }
                }
            }
        }

        if (!getGlobalConfig().isExpireInstance()) {
            return;
        }

        // 这里还是遍历 临时实例
        for (Instance instance : instances) {

            if (instance.isMarked()) {
                continue;
            }

            // 当前时间 - instance中 lastBeat属性时间  > 30s
            if (System.currentTimeMillis() - instance.getLastBeat() > instance.getIpDeleteTimeout()) {
                Loggers.SRV_LOG.info("[AUTO-DELETE-IP] service: {}, ip: {}", service.getName(),
                        JacksonUtils.toJson(instance));
                // 直接从注册表中删除当前 instance
                deleteIp(instance);
            }
        }

    } catch (Exception e) {
        Loggers.SRV_LOG.warn("Exception while processing client beat time out.", e);
    }

}

小结：

  • 第一个循环的作用，为了筛选出不健康的 Instance 实例，并且把 Instance 中的 healthy  属性改为 false。那么怎么筛选出不健康的实例的 ？利用的就是 Instance 中的 lastBeat 属性。如果是健康的实例，那么客户端就会每5s调一次实例心跳接口，更新 lastBeat 属性为当前时间。如果是不健康的实例，那么 Instance 实例 中的 lastBeat 属性是不会变化的，一旦 lastBeat 跟当前时间比超过 15s，就会被认定为不健康的实例。
  • 第二个循环的作用，找出那些 Instance 是需要删除的，如果 lastBeat 跟当前时间比超过 30s，Nacos 会把该 Instance 从注册表当中进行删除。
五、总结

总结：

     本章讲了Nacos怎么维护整个微服务实例健康状态的流程，在客户端发起注册服务时会有心跳任务，每5s给服务端发送一次心态，服务端会把该 Instance 实例中的lastBeat 属性更新为当前时间。并且在服务端实例注册的时候，会开启心跳健康检查任务，把 lastBeat 跟当前时间比超过 15s，就会被标识为不健康的实例，把lastBeat 跟当前时间比超过 30s，Nacos 会把该 Instance 从注册表当中进行删除。

最后的最后，别忘了把源码分析图补充完整： 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/633542.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Go-zero（api部分）

Go-zero（api部分）

目录 api的语法&#xff1a; type&#xff1a;用于定义请求/响应体 service&#xff1a;定义HTTP服务 server&#xff1a;控制生成HTTP服务时候的meta信息 根据api文档生成最小HTTP服务 目录结构 api响应封装 api的语法&#xff1a; 首先定义一个api文档 type&#xff…
阅读更多...
nginx+nginx-http-flv-module在Linux服务器搭建

nginx+nginx-http-flv-module在Linux服务器搭建

需求 在服务器搭建点播/视频平台的话需要在服务器搭建nginx和rtmp模块 rtmp模块 rtmp 模块有 nginx-rtmp-module &#xff0c;但是我们这里使用 nginx-http-flv-module 来替代。因为后者是基于前者开发的&#xff0c;前者拥有的功能后者都有&#xff0c;后者是国内的开发开…
阅读更多...
资源回收：从冷门到热门，未来的智慧与潜力不可小觑|中联环保圈

资源回收：从冷门到热门，未来的智慧与潜力不可小觑|中联环保圈

近年来&#xff0c;资源回收成为了越来越热门的话题。今年的工作报告中明确提出&#xff0c;2024 年要大力推动废弃物循环利用。这意味着资源回收领域将迎来更多商机&#xff0c;逐渐成为环保产业中的重要一员。 回首过去&#xff0c;十年前的资源回收业务相对简单&#xff0c;…
阅读更多...
中国医学健康管理数字化发展风向标——专家共话未来趋势

中国医学健康管理数字化发展风向标——专家共话未来趋势

随着科技的飞速发展&#xff0c;数字化已经成为中国医学健康管理领域的重要发展方向。 2024年5月20日由中国管理科学研究院智联网研究所、中国民族医药协会医养教育委员会、国家卫健委基层健康服务站、中国老龄事业发展基金会、中国智联网健康管理系统平台、中国医学健康管理数…
阅读更多...
自动化测试--利用pytest实现整条业务链路测试

自动化测试--利用pytest实现整条业务链路测试

​ 概述 前面一章讲解了单个接口的测试&#xff0c;但是实际项目中&#xff0c;因为权限和登录状态的限制&#xff0c;大部分接口没办法直接访问到&#xff0c;这时候我们想访问到一个系统的接口&#xff0c;就需要模拟用户登录拿到用户的token和所拥有的权限之后再将这些信息…
阅读更多...
微软AI版的语音自动操作助手来了；免费部署私人 Gemini 应用的开源项目TalkWithGemini；开源自动化测试Cover-Agent

微软AI版的语音自动操作助手来了；免费部署私人 Gemini 应用的开源项目TalkWithGemini；开源自动化测试Cover-Agent

✨ 1: Microsoft Power Automate Microsoft Power Automate利用自动化和AI来革新工作方式&#xff0c;提高生产力。 微软发布了新版 Power Automate&#xff0c;带来了全新的AI驱动自动化体验。 用户只需通过屏幕分享和语音描述操作步骤&#xff0c;AI便能自动学习并生成工作…
阅读更多...
FreeRTOS_事件组_学习笔记

FreeRTOS_事件组_学习笔记

事件组 原文链接 事件组是一个整数&#xff0c;其中的高8位留给内核&#xff0c;只能用其他位来表示时间 每一位代表一个事件&#xff0c;且每个时间的含义由程序员决定 1为发生&#xff0c;0为未发生 一个/多个任务或ISR都能读写这些位 可以等待某一位&#xff0c;也可以等待…
阅读更多...
网络的基础理解

网络的基础理解

文章目录 网络的基础认识 网络协议协议分层OSI七层模型TCP/IP 五层/四层 模型 网络的基础认识 先来看下面几个问题 什么是网络&#xff1f; 网络就是有许多台设备包括计算机单不仅限于计算机&#xff0c;这些设备通过相互通信所组成起来系统&#xff0c;我们称之为网络所以如…
阅读更多...
CAD2023 2024 2025以上版本出现无法运行 AutoCAD，原因可能如下1) 此版本的 AutoCAD 安装不正确

CAD2023 2024 2025以上版本出现无法运行 AutoCAD，原因可能如下1) 此版本的 AutoCAD 安装不正确

错误提示如下 此版本的 AutoCAD 安装不正确 缺少依赖组件Microsoft Edge webview2 Runtime 缺少依赖组件 Microsoft.NET跟You must install .NET Desktop Runtime 打开autoremove&#xff0c;点击扩展&#xff0c;输入 无法运行&#xff0c;点击搜索 你的软件属于什么版本…
阅读更多...
简单的TCP网络程序：英译汉服务器

简单的TCP网络程序：英译汉服务器

一、服务器的初始化 下面介绍程序中用到的socket API,这些函数都在sys/socket.h中。 1.创建套接字 socket()&#xff1a; ⭐参数介绍&#xff1a; socket()打开一个网络通讯端口,如果成功的话,就像open()一样返回一个文件描述符;应用程序可以像读写文件一样用read/write在网…
阅读更多...
Unity 开发Hololens，制作面板跟随眼镜一起移动，（面板跟踪）

Unity 开发Hololens，制作面板跟随眼镜一起移动，（面板跟踪）

Hololens滑动框以及面板跟踪 创建空物体&#xff0c;并添加组件 SolverHandler、RedialView、FollowMeToggle 创建按钮&#xff0c;控制停止/开始跟踪 创建一个Hololens自带的按钮放到右上角&#xff0c;并添加事件 创建蓝色背景板 创建空物体Backplate&#xff0c;下面再…
阅读更多...
yaml文件格式详解 及 k8s实战演示

yaml文件格式详解 及 k8s实战演示

目录 一 k8s 支持的语言格式 1&#xff0c;YAML 语法格式 2&#xff0c;查看 api 资源版本标签 二 k8s 运行nginx pod实例 yaml文件 具体讲解 1&#xff0c;写一个yaml文件demo 2&#xff0c;deployment 管理nginx 的yaml 文件 3&#xff0c;创建资源对象 4&#…
阅读更多...
基于深度学习的表情识别系统

基于深度学习的表情识别系统

欢迎大家点赞、收藏、关注、评论啦 &#xff0c;由于篇幅有限&#xff0c;只展示了部分核心代码。 文章目录 一项目简介 二、功能三、系统四. 总结 一项目简介 一、项目背景 随着人工智能技术的快速发展&#xff0c;表情识别成为了人机交互领域的一个研究热点。表情识别技术旨…
阅读更多...
优先编码器电路①

优先编码器电路①

优先编码器电路① 坑主要在这个输入的高位和低位上 这里的低位在最左边 就是大小端的问题 module encoder_0(input [8:0] I_n ,output reg [3:0] Y_n ); always(*)begincasex(I_n)9b1111_1111_1: Y_n < 4b1111;9b1111_1111_0: Y_n < 4b1110;9…
阅读更多...
redis--数据类型

redis--数据类型

字符串 字符串是所有编程语言中最常见的和最常用的数据类型&#xff0c;而且也是redis最基本的数据类型之一&#xff0c;而且redis中所有的key的类型都是字符串。常用于保存 Session 信息场景&#xff0c;此数据类型比较常用 命令含义复杂度set key value设置key-valueo(1)get…
阅读更多...
基于 vLLM 搭建 DeepSeek-V2 Chat 服务

基于 vLLM 搭建 DeepSeek-V2 Chat 服务

直奔主题。 安装vLLM 官方实现的代码还没有 merge 到 vLLM 主分支&#xff0c;所以直接 git clone DeepSeek 的分支。 git clone https://github.com/zwd003/vllm.git cd vllm pip install -e .源码安装大概耗时 10 分钟。 OpenAI 接口规范启动 官方 Github 放的是单条推理…
阅读更多...
不闭合三维TSP：成长优化算法GO求解不闭合三维TSP（起点固定，终点不定，可以更改数据集），MATLAB代码

不闭合三维TSP：成长优化算法GO求解不闭合三维TSP（起点固定，终点不定，可以更改数据集），MATLAB代码

一、旅行商问题 旅行商问题&#xff08;Traveling salesman problem, TSP&#xff09;是一个经典的组合优化问题&#xff0c;它可以描述为一个商品推销员去若干城市推销商品&#xff0c;要求遍历所有城市后回到出发地&#xff0c;目的是选择一个最短的路线。当城市数目较少时&…
阅读更多...
Java-MySql：JDBC

Java-MySql：JDBC

目录 JDBC概述 JDBC搭建 1、导入mysql开发商提供的jar包 2、注册驱动 3、与数据库连接 注解&#xff1a; Statement&#xff1a; 代码 运行 PreparedStatement&#xff1a; 代码 运行 PreparedStatement和Statement Statement 增 代码 运行 删 代码 运…
阅读更多...
前端 CSS 经典：filter 滤镜

前端 CSS 经典：filter 滤镜

前言&#xff1a;什么叫滤镜呢&#xff0c;就是把元素里的像素点通过一套算法转换成新的像素点&#xff0c;这就叫滤镜。而算法有 drop-shadow、blur、contrast、grayscale、hue-rotate 等。我们可以通过这些算法实现一些常见的 css 样式。 1. drop-shadow 图片阴影 可以用来…
阅读更多...
民国漫画杂志《时代漫画》第5期.PDF

民国漫画杂志《时代漫画》第5期.PDF

时代漫画05.PDF: https://url03.ctfile.com/f/1779803-1246745815-7953cf?p9586 (访问密码: 9586) 《时代漫画》的杂志在1934年诞生了&#xff0c;截止1937年6月战争来临被迫停刊共发行了39期。 ps:资源来源网络&#xff01;
阅读更多...
最新文章

Copyright @ 2022~2023