NacosNaming活跃检测方法是什么
本篇内容介绍了“Nacos Naming活跃检测方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
创新互联公司坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站设计、成都网站制作、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的宜良网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
临时服务实例在注册到naming server上之后,会周期性得发送心跳信息来保持节点的活跃。同时,naming server会周期性检测每个实例最后一次收到心跳信息的时间戳,摘除超时的节点并通知所有订阅的客户端。
实例活跃性检测的定时任务封装在Service类中,在init方法里启动:
public class Service extends com.alibaba.nacos.api.naming.pojo.Service implements Record, RecordListener{ private ClientBeatCheckTask clientBeatCheckTask = new ClientBeatCheckTask(this); public void init() { // 启动检测任务 HealthCheckReactor.scheduleCheck(clientBeatCheckTask); ... } }
ClientBeatCheckTask会获取当前服务所有的临时节点并一一检测该节点是否超时:
public class ClientBeatCheckTask implements Runnable { public void run() { try { // 当前服务不由本节点操作,则跳过 if (!getDistroMapper().responsible(service.getName())) { return; } // 所有临时节点 Listinstances = service.allIPs(true); // first set health status of instances: for (Instance instance : instances) { if (System.currentTimeMillis() - instance.getLastBeat() > ClientBeatProcessor.CLIENT_BEAT_TIMEOUT) { if (!instance.isMarked()) { if (instance.isHealthy()) { // 设置为下线 instance.setHealthy(false); // 通知订阅客户端 getPushService().serviceChanged(service.getNamespaceId(), service.getName()); } } } } // .... // then remove obsolete instances: for (Instance instance : instances) { if (System.currentTimeMillis() - instance.getLastBeat() > service.getIpDeleteTimeout()) { // delete instance deleteIP(instance); } } } catch (Exception e) { Loggers.SRV_LOG.warn("Exception while processing client beat time out.", e); } } }
client通过调用/beat这一api来发送心跳信息,该请求在InstanceController.beat(..)方法中被处理,后续调用Service.processClientBeat(..)方法:
// Service类 public void processClientBeat(final RsInfo rsInfo) { ClientBeatProcessor clientBeatProcessor = new ClientBeatProcessor(); clientBeatProcessor.setService(this); clientBeatProcessor.setRsInfo(rsInfo); HealthCheckReactor.scheduleNow(clientBeatProcessor); }
ClientBeatProcessor会更新instance的lastBeat信息:
// ClientBeatProcessor public void run() { Service service = this.service; String ip = rsInfo.getIp(); String clusterName = rsInfo.getCluster(); int port = rsInfo.getPort(); Cluster cluster = service.getClusterMap().get(clusterName); Listinstances = cluster.allIPs(true); for (Instance instance : instances) { if (instance.getIp().equals(ip) && instance.getPort() == port) { // 更新心跳时间 instance.setLastBeat(System.currentTimeMillis()); if (!instance.isMarked()) { if (!instance.isHealthy()) { instance.setHealthy(true); getPushService().serviceChanged(service.getNamespaceId(), this.service.getName()); } } } } }
“Nacos Naming活跃检测方法是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!
网页名称:NacosNaming活跃检测方法是什么
URL分享:http://scyanting.com/article/jcghip.html