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
();//
作用：创建一个客户端，并添加到定时任务中定时（默认5s）检测客户端状态，实现健康检测
实现原理：客户端默认五秒发一次心跳，服务端会更新字段，默认情况下，超15s，置为不健康，.(false);，超30秒，删除客户端服务，.e();
= (, , );//
此处构建一个对象，暂不做解释，其结构为：
ce.(, , );//
Service singleton = ServiceManager.getInstance().getSingleton(service);//code_3.1client.addServiceInstance(singleton, instanceInfo);//code_3.2
.1
先了解服务端如何保存客户端服务的（结构如下，图片引用）
相关代码：
//保存客户端服务容器private final ConcurrentHashMap<Service, Service> singletonRepository;//通过key做环境隔离 key：Service.getNamespace()private final ConcurrentHashMap<String, Set<Service>> namespaceSingletonMaps;
.2
客户端保存发布者信息(客户端发送心跳请求，会使用到 )
IpPortBasedClient：ConcurrentHashMap<Service, InstancePublishInfo> publishers = new ConcurrentHashMap<>(16, 0.75f, 1);publishers.put(service, instancePublishInfo)
总结：nacos心跳机制及健康检查有了个初步的了解
仔细看了下源码，nacos-.包，大概结构如下（发布–订阅模式）
简单聊聊这个设计模式，通俗来讲就是：“我放个屁股在这里，有瓜踢一下”，或者举个例子
我是一个销售人员，专门卖BYD电动汽车的，A，B，C三个用户找我买比亚迪汉，巧了暂时没有货，然后他们每人给了一个联系方式给我，等哪天有货了，我再去通知他们过来买车。
