Nacos注册中心AP模式核心源码分析（单机模式）

文章目录

  • 概述
  • 一、客户端启动主线流程源码分析
    • 1.1、客户端与Spring Boot整合
    • 1.2、注册实例（服务注册）
    • 1.3、发送心跳
    • 1.4、拉取服务端实例列表（服务发现）
  • 二、服务端接收请求主线流程源码分析
    • 2.1、接收注册请求
      • 2.1.1、初始化注册表
      • 2.1.2、获取服务信息
      • 2.1.3、将实例添加到服务
    • 2.2、接收获取服务实例请求
    • 2.3、接收发送心跳请求
    • 2.4、接收删除实例请求
  • 三、服务端启动主线流程源码分析
  • 小结：单机模式下的定时任务

概述

  Nacos注册表架构：
在这里插入图片描述  Nacos中注册表是一个重要的概念，也是Nacos存储服务实例的数据结构，源码中体现在ServiceManager的serviceMap属性中。
例：

{
public = {
DEFAULT_GROUP@@stock-service = Service{
name=‘DEFAULT_GROUP@@stock-service’,
protectThreshold=0.0,
appName=‘null’,
groupName=‘DEFAULT_GROUP’,
metadata={}
}
}
}

  1. 第一层 Map：Map<String, Map<String, Service>>
    • 键（String）：public → 代表命名空间（namespaceId）。
    • 值（Map<String, Service>） → 该命名空间下的所有服务。
  2. 第二层 Map：Map<String, Service>
    • 键（String）：DEFAULT_GROUP@@stock-service
      • DEFAULT_GROUP：Nacos 中的 服务分组（Group）。
      • stock-service：具体的服务名称（Service Name）。
      • 拼接方式：groupName + “@@” + serviceName
  3. Service 对象:

Service {
name=‘DEFAULT_GROUP@@stock-service’, // 服务唯一标识
protectThreshold=0.0, // 保护阈值（避免雪崩）
appName=‘null’, // 可能未指定应用名
groupName=‘DEFAULT_GROUP’, // 该服务所属分组
metadata={} // 额外的元数据（如 tags、扩展信息）
}

  基本组件及概念（服务相关）：

名词解释
namespaceId（命名空间）用于隔离不同环境的服务，如 public、test、prod。在 serviceMap 中，namespaceId 是最外层的键。
group（服务分组）用于将服务进一步分类，例如 DEFAULT_GROUP。多个不同业务的同名服务可以通过 group 进行区分。
serviceName（服务名称）标识一个具体的服务，例如 order-service、stock-service。
service表示 Nacos 中的一个服务对象，包含 name、groupName、metadata 等信息。
instance（实例）具体提供服务的实例，通常指某个 IP + 端口（如 192.168.1.10:8080）。
weight（权重）用于负载均衡，不同实例可以有不同的权重，影响流量分配比例。
protectThreshold（保护阈值）用于设置 服务降级，防止雪崩效应，取值范围 0~1。
healthy（健康状态）表示服务实例是否健康，通常由 心跳检测 维护。

  基本组件及概念（配置管理相关）：

名词解释
DataId配置项的唯一标识，如 application-dev.yml，类似于 文件名。
Group（配置分组）配置的分组，默认是 DEFAULT_GROUP，可以用于区分不同的配置类别。
Namespace（命名空间）用于隔离不同环境（如 dev、test、prod），可作用于 配置 和 服务。
Content（配置内容）具体的配置信息，如 YAML、JSON 或 Properties 格式的内容。
Snapshot（快照）本地缓存的配置快照，在网络异常时可以使用。

一、客户端启动主线流程源码分析

1.1、客户端与Spring Boot整合

  在Spring Boot项目中，如果需要使用Nacos注册中心，需要引入：

		<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>

  引入了依赖后，Nacos将通过Spring Boot 自动装配机制，完成整合：
在这里插入图片描述  在spring.factories中，与自动装配关系最为密切的是NacosDiscoveryAutoConfiguration，其主要工作是向Spring 容器中设置了三个Bean:

  • NacosServiceRegistry（Nacos 服务注册中心实例）：创建 Nacos 服务注册中心，用于将 Spring Boot 应用注册到 Nacos。负责和 Nacos 交互，比如 注册/注销 服务。
  • NacosRegistration（Nacos 服务注册信息）：封装当前服务实例的注册信息。
  • NacosAutoServiceRegistration（Nacos 自动服务注册器）：自动注册 Spring Boot 服务到 Nacos。

在这里插入图片描述  其中NacosAutoServiceRegistration最为核心，NacosAutoServiceRegistration的继承体系结构：
在这里插入图片描述  实现了ApplicationListener接口，监听WebServerInitializedEvent类型的事件，调用onApplicationEvent方法：
在这里插入图片描述  最终调用到register方法：
在这里插入图片描述  这里的ServiceRegistry正是NacosDiscoveryAutoConfiguration中注册的NacosServiceRegistry，getRegistration获取到的是NacosRegistration。也就是调用Nacos 服务注册中心实例的register方法，去注册Nacos 服务注册信息：
在这里插入图片描述

1.2、注册实例（服务注册）

  在register方法中，首先会去通过getNacosInstanceFromRegistration方法，初始化一些实例的信息：
在这里插入图片描述  然后调用namingService的registerInstance方法进行实例注册：
在这里插入图片描述  请求路径：/nacos/v1/ns/instance，reqApI的底层，通过HttpClient发送请求：
在这里插入图片描述

1.3、发送心跳

  在调用namingService的registerInstance方法进行实例注册时，会有一个判断条件，如果实例是非永久的，就会去开启一个发送心跳的定时任务。
在这里插入图片描述  实例默认就是非永久的。
在这里插入图片描述  初始化发送心跳定时任务：在这里插入图片描述  BeatTask实现了Runnable接口，真正执行的是其中的run方法，run方法中的sendBeat，同样是去利用HttpClient去发送请求，路径是/nacos/v1/ns/instance/beat。
在这里插入图片描述  sendBeat方法会返回clientBeatInterval，也就是客户端心跳间隔的时间，并且将该时间间隔作为定时任务的延迟时间，继续递归执行该任务，持续向服务端发送心跳。
在这里插入图片描述

1.4、拉取服务端实例列表（服务发现）

  除了向服务端注册自身的信息外，客户端还有服务发现的请求NacosNamingService#getAllInstances：这里的subscribe属性默认为true，会进入hostReactor的getServiceInfo方法：
在这里插入图片描述  在getServiceInfo方法中，首先会尝试从缓存中获取值：
在这里插入图片描述在这里插入图片描述  如果获取不到，则调用updateServiceNow方法：
在这里插入图片描述  同样是通过Http请求，访问/nacos/v1/ns/instance/list，去从服务端获取所有的服务实例：
在这里插入图片描述  最后还会调用scheduleUpdateIfAbsent方法
在这里插入图片描述  去开启一个延迟的定时任务：
在这里插入图片描述  默认时延1s：
在这里插入图片描述  任务对象UpdateTask的run方法完成的逻辑：定时拉取服务端的最新数据，并且更新到本地。
在这里插入图片描述

二、服务端接收请求主线流程源码分析

  客户端无论是注册实例，发送心跳，还是从服务端拉取实例列表，实际上都是通过http请求，远程调用服务端InstanceController的接口，使用的是restFul请求风格：
在这里插入图片描述请求路径为：/v1/ns/instance

2.1、接收注册请求

  接收注册请求，调用的是register方法，在方法中，首先会生成namespaceId和serviceName以及校验serviceName的合法性，并且从请求中还原出Instance然后调用registerInstance方法进行注册：
在这里插入图片描述  在registerInstance方法中，主要完成了三件事：

  • 初始化注册表
  • 获取服务信息
  • 将实例添加到服务
    在这里插入图片描述

2.1.1、初始化注册表

  createServiceIfAbsent方法，首先会去尝试通过命名空间Id和服务名称去获取Service。如果实例类型是永久实例，那么getService这一行代码就可以获取到，反之在启动过程中获取不到，会进入if分支，去初始化Service。
在这里插入图片描述
  Service初始化完成后，执行putServiceAndInit的逻辑，在该方法中，同样做了两件事：

  • 填充注册表
  • 初始化检测心跳定时任务

在这里插入图片描述  putService是填充注册表的方法，首先通过双检锁模式，对注册表进行初始化，这里初始化的是外层的map，key就是当前的命名空间。如dev，check，prod等。（外层map的value为何是跳表的结构？）。然后会去初始化内层的map，key是同一类型微服务的分组
在这里插入图片描述

  init方法中，会初始化两个定时任务。

  • clientBeatCheckTask：服务端监听心跳定时任务，在客户端的启动过程中，会去向服务端通过延迟定时任务的方式发送自身的心跳。
  • HealthCheckTask：在entry.getValue().init();中被初始化，是定期主动健康检查定时任务。
    在这里插入图片描述
      其中服务端监听心跳定时任务，超过15s没有检测到心跳，就会标记该实例的状态为非健康状态
    在这里插入图片描述  超过30s没有检测到心跳，就会去删除该实例：
    在这里插入图片描述在这里插入图片描述在这里插入图片描述

2.1.2、获取服务信息

  在getService方法中，首先会通过命名空间ID，获取注册表外层map的value。然后根据服务名称，获取具体的实例。
在这里插入图片描述

2.1.3、将实例添加到服务

  在addInstance方法中，主要也完成了三件事：

  • 根据传入的ephemeral属性，生成一个全局唯一的key。
  • 将传入的 Instance 添加到 service 的实例列表中。
  • 将实例信息写入服务端内存中。

在这里插入图片描述

  consistencyService.put(key, instances);实际执行的是DelegateConsistencyServiceImpl的put方法：
在这里插入图片描述  在put方法中，首先会解析之前生成的key，获取对应的实例，然后调用其put方法：
在这里插入图片描述  在这里获取到的是ephemeralConsistencyService非永久。
在这里插入图片描述
  调用的实际是ephemeralConsistencyService子类DistroConsistencyServiceImpl的put方法：
在这里插入图片描述  单机模式下重点关注onPut方法，是将key和instance实例放入一个阻塞队列中：
在这里插入图片描述在这里插入图片描述  上述所有的操作，都是服务端启动完成后，接收到客户端启动时发送的注册请求从而执行的全部流程。 所以为什么每次都是先要启动服务端再启动客户端的原因？

2.2、接收获取服务实例请求

  客户端在发起获取所有服务实例的请求后，实际调用的是服务端的：
在这里插入图片描述  在doSrvIpxt方法中，首先会去调用getService方法，获取当前命名空间下的所有实例，然后调用service的srvIPs方法：
在这里插入图片描述

2.3、接收发送心跳请求

  客户端在发起上报心跳的请求后，实际调用的是服务端的：
在这里插入图片描述  如果服务端发现实例不存在，则会走注册的逻辑：
在这里插入图片描述  否则开启一个定时任务对客户端发送的心跳信息进行处理：
在这里插入图片描述  在ClientBeatProcessor的run方法中，循环所有的实例，并且更新心跳时间
在这里插入图片描述

2.4、接收删除实例请求

  当某个实例30s没有向服务端发送心跳时，客户端就会发送删除实例请求：
在这里插入图片描述  最终实际调用的是ServiceManager#updateIpAddresses的instanceMap.remove(instance.getDatumKey());方法。

三、服务端启动主线流程源码分析

  在2.1、接收注册请求的最后，服务端会将实例的信息存入一个阻塞队列，而Notifier实现了Runnable，必然有一个run方法需要执行，run方法的主要作用是消费阻塞队列的数据，然后真正地去执行将客户端的注册信息存入服务端内存的操作。，那么run方法是何时被执行的呢？
在这里插入图片描述  Notifier是DistroConsistencyServiceImpl的一个属性，随着DistroConsistencyServiceImpl的实例化而被实例化，真正将其通过线程池运行的在于DistroConsistencyServiceImpl的init方法。该方法上加入了@PostConstruct注解，是在spring启动的流程中执行的。
在这里插入图片描述  Nacos的服务端实际上也是一个Spring Boot项目，在启动的过程中，会去向线程池submit一个Notifier任务，从而执行其中的run方法的逻辑。再去仔细观察一下run方法，被设置成了死循环，那么**这样是否会造成cpu资源的浪费？可能很多人会想，如果我只启动了服务端，而一直没有启动客户端，那么代码会在for循环中无限空转。实际这种情况是不会发生的，因为tasks属性的数据结构是阻塞队列。**当队列为空时，则会陷入阻塞，不会一直循环。
  这里的handle方法，会进入if (action == DataOperation.CHANGE)的分支。
在这里插入图片描述  最终调用的是Service的onChange方法，然后调用updateIPs:
在这里插入图片描述  在updateIPs中有两个关键的逻辑：

  • 将临时实例写入内存
  • 主动向客户端推送发布事件

在这里插入图片描述

  将临时实例写入内存，应用了写时复制的思想。具体是将原有的内存结构复制一份，待操作完成后，再写回注册表的属性中。
在这里插入图片描述  虽然牺牲了一定的实时性（其他线程读取到的是旧的数据），但是降低了锁的粒度，提高了并发。
在这里插入图片描述

  在将临时实例写入内存后，还会主动发布事件，告知客户端服务端最新的注册表内容，实际调用的是PushService的方法：
在这里插入图片描述  而PushService又实现了ApplicationListener<ServiceChangeEvent>，所以最终由该类的onApplicationEvent方法执行逻辑：给服务端发送udp请求，将服务变更发送给订阅的客户端。
在这里插入图片描述

小结：单机模式下的定时任务

组件任务名称触发频率作用
客户端（SDK）发送心跳（BeatReactor）默认 5 秒客户端定期向 Nacos 发送 心跳，保持实例存活状态
客户端（SDK）服务列表拉取（HostReactor）默认 10 秒客户端定期拉取注册中心中的 服务列表，用于本地缓存
客户端（SDK）配置监听（ClientWorker）10 秒（长轮询）监听 配置变更，若有变化，则更新本地缓存
客户端（SDK）负载均衡（LoadBalancer）10 秒轮询 可用实例，选择最优的实例进行调用
服务端（Nacos Server）处理客户端心跳（ClientBeatCheckTask）5 秒检查服务实例是否仍然存活，如果未收到心跳，则标记为 不健康 或移除
服务端（Nacos Server）临时实例清理（ExpireInstanceTask）定期执行清除失效的 临时实例（即 ephemeral=true）
服务端（Nacos Server）持久化实例同步（PersistentServiceTask）30 秒将持久化实例（ephemeral=false）的状态写入数据库
服务端（Nacos Server）配置变更通知（ConfigChangeNotifier）实时触发监听 配置变更，并通知所有监听的客户端
服务端（Nacos Server）配置清理（ConfigCleanupTask）10 分钟清理过期或无用的 历史配置
服务端（Nacos Server）权限数据同步（AuthRefreshTask）5 分钟刷新权限信息，确保权限策略有效
服务端（Nacos Server）Raft 协议日志清理（RaftLogCleanupTask）10 分钟清理过期的 Raft 日志，保持数据一致性

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/900125.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

prism WPF 模块

prism WPF 模块

模块 DLL ModuleA 和 ModuleB 都要安装 Prism.Unity 引用方式1 项目引用 直接 在引用中添加项目引用 App.xaml.cs 添加模块 ConfigureModuleCatalog using ModuleA; using ModuleB; using Prism.Ioc; using Prism.Modularity; using Prism.Unity; using PrismWpfApp.ViewMo…
阅读更多...
CSS：换行与不换行

CSS：换行与不换行

一、CSS 不允许换行 在 CSS 中&#xff0c;有几种方法可以控制文本不换行&#xff1a; 1. 使用 white-space 属性 .no-wrap {white-space: nowrap; } white-space: nowrap; 会强制文本在一行显示&#xff0c;不换行。 2. 使用 overflow 和 text-overflow 通常与 white-sp…
阅读更多...
JavaScript BOM、事件循环

JavaScript BOM、事件循环

目录 BOM&#xff08;浏览器对象模型&#xff09; 一、window 对象 1. 窗口控制 2. 定时器 二、location 对象 三、navigator 对象 四、history 对象 五、screen 对象 六、本地存储 1. localStorage 2. sessionStorage 七、BOM 应用场景 八、总结 JavaScript 执行…
阅读更多...
k8s运维面试总结(持续更新)

k8s运维面试总结(持续更新)

一、你使用的promethues监控pod的哪些指标&#xff1f; CPU使用率 内存使用率 网络吞吐量 磁盘I/O 资源限制和配额&#xff1a;Prometheus可以监控Pod的资源请求和限制&#xff0c;确保它们符合预设的配额&#xff0c;防止资源过度使用。具体指标如container_spec_cpu_quota用于…
阅读更多...
ubuntu20.04升级成ubuntu22.04

ubuntu20.04升级成ubuntu22.04

命令行 sudo do-release-upgrade 我是按提示输入y确认操作&#xff0c;也可以遇到配置文件冲突时建议选择N保留当前配置
阅读更多...
Cortex-M​ 函数调用的入栈与出栈操作

Cortex-M​ 函数调用的入栈与出栈操作

在 ARM Cortex-M 系列单片机中，普通C函数调用的入栈（压栈）和出栈操作通常由编译器编译后生成的代码管理，而硬件仅负责部分关键操作。以下是详细分析： 1. 函数调用与返回的核心机制 (1) 硬件自动完成的部分 返回地址的保存： 当通过 BL（Branch with Link）或 BLX 指令调用…
阅读更多...
DeepSeek能否用于对话系统（Chatbot）？技术解析与应用实例！

DeepSeek能否用于对话系统（Chatbot）？技术解析与应用实例！

引言&#xff1a;Chatbot 的进化与挑战 你有没有发现&#xff0c;现在的AI聊天机器人越来越聪明了&#xff1f;无论是客服助手、智能语音设备&#xff0c;还是社交媒体上的自动回复&#xff0c;Chatbot&#xff08;对话系统&#xff09;已经渗透到我们生活的方方面面。但问题是…
阅读更多...
多表查询的多与一

多表查询的多与一

1.查寻表需要的条件 1.1.首先我们要了解查询表有哪些 1.1.1.多对一 多对一就是一个年表拥有例外一个表的多条数据 一个表对应立一个表的多条数据&#xff0c;另一个表对应这个表的多条数据 这个点被称为多对一 1.1.2.多对多 多对多简单来说就是需要一个中间商 中间商就…
阅读更多...
配置文件、Spring日志

配置文件、Spring日志

SpringBoot配置⽂件 SpringBoot⽀持并定义了配置⽂件的格式, 也在另⼀个层⾯达到了规范其他框架集成到SpringBoot的 ⽬的. 很多项⽬或者框架的配置信息也放在配置⽂件 中, ⽐如: 项⽬的启动端⼝ 数据库的连接信息(包含⽤⼾名和密码的设置) 第三⽅系统的调⽤密钥等信息 ⽤…
阅读更多...
嵌入式——Linux系统的使用以及编程练习

嵌入式——Linux系统的使用以及编程练习

目录 一、Linux的进程、线程概念 &#xff08;一&#xff09;命令控制进程 1、命令查看各进程的编号pid 2、命令终止一个进程pid 二、初识Linux系统的虚拟机内存管理 &#xff08;一&#xff09;虚拟机内存管理 &#xff08;二&#xff09;与STM32内存管理对比 三、Lin…
阅读更多...
Springcache+xxljob实现定时刷新缓存

Springcache+xxljob实现定时刷新缓存

目录 SpringCache详解 SpringCache概述 核心原理 接口抽象与多态 AOP动态代理 核心注解以及使用 公共属性 cacheNames KeyGenerator&#xff1a;key生成器 key condition&#xff1a;缓存的条件&#xff0c;对入参进行判断 注解 xxl-job详解 SpringcacheRedis实现…
阅读更多...
前端Uniapp接入UviewPlus详细教程！！！

前端Uniapp接入UviewPlus详细教程！！！

相信大家在引入UviewPlusUI时遇到很头疼的问题&#xff0c;那就是明明自己是按照官网教程一步一步的走&#xff0c;为什么到处都是bug呢&#xff1f;今天我一定要把这个让人头疼的问题解决了&#xff01; 1.查看插件市场 重点&#xff1a; 我们打开Dcloud插件市场搜素uviewPl…
阅读更多...
vector的介绍与代码演示

vector的介绍与代码演示

由于以后我们写OJ题时会经常使用到vector&#xff0c;所以我们必不可缺的是熟悉它的各个接口。来为我们未来作铺垫。 首先&#xff0c;我们了解一下&#xff1a; https://cplusplus.com/reference/vector/ vector的概念&#xff1a; 1. vector是表示可变大小数组的序列容器…
阅读更多...
ZLMediaKit 源码分析——[5] ZLToolKit 中EventPoller之延时任务处理

ZLMediaKit 源码分析——[5] ZLToolKit 中EventPoller之延时任务处理

系列文章目录 第一篇 基于SRS 的 WebRTC 环境搭建 第二篇 基于SRS 实现RTSP接入与WebRTC播放 第三篇 centos下基于ZLMediaKit 的WebRTC 环境搭建 第四篇 WebRTC学习一&#xff1a;获取音频和视频设备 第五篇 WebRTC学习二&#xff1a;WebRTC音视频数据采集 第六篇 WebRTC学习三…
阅读更多...
【零基础入门unity游戏开发——2D篇】SortingGroup（排序分组）组件

【零基础入门unity游戏开发——2D篇】SortingGroup（排序分组）组件

考虑到每个人基础可能不一样&#xff0c;且并不是所有人都有同时做2D、3D开发的需求&#xff0c;所以我把 【零基础入门unity游戏开发】 分为成了C#篇、unity通用篇、unity3D篇、unity2D篇。 【C#篇】&#xff1a;主要讲解C#的基础语法&#xff0c;包括变量、数据类型、运算符、…
阅读更多...
26信号和槽_自定义信号(1)

26信号和槽_自定义信号(1)

Qt 中也允许自定义信号 ①自定义槽函数,非常关键.开发中大部分情况都是需要自定义槽函数的. 槽函数&#xff0c;就是用户触发某个操作之后,要进行的业务逻辑. ②自定义信号,比较少见.实际开发中很少会需要自定义信号. 信号就对应到用户的某个操作~ 在 GUI,用户能够进行哪些操作…
阅读更多...
今天来介绍一下一个简单,灵活的JavaScrip图标工具Chart.js

今天来介绍一下一个简单,灵活的JavaScrip图标工具Chart.js

Chart.js 柱形图 先看效果&#xff1a; 代码部分&#xff1a; <!DOCTYPE html> <html> <head> <meta charset"utf-8"> <title></title> <script src"https://lf26-cdn-tos.bytecdntp.com/cdn/expire-1-M/Chart.js/3.7…
阅读更多...
Mysql 中的 binlog、redolog、undolog

Mysql 中的 binlog、redolog、undolog

Binlog MySQL中的Binlog&#xff08;Binary Log&#xff09; 是 MySQL 用来记录数据库所有数据更改操作的日志文件。它是 MySQL 数据库的核心组件之一&#xff0c;广泛应用于 数据复制、数据恢复 和 故障恢复 等操作中。 Binlog的主要作用&#xff1a; 数据复制&#xff08;…
阅读更多...
object中的方法，和String类常用api

object中的方法，和String类常用api

Java Object 类和 String 类常用 API 一、Object 类核心方法 Object 类是 Java 中所有类的超类&#xff0c;提供了以下重要方法&#xff1a; 1. 基本方法 方法描述重写建议public boolean equals(Object obj)对象相等性比较必须重写&#xff08;同时重写hashCode&#xff0…
阅读更多...
Haskell语言的云安全

Haskell语言的云安全

Haskell语言的云安全探索 引言 在信息技术迅猛发展的今天&#xff0c;云计算已经成为了企业和个人用户不可或缺的重要组成部分。然而&#xff0c;随着云计算的普及&#xff0c;相关的安全问题也日益突显。云安全不仅涉及数据的安全性、隐私保护&#xff0c;更涵盖了访问控制、…
阅读更多...
最新文章

Copyright @ 2022~2023