心跳机制及健康监测 Nacos源码阅读系列2

服务注册
前面已经准备了源码环境
谈及Nacos , 服务注册中心不可不提及
问题1: 服务注册流程(服务端处理逻辑)
问题2:客户端心跳机制及服务端的健康检测
注册成功后客户端默认每隔五秒发一次心跳,接口:( /v1/ns/beat)
服务端在客户端注册过程中,会创建定时任务去检查,默认情况下,超15秒 , 将服务置为不健康 , 超30s,删除客户端服务
入口:nacos-模块提供api接口:(.) /v1/ns/
getInstanceOperator().registerInstance(namespaceId, serviceName, instance);//方法内重要代码(下面一一说明)createIpPortClientIfAbsent(clientId);//code_1Service service = getService(namespaceId, serviceName, ephemeral);//code_2clientOperationService.registerInstance(service, instance, clientId);//code_3
();//

心跳机制及健康监测  Nacos源码阅读系列2

文章插图
作用:创建一个客户端,并添加到定时任务中定时(默认5s)检测客户端状态,实现健康检测
实现原理:客户端默认五秒发一次心跳,服务端会更新字段,默认情况下,超15s,置为不健康,.(false);,超30秒,删除客户端服务,.e();
= (, , );//
此处构建一个对象 , 暂不做解释,其结构为:
ce.(, , );//
Service singleton = ServiceManager.getInstance().getSingleton(service);//code_3.1client.addServiceInstance(singleton, instanceInfo);//code_3.2
.1
心跳机制及健康监测  Nacos源码阅读系列2

文章插图
先了解服务端如何保存客户端服务的(结构如下,图片引用)
相关代码:
//保存客户端服务容器private final ConcurrentHashMap singletonRepository;//通过key做环境隔离 key:Service.getNamespace()private final ConcurrentHashMap> namespaceSingletonMaps;
.2
客户端保存发布者信息(客户端发送心跳请求,会使用到 )
IpPortBasedClient:ConcurrentHashMap publishers = new ConcurrentHashMap<>(16, 0.75f, 1);publishers.put(service, instancePublishInfo)
【心跳机制及健康监测Nacos源码阅读系列2】总结:nacos心跳机制及健康检查有了个初步的了解
仔细看了下源码,nacos-.包 , 大概结构如下(发布–订阅模式)
简单聊聊这个设计模式,通俗来讲就是:“我放个屁股在这里,有瓜踢一下”,或者举个例子
我是一个销售人员,专门卖BYD电动汽车的,A,B,C三个用户找我买比亚迪汉 , 巧了暂时没有货,然后他们每人给了一个联系方式给我,等哪天有货了,我再去通知他们过来买车 。