nacos源码学习--健康检查与心跳机制

--------------客户端----------------------------------------

---------------NacosNamingSpaceService------------------
// @ZyxNote健康检查与心跳
@Override
public void registerInstance(String serviceName, String groupName, Instance instance) throws NacosException {
NamingUtils.checkInstanceIsLegal(instance);
String groupedServiceName = NamingUtils.getGroupedName(serviceName, groupName);
// @ZyxNote健康检查与心跳 首先判断 是不是临时实例
if (instance.isEphemeral()) {
BeatInfo beatInfo = beatReactor.buildBeatInfo(groupedServiceName, instance);
// @ZyxNote健康检查与心跳 注册实例的时候 添加了一个BeatInfo 追进去
beatReactor.addBeatInfo(groupedServiceName, beatInfo);
}
serverProxy.registerService(groupedServiceName, groupName, instance);
}
--------------addBeatInfo(..)-----------------------------
public void addBeatInfo(String serviceName, BeatInfo beatInfo) {
NAMING_LOGGER.info("[BEAT] adding beat: {} to beat map.", beatInfo);
String key = buildKey(serviceName, beatInfo.getIp(), beatInfo.getPort());
BeatInfo existBeat = null;
//fix #1733
if ((existBeat = dom2Beat.remove(key)) != null) {
existBeat.setStopped(true);
}
dom2Beat.put(key, beatInfo);
// @ZyxNote健康检查与心跳 BeatTask implements Runnable 5sec之后执行这个任务 追进去
executorService.schedule(new BeatTask(beatInfo), beatInfo.getPeriod(), TimeUnit.MILLISECONDS);
MetricsMonitor.getDom2BeatSizeMonitor().set(dom2Beat.size());
}
----------------BeatTask.run()------------------------------
先发送一个延时任务
// @ZyxNote健康检查与心跳 点进去 执行了一个延时任务
JsonNode result = serverProxy.sendBeat(beatInfo, BeatReactor.this.lightBeatEnabled);
  -------------sendBeat(..)---------------------
// @ZyxNote健康检查与心跳 一大堆东西封装 调用了这个方法 发送实例心跳
String result = reqApi(UtilAndComs.nacosUrlBase + "/instance/beat", params, bodyMap, HttpMethod.PUT);
------------------------------------------------
定时发心跳的方法
// @ZyxNote健康检查与心跳 执行了一个定时任务 发送心跳
executorService.schedule(new BeatTask(beatInfo), nextTime, TimeUnit.MILLISECONDS);
---------------------------------------------------------
  服务端的心跳定时检查任务
  服务端注册实例后 起一个定时监测心跳任务
public void init() {
// @ZyxNote健康检查与心跳 此处 注册了心跳监测定时任务
HealthCheckReactor.scheduleCheck(clientBeatCheckTask);
for (Map.Entry<String, Cluster> entry : clusterMap.entrySet()) {
entry.getValue().setService(this);
entry.getValue().init();
}
}
------------ClientBeatCheckTask.run()---------------
// @ZyxNote健康检查与心跳 判断服务健康算法
if (System.currentTimeMillis() - instance.getLastBeat() > instance.getInstanceHeartBeatTimeOut()) {
            &
// @ZyxNote健康检查与心跳 判断服务是否存活算法
if (System.currentTimeMillis() - instance.getLastBeat() > instance.getIpDeleteTimeout()) {
----------------------------------------------------------














上一篇:Instance Eviction 导致实例重启


下一篇:Windows环境下VMware虚拟机的自启动与自动关机--命令行操作