NacosServiceRegistry的实现
在NacosServiceRegistry.registry方法中,调用了Nacos Client SDK中的namingService.registerInstance完成服务的注册。
跟踪NacosNamingService的registerInstance()方法：
- 通过
beatReactor.addBeatInfo()创建心跳信息实现健康检测, Nacos Server必须要确保注册的服务实例是健康的,而心跳检测就是服务健康检测的手段。 serverProxy.registerService()实现服务注册
心跳机制：
从上述代码看,所谓心跳机制就是客户端通过schedule定时向服务端发送一个数据包 ,然后启动-个线程不断检测服务端的回应,如果在设定时间内没有收到服务端的回应,则认为服务器出现了故障。Nacos服务端会根据客户端的心跳包不断更新服务的状态。
注册原理：
Nacos提供了SDK和Open API两种形式来实现服务注册。
Open API：
SDK：
这两种形式本质都一样，底层都是基于HTTP协议完成请求的。所以注册服务就是发送一个HTTP请求：
对于nacos服务端，对外提供的服务接口请求地址为nacos/v1/ns/instance，实现代码咋nacos-naming模块下的InstanceController类中：
- 从请求参数汇总获得serviceName（服务名）和namespaceId（命名空间Id）
- 调用registerInstance注册实例
- 创建一个控服务（在Nacos控制台“服务列表”中展示的服务信息），实际上是初始化一个serviceMap，它是一个ConcurrentHashMap集合
- getService，从serviceMap中根据namespaceId和serviceName得到一个服务对象
- 调用addInstance添加服务实例
- 根据namespaceId、serviceName从缓存中获取Service实例
- 如果Service实例为空，则创建并保存到缓存中
- 通过
putService()方法将服务缓存到内存 service.init()建立心跳机制consistencyService.listen实现数据一致性监听
service.init ( )方法的如下图所示，它主要通过定时任务不断检测当前服务下所有实例最后发送心跳包的时间。如果超时,则设置healthy为false表示服务不健康,并且发送服务变更事件。
在这里请大家思考一一个问题,服务实例的最后心跳包更新时间是谁来触发的?实际上前面有讲到, Nacos客户端注册服务的同时也建立了心跳机制。
putService方法，它的功能是将Service保存到serviceMap中：
继续调用addInstance方法把当前注册的服务实例保存到Service中：
总结：
- Nacos客户端通过Open API的形式发送服务注册请求
- Nacos服务端收到请求后，做以下三件事：
- 构建一个Service对象保存到ConcurrentHashMap集合中
- 使用定时任务对当前服务下的所有实例建立心跳检测机制
- 基于数据一致性协议服务数据进行同步
