皮皮网

1.Nacos 服务注册源码分析
2.Nacos服务端源码分析(四): 拉取服务信息
3.Nacos 注册服务源码分析
4.Nacos 配置中心源码 | 京东物流技术团队
5.nacos原理
6.Nacos源码分析-集群间临时实例数据的码阅一致性同步

Nacos 服务注册源码分析

       文章标题：Nacos 服务注册源码深度剖析

       作者郑哥在微信公众号运维开发故事中，详细解析了Nacos服务注册过程中服务端和客户端的码阅运作机制。以Spring-Boot为基础，码阅Nacos在服务架构中扮演着中心角色，码阅与Eureka、码阅Zookeeper等其他中间件相区分，码阅嗨皮源码app其特点是码阅支持AP和CP模式，并采用Raft协议保证分区一致性。码阅

       客户端注册服务是码阅主动的，通过Spring-Cloud Alibaba组件集成。码阅关键配置类NacosServiceRegistryAutoConfiguration定义了核心Bean，码阅如NacosAutoServiceRegistration，码阅它负责将服务实例注册到Nacos。码阅NacosServiceRegistry则负责实际的码阅注册操作，通过心跳机制保持与服务端的码阅连接。

       服务端，Nacos根据客户端注册时的ephemeral属性决定使用Distro（AP）或Raft（CP）协议。AP模式下，Nacos通过udp更新服务实例信息，而CP模式下，会触发raftCore.signalPublish进行数据同步和通知。

       对于源码调试，郑哥分享了如何定位启动类com.alibaba.nacos.Nacos，以及如何通过IDEA进行启动和调试。要深入了解Nacos的源码，可以参考nacos.io和github.com/alibaba/nacos...的文档。

Nacos服务端源码分析(四): 拉取服务信息

       本文深入解析Nacos服务端源码，特别关注服务信息的主动拉取机制。主动拉取服务信息的python源码运用URL为：https://localhost:/nacos/v1/ns/instance/list。依据此URL，Nacos服务端会处理请求，具体操作如下：

       首先，获取并校验参数，随后调用`getInstanceOperator().listInstance()`函数。

       `getInstanceOperator().listInstance()`执行流程如下：

       通过`createIpPortClientIfAbsent()`确保client管理正常，若未存在则加入`clients`。

       调用`clientOperationService.subscribeService()`发布事件`ClientOperationEvent.ClientSubscribeServiceEvent`，进行服务订阅。

       调用`ServiceUtil.selectInstancesWithHealthyProtection()`获取serviceInfo，包括实例列表。

       分析各个方法的内部逻辑：

       `createIpPortClientIfAbsent()`：若`clientManager`中不存在指定`clientId`，则加入`clients`。

       `clientOperationService.subscribeService()`：发布事件`ClientOperationEvent.ClientSubscribeServiceEvent`，涉及订阅操作，将服务作为key，保存在`subscriberIndexes`中。首次添加时，会触发事件`ServiceEvent.ServiceSubscribedEvent`，将服务信息推送至订阅客户端。

       `ServiceUtil.selectInstancesWithHealthyProtection()`：整合相关信息，筛选健康的服务实例，最终返回。

       总结以上分析，Nacos服务端主动拉取服务信息的过程涉及参数验证、事件发布、实例筛选等关键步骤。这一机制确保了服务信息的溯源码圆角及时更新与准确传递。

       下篇文章预告：探讨Nacos之Distro协议的理论基础。

Nacos 注册服务源码分析

       Nacos 注册服务源码分析

       首先，从nacos-example样例工程入手，寻找注册服务的关键入口。在NamingExample的main方法中，我们关注的两行代码揭示了整个过程的起点。

       从NamingFactory#createNamingService开始，这个方法通过构造函数创建了一个NacosNamingService。值得注意的是，虽然创建过程看似简单，但构造方法中包含了属性的初始化和处理，这在非Spring项目中尤为重要，通常通过静态代码块或构造方法自行完成。

       真正注册服务的核心在于registerInstance方法。这个方法内部调用了clientProxy.registerService，跟踪这个过程是理解Nacos注册服务的关键。

       进一步追踪NamingService的构造方法，可以看到它内部创建了NamingClientProxyDelegate代理类。这个代理类实际上是设计模式中的代理模式，用于将请求委托给grpcClientProxy或httpClientProxy进行远程调用。

       深入理解后，我们发现grpcClientProxy#registerService是实际执行注册操作的地方。它通过gRpc技术，将客户端的请求发送到服务端，注册成功后，整个注册过程完成。

       接下来，我们关注的更多源码获取是rpcClient#request方法，这里涉及currentConnection的创建和请求过程。currentConnection在RpcClient的start方法中初始化，然后在connectToServer方法中建立连接。

       至于rpc的请求，就是简单地利用已建立的连接和请求Stub发送请求。

       总结来说，Nacos客户端通过NacosNamingService调用代理类，最终通过gRpc技术与服务端进行交互。虽然本文仅阐述了客户端的请求过程，但服务端如何处理这些请求才是Nacos的核心功能。

Nacos 配置中心源码 | 京东物流技术团队

       Nacos配置中心的源码解析

       Nacos配置中心的入口位于spring-cloud-starter-alibaba-nacos-config-2.2.5.RELEASE.jar中的spring.factories文件，其中包含NacosConfigBootstrapConfiguration类，作为配置中心的核心入口，它管理了三个关键组件：NacosConfigProperties、NacosConfigManager和NacosPropertySourceLocator。

       NacosConfigManager主要负责管理NacosConfigProperties和ConfigService，构造时会创建ConfigService实例，该实例中包含MetricsHttpAgent和ServerHttpAgent，前者负责与Nacos服务器的通信，后者通过NacosRestTemplate发送GET请求获取配置信息。

       客户端工作主要由NacosConfigService负责，它初始化一个ClientWorker，包含一个定时任务线程池用于每隔毫秒轮询配置，以及一个线程池处理来自Nacos的配置更新。这些线程池执行checkConfigInfo、checkLocalConfig、checkUpdateDataIds、getServerConfig和checkListenerMd5等方法，spring企业源码确保配置的实时更新和缓存管理。

       当配置更新时，Nacos会发布RefreshEvent，由Spring Cloud的RefreshEventListener监听。该监听器会根据@RefreshScope注解刷新相关bean，涉及的刷新操作包括提取环境变量，更新配置文件，触发环境变更事件，并重新加载配置。

       在服务端，DumpService类负责将配置数据保存到磁盘，包括全量或增量更新。ExternalDumpService在初始化时执行dumpConfigInfo方法，根据条件决定是否全量更新。ConfigCacheService则负责将配置写入磁盘并更新MD5缓存，同步到客户端。

       客户端获取配置通过HTTP GET请求，监听配置则是通过POST请求的长连接轮询。Nacos管理端变更配置通过POST请求，修改后会触发ConfigDataChangeEvent，用于同步到其他节点。

       总的来说，Nacos配置中心通过精细的架构设计，实现了配置的高效获取、更新和同步，确保了应用环境的动态刷新。

nacos原理

       nacos目前是集成到spring cloud alibaba里去的，也就是在spring cloud的标准之下实现了一些东西，spring cloud自己是有一个接口，叫做ServiceRegistry，也就是服务注册中心的概念，nacos中有一个它的实现类NacosServiceRegistry，实现了register、deregister、close、setStatus、getStatus之类的方法。

        自动装配是一个spring boot的一个概念，自动装配的意思，其实就是说系统启动的时候，自动装配机制会运行，实现一些系统的初始化，自动运行，也就是系统启动时自动去调用NacosServiceRegistry的register方法去进行服务注册。而且除了注册之外，还会通过schedule线程池去提交一个定时调度任务，源码如下：

        this.exeutorService.schedule(new BeatReactor.BeatTask(beatInfo), beatInfo.getPeriod(), TimeUnit.MILLISECONDS)，这就是一个心跳机制，定时发送心跳给nacos server。

        然后会访问nacos server的open api，其实就是http接口，他有一个接口：http://...:/nacos/v1/ns/instance?serviceName=xx&ip=xx&port=xx，这么一个东西，也没什么特别的，这里就是访问注册接口罢了

        nacos server那里是基于一个ConcurrentHashMap作为注册表来放服务信息的，直接会构造一个Service放到map里，然后对Service去addInstance添加一个实例，本质里面就是在维护信息，同时还会建立定时检查实例心跳的机制。最后还会基于一致性协议，比如说raft协议，去把注册同步给其他节点。

        服务发现的本质其实也是nacos server上的一个http接口，就是：http://...:/nacos/v1/ns/instance/list?serviceName=xx，就这么一个接口，然后就会启动定时任务，每隔s拉取一次最新的实例列表，然后服务端还会监听他服务的状态，有异常就会基于UDP协议反向通知客户端这次服务异常变动。

Nacos源码分析-集群间临时实例数据的一致性同步

       Nacos集群在部署时，如何实现临时实例数据在集群间的同步？答案在于Distro一致性协议。Distro协议确保了Nacos注册中心的可用性，当临时实例注册到Nacos注册中心时，集群中的实例数据并不一致，通过Distro协议同步后才达到最终一致性状态。

       Distro协议将数据分为多个blocks，每个Nacos集群节点负责一个block的数据处理，确保每个节点仅处理实例数据的一部分。同时，所有节点都会将数据同步到集群内其他节点。Distro协议的实现主要通过DistroProtocol类，包含sync方法，遍历除自身外的所有集群节点，封装Distro延迟任务DistroDelayTask，并通过任务引擎DistroTaskEngine进行执行。任务引擎的实现较为复杂，包括延迟任务处理器DistroDelayTaskProcessor，负责处理延迟任务。当将延迟任务添加到任务引擎中，DistroDelayTaskProcessor将根据任务类型执行相应的处理逻辑，如数据改变同步任务DistroSyncChangeTask。

       DistroSyncChangeTask的run方法负责获取需要同步的数据，设置同步数据的类型，并进行临时实例数据的同步。如果同步失败或过程中发生异常，则进行重试处理，即将任务重新添加到任务执行引擎中。同步临时实例数据主要由DistroHttpAgent类的syncData方法负责，该方法通过HTTP请求将数据同步到其他节点。当其他节点接收到同步请求时，DistroController类的onSyncDatum方法处理同步过来的数据，首先验证数据是否为空，然后判断是否为临时实例数据，根据情况创建或更新服务实例，并将数据传递给distroProtocol的onReceive方法处理。

       在DistroProtocol的onReceive方法中，首先根据资源类型找到处理实例数据的处理器，然后调用DistroConsistencyServiceImpl处理器的processData方法处理数据，该方法负责反序列化数据，并调用onPut方法进行临时数据缓存并通知变更。

       当Nacos集群中有新节点加入时，新节点需要从其他节点拉取全量数据。DistroProtocol初始化时，调用startDistroTask方法启动全量拉取数据任务。DistroLoadDataTask负责加载全量数据，通过load方法从远程加载数据，并在检测到加载完成或异常时进行相应的回调。服务启动时，新节点会等待服务地址和数据存储类型不为空，之后遍历数据存储类型，加载未完成的数据，处理全量数据。

       综上所述，Nacos通过Distro一致性协议实现了集群间临时实例数据的同步，确保了注册中心的可用性和一致性。新节点加入时，通过全量拉取数据来更新集群状态，实现数据的一致性。

手撕Nacos源码剖析，建议收藏

       Nacos源码剖析

       深入学习Nacos，解析源码，重点关注以下两点：

       源码环境搭建

       从官方项目克隆Nacos源码，检出1.4.1版本，导入IDEA。

       在本地MySQL中创建nacos-config数据库，执行resources/META-INF/nacos-db.sql脚本创建表。

       修改console模块下的application.properties文件，配置相关参数。

       启动console模块的启动类，非集群模式启动Nacos服务端。

       访问本地Nacos服务：http://localhost:/nacos。

       Nacos客户端功能

       Nacos客户端集成在应用服务内，通过依赖引入实现服务注册、发现、下线及订阅功能。

       客户端核心功能包括服务注册、服务发现、服务下线与服务订阅。

       客户端与服务端交互，主要聚焦服务注册、服务下线、服务发现与服务订阅。

       服务注册

       注册服务时，客户端执行定时任务设置心跳监测，同时向服务端注册服务。

       服务注册中，远程请求通过NacosRestTemplate封装，调用callServer()执行。

       服务发现

       通过NamingService.getAllInstances()方法实现服务发现。

       获取服务信息首先从缓存查找，若无数据，则向Nacos服务端请求更新。

       服务下线

       服务下线操作简化，主要取消心跳检测与服务下线接口请求。

       服务订阅

       客户端创建线程池，封装监听器，监听指定服务实例信息变化。

       通过NamingService.subscribe()方法实现服务订阅，注册监听器，接收实例信息更新。

Nacos系列创建ConfigService实例源码分析

       在学习Nacos的过程中，我们关注的重点是创建ConfigService实例的实现。Nacos通过NacosFactory的createConfigService方法创建ConfigService实例，这个工厂类是获取各种服务对象的统一入口。

       ConfigService是配置服务接口，负责配置的获取、发布、管理等操作，其核心实现类NacosConfigService。同样，Nacos的命名服务和维护服务也是通过NacosFactory创建实例的，如NamingService用于服务实例的注册与管理，NamingMaintainService则直接与Nacos服务器交互。

       创建ConfigService的具体流程中，首先通过ConfigFactory的createConfigService方法，构造器会进行一些参数校验，并初始化命名空间。例如，校验contextPath属性的合法性，确保其不包含连续的/。然后，会根据用户租户信息、环境变量或配置属性获取namespace值。

       ConfigFilterChainManager和ServerListManager的构造也非常重要，前者管理配置过滤器，后者负责维护服务器列表，能够通过配置属性或动态请求获取最新的服务器信息。当创建ConfigService实例时，还会启动长轮询定时任务，如ClientWorker的executeConfigListen方法，通过ServerHttpAgent进行HTTP请求以获取和管理配置数据。

       总结来说，创建ConfigService实例涉及工厂方法的调用、参数处理、服务实例初始化以及与Nacos服务器的交互。通过本文的深入分析，你将更好地理解Nacos配置服务的初始化过程。