程序员最近都爱上了这个网站  程序员们快来瞅瞅吧！  it98k网:it98k.com

Nacos介绍

Nacos中文官方文档：https://nacos.io/zh-cn/docs/quick-start.html

Nacos是什么？

Nacos是一个注册中心组件，Nacos也是一个配置中心，比如SpringCloud中的Config，将配置文件版本化管理。

那么Nacos到底是什么呢, 总结为官网一句话就是:

Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。

Nacos功能

1. 服务注册发现和服务健康检测

Nacos支持基于DNS和基于RPC的服务发现，服务端可以通过SDK或者Api进行服务注册，相应的服务消费者可以使用DNS或者Http查找的方式获取服务列表。Nacos同时提供对服务的实时健康检查，阻止不健康的主机或服务发送请求，与Eureka类似Nacos也有友好的控制台界面。

2. 动态配置服务

接触过SpringCloud应该对config有所了解，那么配置中心也就很好理解，Nacos支持动态的配置管理，将服务的配置信息分环境分类别外部管理，并且支持热更新。不过与Config不同Nacos的配置信息存储与数据库中，支持配置信息的监听和版本回滚。

3. 动态DNS服务

支持权重路由，更容易地实现中间层负载均衡、更灵活的路由策略、流量控制以及数据中心内网的简单DNS解析服务。不过这个特性目前版本还不支持

4. 服务及元数据管理

Nacos 能让您从微服务平台建设的视角管理数据中心的所有服务及元数据，包括管理服务的描述、生命周期、服务的静态依赖分析、服务的健康状态、服务的流量管理、路由及安全策略、服务的 SLA 以及最首要的 metrics 统计数据。

Nacos架构

• Provider APP：服务提供者
• Consumer APP：服务消费者
• Name Server：通过VIP（Virtual IP）或DNS的方式实现Nacos高可用集群的服务路由
• Nacos Server：Nacos服务提供者，里面包含的Open API是功能访问入口，Conig Service、Naming Service 是Nacos提供的配置服务、命名服务模块。Consitency Protocol是一致性协议，用来实现Nacos集群节点的数据同步，这里使用的是Raft算法（Etcd、Redis哨兵选举）
• Nacos Console：控制台

Nacos注册中心原理

1. 服务实例在启动时注册到服务注册表，并在关闭时注销
2. 服务消费者查询服务注册表，获得可用实例
3. 服务注册中心需要调用服务实例的健康检查API来验证它是否能够处理请求

服务完成注册的时机

在Spring-Cloud-Common包中有一个类org.springframework.cloud. client.serviceregistry.ServiceRegistry ,它是Spring Cloud提供的服务注册的标准。集成到Spring Cloud中实现服务注册的组件,都会实现该接口。

该接口有一个实现类是NacosServiceRegistry：

SpringCloud集成Nacos的实现过程

在spring-cloud-commons包的META-INF/spring.factories中包含自动装配的配置信息如下：

其中AutoServiceRegistrationAutoConfiguration就是服务注册相关的配置类：

在AutoServiceRegistrationAutoConfiguration配置类中,可以看到注入了一个AutoServiceRegistration实例,该类的关系图如下所示:

可以看出, AbstractAutoServiceRegistration抽象类实现了该接口,并且最重要的是NacosAutoServiceRegistration继承了AbstractAutoServiceRegistration。

看到EventListener我们就应该知道，Nacos是通过Spring的事件机制继承到SpringCloud中去的。

AbstractAutoServiceRegistration实现了onApplicationEvent抽象方法,并且监听WebServerInitializedEvent事件(当Webserver初始化完成之后) , 调用this.bind ( event )方法。

最终会调用NacosServiceREgistry.register()方法进行服务注册:

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中：

服务提供者地址查询

Open API：

SDK：

InstanceController中的list方法：

• 解析请求参数
• 通过doSrvIPXT返回服务列表数据

• 根据namespaceId、serviceName获得Service实例
• 从Service实例中基于srvIPs得到所有服务提供者实例
• 遍历组装JSON字符串并返回

Nacos服务地址动态感知原理

可以通过subscribe方法来实现监听，其中serviceName表示服务名、EventListener表示监听到的事件：

具体调用方式如下：

或者调用selectInstance方法，如果将subscribe属性设置为true，会自动注册监听：

Nacos客户端中有一个HostReactor类，它的功能是实现服务的动态更新，基本原理是：

• 客户端发起时间订阅后，在HostReactor中有一个UpdateTask线程，每10s发送一次Pull请求，获得服务端最新的地址列表
• 对于服务端，它和服务提供者的实例之间维持了心跳检测，一旦服务提供者出现异常，则会发送一个Push消息给Nacos客户端，也就是服务端消费者
• 服务消费者收到请求之后，使用HostReactor中提供的processServiceJSON解析消息，并更新本地服务地址列表

总结：

• Nacos客户端通过Open API的形式发送服务注册请求
• Nacos服务端收到请求后，做以下三件事：
  1、构建一个Service对象保存到ConcurrentHashMap集合中
  2、使用定时任务对当前服务下的所有实例建立心跳检测机制
  3、基于数据一致性协议服务数据进行同步