本篇内容介绍了“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;
}
// 所有临时节点
List instances = 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);
List instances = 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活跃检测方法是什么”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！
