nacos源码入门
nacos官方文档地址:nacos官方文档
Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service的首字母简称,一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。
简单来说,nacos就是一个注册中心、配置中心,这篇博客,我们主要来学习nacos作为注册中心,在业务应用启动的时候,是如何将当前业务应用的信息注册到nacos中的
注册中心源码
首先在 我们的业务应用中,在使用nacos的时候,需要引入nacos相关的jar包
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>${latest.version}</version>
</dependency>
在这个jar包中,我们看spring.factories这个文件中,自动注入的bean有哪些,主要看第一个,因为下面几个看起来都和注册中心没有关系

在这个bean中,会通过@Bean的形式,注入了三个bean,这三个bean是极其重要的(☆☆☆)这个打个星

在介绍这三个bean之前,需要先介绍一个bean
org.springframework.cloud.client.serviceregistry.AbstractAutoServiceRegistration#onApplicationEvent
AbstractAutoServiceRegistration
这个bean是监听了WebServerInitializedEvent事件,在监听到这个事件之后,会进行一些列的逻辑,我们来看下

主要关注这里的register()方法

protected void register() {this.serviceRegistry.register(getRegistration());
}
getRegistration()
可以看到,在register()方法中,只有一行代码,但是这里是核心的逻辑
我们先看getRegistration()的逻辑
com.alibaba.cloud.nacos.registry.NacosAutoServiceRegistration#getRegistration
可以看到,这里在getRegistration()注册信息的时候,实际上,是通过构造函数传进来的,这里的构造函数,可以看下前面打星的地方(☆☆☆)

this.serviceRegistry.register
在这里,我们可以看到,是根据入参的registration,从这个对象中获取到对应的instance信息,然后调用nameService的registerInstance()方法,这里的serviceRegistry的实现类是:
com.alibaba.cloud.nacos.registry.NacosServiceRegistry#register

从registration中获取到当前的ip和端口

这里我们知道最后会通过namingService进行服务注册,如果我们点进去,我们会发现,namingService实际上已经是nacos-api的类了
com.alibaba.nacos.client.naming.NacosNamingService#registerInstance(java.lang.String,
com.alibaba.nacos.api.naming.pojo.Instance)
可以看到,这里会开启一个心跳,然后继续调用serviceProxy的注册方法

注册心跳:
会发现,这里注册心跳,使用的是ScheduledExecutorService.schedule()方法,我们知道,schedule方法只会执行一次,按道理来讲,既然是心跳服务,那一定是需要定时去发送心跳的,我们接着来看下这里的task

会发现,在task方法中,执行了之后,会继续调用schedule方法,触发下次调用

在namingProxy的registerService()方法中,会构建一个http请求,去调用nacos服务端的代码,这里服务端是如何处理的,暂时先不关心,后面单独起博客去记录

回归到NacosDiscoveryAutoConfiguration
我们再把思路拉会到这个bean中,这个bean中,注入的三个bean分别是:
NacosAutoServiceRegistration(别名A类)
NacosRegistration(别名B类)
NacosServiceRegistry(别名C类)
为了便于描述这三个bean之间的关系,我们分别命名别名为A、B、C类
根据前面的代码,我们会发现,在注册的过程中,实际上就是通过这个类中注入的三个bean来完成注册的
先说结论,实际上是A类会监听WebServerInitializedEvent,在监听到这个事件之后,会通过B类获取到当前业务系统的ip和端口信息,最后去调度,通过C类的注册方法,完成服务的注册
NacosAutoServiceRegistration
会发现,这个类继承了AbstractAutoServiceRegistration,这个类的作用,可以看博客的开头

NacosRegistration
我们发现,在使用NacosRegistration.getPort()的时候,是通过nacosDiscoveryProperties对象获取的

nacosDiscoveryProperties是通过构造函数注入的,所以我们接着往上看


最终我们会发现,是通过解析配置文件中,以spring.cloud.nacos.discovery开头的配置信息

这也是nacos官网,告诉我们在配置文件中,要这样配置的原因

NacosServiceRegistry
这个类,可以看 this.serviceRegistry.register 这一小节,不再阐述
总结
对于nacos注册中心,业务应用是如何注册的,再总结下
- 在应用启动之前,我们需要引入springcloud-nacos相关的jar包
- 在jar包中,会通过springboot自动注入的功能,注入了NacosRegistration、NacosServiceRegistry、NacosAutoServiceRegistration这三个bean
- 其中NacosAutoServiceRegistration是继承了spring-cloud-common中的一个abstract类,在这个抽象类中,spring-cloud会定义好,服务注册的流程(简单来说,就是监听到WebServerInitializedEvent事件之后,会调用serviceRegistry.register()方法,方法的入参是通过registration类来获取的)
- spring-cloud-common中定义了注册的规则,至于底层的实现是nacos,还是zookeeper,还是其他注册中心,springcloud不关心,业务引入的是哪个类型的注册中心,这里就会调用对应的实现类去注册
- 所谓的注册,实际上在和nacos交互的时候,会通过http请求的方式去交互
相关文章:
nacos源码入门
nacos官方文档地址:nacos官方文档 Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service的首字母简称,一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。 简单来说,nacos就是一个注册中心、配置中心࿰…...
【记录】Samba|Windows 11的Samba连接切换用户
Samba是一个用于共享文件和打印机的网络协议,可以使不同的操作系统之间共享文件和资源变得容易。在Windows 11上,可以使用Samba来连接到网络共享。 如果您想在Windows 11上切换用户并连接到另一个Samba共享,可以按照以下步骤操作。 文章目录…...
vue hiprint vue使用hiprint打印控件VUE HiPrint HiPrint简单使用
vue hiprint vue使用hiprint打印控件VUE HiPrint HiPrint简单使用安装相关依赖安装Hi PrintJQuery引入依赖简单使用官方所有 打印示例安装相关依赖 安装Hi Print npm install vue-plugin-hiprintJQuery 因为 hi print 使用到了 JQuery 所以需要安装对应依赖 npm i jquery -…...
HBase常用Shell命令
HBase提供了一个非常方便的命令行交互工具HBase Shell。通过HBase Shell,HBase可以与MySQL命令行一样创建表、索引,也可以增加、删除和修改数据,同时集群的管理、状态查看等也可以通过HBase Shell实现。 一、数据定义语言 数据定义语言&…...
【阿里云】Apsara Clouder云计算专项技能认证-云服务器ECS入门,考试真题分享
以下是阿里云Apsara Clouder云计算专项技能认证-云服务器ECS入门真题汇总篇分享: 1.下列哪一个不是重置ECS密码的步骤? A. 查看实例详情 B.进入控制台 C.远程连接ECS D.点击控制台“概览” 2.针对云服务器ECS安全组说法正确的是 A.是一种物理防火墙 B.仅用于控制…...
怎样编写java程序
搭建好了Java开发环境之后,下面就来学习一下如何开发Java程序。为了让初学者更好地完成第一个Java程序,接下来通过几个步骤进行逐一讲解。 1.编写Java源文件 在D盘根目录下新建一个test文件夹,并在该文件夹中新建文本文档&#…...
面向对象设计模式:结构型模式之适配器模式
一、引入 Object Oriented Adapters 二、XX 模式 aka:Wrapper (包装器) 2.1 Intent 意图 Convert the interface of a class into another interface clients expect. 将一个类的接口转换成客户希望的另外一个接口. 作为两个不兼容的接口之间的桥梁 适配器模式使…...
Unity3D Shader系列之模板测试
一、 模板测试原理模板测试位于GPU渲染流水线的逐片元操作阶段,片元着色器完成之后就会进入模板测试,模板测试通过后再进入深度测试。我们的GPU中有一个模板缓冲区(Stencil Buffer)(Stencil即是模板的意思),其大小为整个屏幕大小*8位…...
机器学习中的数学——精确率与召回率
在Yolov5训练完之后会有很多图片,它们的具体含义是什么呢? 通过这篇博客,你将清晰的明白什么是精确率、召回率。这个专栏名为白话机器学习中数学学习笔记,主要是用来分享一下我在 机器学习中的学习笔记及一些感悟,也希…...
Oracle启动数据库报ORA-01102解决办法
1.机器启动之后登录服务器使用sqlplus / as sysdba 登录数据库发现数据库并没有启动之前把数据库服务添加过开机自启动 2.使用startup命令启动数据库报错了 SYSorcl>startup; ORACLE 例程已经启动。 Total System Global Area 2471931904 bytes Fixed Size 2255752 byt…...
Go 语言面向对象编程及实践
面向对象编程是计算机科学中的一种重要的编程方法,它将数据和处理它的代码组合成对象,并将这些对象组合成更大的程序。在 Go 语言中,我们同样可以使用面向对象编程的方式进行开发。本篇文章将介绍 Go 语言面向对象编程的概念、特性、使用方法以及实践技巧。 面向对象编程概…...
0102 MySQL05
1.约束 1.约束(constraint):在创建表时,可以给表中的字段加上一些约束,保证表中数据的完整性,有效性 常见的约束? 非空约束:not null 唯一性约束:unique 主键约束&am…...
[深入理解SSD系列 闪存2.1.3] 固态硬盘闪存的物理学原理_NAND Flash 的读、写、擦工作原理
2.1.3.1 Flash 的物理学原理与发明历程 经典物理学认为 物体越过势垒,有一阈值能量;粒子能量小于此能量则不能越过,大于此能 量则可以越过。例如骑自行车过小坡,先用力骑,如果坡很低,不蹬自行车也能 靠惯性过去。如果坡很高,不蹬自行车,车到一半就停住,然后退回去。 …...
洗地机哪家强?洗地机排行榜
随着清洁行业电器的开展,越来越多的新颖工具和电器开端进入消费者的生活之中。众所周知,面对美不胜收的清洁电器产品,选购也是一大头疼事,应该怎样选购洗地机等清洁电器呢,实在的用户体验和清洁效率莫过于消费者最看重…...
【Java基础 下】 029 -- 多线程
目录 一、为什么要有多线程? 1、线程与进程 2、多线程的应用场景 3、小结 二、多线程中的两个概念(并发和并行) 1、并发 2、并行 3、小结 三、多线程的三种实现方式 1、继承Thread类的方式进行实现 2、实现Runnable接口的方式进行实现 3、利用…...
R语言生物群落(生态)数据统计分析与绘图
查看原文>>>R语言生物群落(生态)数据统计分析与绘图 R 语言作的开源、自由、免费等特点使其广泛应用于生物群落数据统计分析。生物群落数据多样而复杂,涉及众多统计分析方法。本课程以生物群落数据分析中的最常用的统计方法回归和混…...
浙江首场千人大会现场爆满!实在智能九哥专题演讲:企业数字化转型,从实在RPA开始!
为帮助众多电商商家探索数字时代下新赛道、新趋势、新方向,制定有目标、有节奏的全年生意规划,“未来电商高峰论坛暨电商生态赋能大会”于3月4日在杭州正式拉开序幕。本次大会旨在向品牌电商企业主、运营操盘手分享数字电商时代的黄金趋势及运营策略&…...
Windows 上 执行docker pull命令 提示:The system cannot find the file specified.
错误提示error during connect: This error may indicate that the docker daemon is not running.: Get "http://%2F%2F.%2Fpipe%2Fdocker_engine/v1.24/version": open //./pipe/docker_engine: The system cannot find the file specified.解决办法在cmd 窗口中执…...
查看 WiFi 密码的两种方法
查看 WiFi 密码的两种方法1. 概述2. 在控制面板中查看 WiFi 密码3. 使用 CMD 查看 WiFi 密码结束语1. 概述 突然忘记 WiFi 密码怎么办? 想连上某个使用过的 WiFi,但有不知道 WiFi 密码怎么办? 使用电脑如何查询 WiFi 密码? 以下是…...
逻辑优化基础-bi-decomposition
简介 bi-decomposition是逻辑综合中用于简化布尔函数的一种技术。其思想是将函数分成两个较小的函数,每个函数仅取决于所选变量的一个值。这些较小的函数可以使用简单的逻辑门(如AND、OR和NOT门)来实现,然后组合以获得原始函数的…...
Vim 调用外部命令学习笔记
Vim 外部命令集成完全指南 文章目录 Vim 外部命令集成完全指南核心概念理解命令语法解析语法对比 常用外部命令详解文本排序与去重文本筛选与搜索高级 grep 搜索技巧文本替换与编辑字符处理高级文本处理编程语言处理其他实用命令 范围操作示例指定行范围处理复合命令示例 实用技…...
React第五十七节 Router中RouterProvider使用详解及注意事项
前言 在 React Router v6.4 中,RouterProvider 是一个核心组件,用于提供基于数据路由(data routers)的新型路由方案。 它替代了传统的 <BrowserRouter>,支持更强大的数据加载和操作功能(如 loader 和…...
Rust 异步编程
Rust 异步编程 引言 Rust 是一种系统编程语言,以其高性能、安全性以及零成本抽象而著称。在多核处理器成为主流的今天,异步编程成为了一种提高应用性能、优化资源利用的有效手段。本文将深入探讨 Rust 异步编程的核心概念、常用库以及最佳实践。 异步编程基础 什么是异步…...
【python异步多线程】异步多线程爬虫代码示例
claude生成的python多线程、异步代码示例,模拟20个网页的爬取,每个网页假设要0.5-2秒完成。 代码 Python多线程爬虫教程 核心概念 多线程:允许程序同时执行多个任务,提高IO密集型任务(如网络请求)的效率…...
微信小程序云开发平台MySQL的连接方式
注:微信小程序云开发平台指的是腾讯云开发 先给结论:微信小程序云开发平台的MySQL,无法通过获取数据库连接信息的方式进行连接,连接只能通过云开发的SDK连接,具体要参考官方文档: 为什么? 因为…...
关键领域软件测试的突围之路:如何破解安全与效率的平衡难题
在数字化浪潮席卷全球的今天,软件系统已成为国家关键领域的核心战斗力。不同于普通商业软件,这些承载着国家安全使命的软件系统面临着前所未有的质量挑战——如何在确保绝对安全的前提下,实现高效测试与快速迭代?这一命题正考验着…...
LeetCode - 199. 二叉树的右视图
题目 199. 二叉树的右视图 - 力扣(LeetCode) 思路 右视图是指从树的右侧看,对于每一层,只能看到该层最右边的节点。实现思路是: 使用深度优先搜索(DFS)按照"根-右-左"的顺序遍历树记录每个节点的深度对于…...
Python Ovito统计金刚石结构数量
大家好,我是小马老师。 本文介绍python ovito方法统计金刚石结构的方法。 Ovito Identify diamond structure命令可以识别和统计金刚石结构,但是无法直接输出结构的变化情况。 本文使用python调用ovito包的方法,可以持续统计各步的金刚石结构,具体代码如下: from ovito…...
【从零学习JVM|第三篇】类的生命周期(高频面试题)
前言: 在Java编程中,类的生命周期是指类从被加载到内存中开始,到被卸载出内存为止的整个过程。了解类的生命周期对于理解Java程序的运行机制以及性能优化非常重要。本文会深入探寻类的生命周期,让读者对此有深刻印象。 目录 …...
根目录0xa0属性对应的Ntfs!_SCB中的FileObject是什么时候被建立的----NTFS源代码分析--重要
根目录0xa0属性对应的Ntfs!_SCB中的FileObject是什么时候被建立的 第一部分: 0: kd> g Breakpoint 9 hit Ntfs!ReadIndexBuffer: f7173886 55 push ebp 0: kd> kc # 00 Ntfs!ReadIndexBuffer 01 Ntfs!FindFirstIndexEntry 02 Ntfs!NtfsUpda…...
