超硬核,Nacos实现原理详细讲解
点击关注公众号,实用技术文章及时了解
来源:blog.csdn.net/cold___play
/article/details/108032204
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:控制台
注册中心的原理
服务实例在启动时注册到服务注册表,并在关闭时注销
服务消费者查询服务注册表,获得可用实例
服务注册中心需要调用服务实例的健康检查API来验证它是否能够处理请求
SpringCloud完成注册的时机
在Spring-Cloud-Common包中有一个类org.springframework.cloud. client.serviceregistry .ServiceRegistry
,它是Spring Cloud提供的服务注册的标准。集成到Spring Cloud中实现服务注册的组件,都会实现该接口。
该接口有一个实现类是NacoServiceRegistry。
SpringCloud集成Nacos的实现过程:
在spring-clou-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服务端会根据客户端的心跳包不断更新服务的状态。另外推荐:Java进阶视频资源
注册原理:
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客户端注册服务的同时也建立了心跳机制。另外推荐:Java进阶视频资源
putService方法,它的功能是将Service保存到serviceMap中:
继续调用addInstance方法把当前注册的服务实例保存到Service中:
总结:
Nacos客户端通过Open API的形式发送服务注册请求
Nacos服务端收到请求后,做以下三件事:
构建一个Service对象保存到ConcurrentHashMap集合中
使用定时任务对当前服务下的所有实例建立心跳检测机制
基于数据一致性协议服务数据进行同步
服务提供者地址查询
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解析消息,并更新本地服务地址列表
欢迎一键三连
推荐:
主流Java进阶技术(学习资料分享)
PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧!
超硬核,Nacos实现原理详细讲解相关推荐
- 超硬核!!!一篇文章搞定TCP、UDP、Socket、HTTP(详细网络编程内容+现实解释三次握手四次挥手+代码示例)【网络编程 1】
TCP.UDP.Socket 一天面试的经验: 什么是网络编程 网络编程中两个主要的问题 网络协议是什么 为什么要对网络协议分层 计算机网络体系结构 1 TCP / UDP 1.1 什么是TCP/IP ...
- 超硬核!兔兔阿里p7学长给的面试知识库
一个阿里p7学长给的nosql面试知识库,绝对真实,学会了去面呀. 最近整理了一下超硬核系列的文章和面经系列的文章,可以持续关注下: 超硬核系列历史文章:(我保证每篇文章都有值得学习的地方,并且对小白 ...
- 超硬核!花33小时来造台3D打印机吧~
超硬核!花33小时来造台3D打印机 3D打印机在实际应用中还是有不少用武之地的,从零开始直接买材料回来自己组装可以有效地提高性价比,用最低的价钱打造一台性价比不错的机子.这里我就用大概两天的时间,成本 ...
- python爬虫原理-python爬虫原理详细讲解
原标题:python爬虫原理详细讲解 一 .爬虫是什么 1.什么是互联网? 互联网是由网络设备(网线,路由器,交换机,防火墙等等)和一台台计算机连接而成,像一张网一样. 2.互联网建立的目的?互联网的 ...
- mysql long类型_怒肝两个月MySQL源码,我总结出这篇2W字的MySQL协议详解(超硬核干货)!!...
点击上方蓝色"冰河技术",关注并选择"设为星标" 持之以恒,贵在坚持,每天进步一点点! 作者个人研发的在高并发场景下,提供的简单.稳定.可扩展的延迟消息队列框架 ...
- 超硬核之傅里叶公式推导(上)
超硬核之傅里叶公式推导 1.三角函数系与正交性 2.周期(2pi)函数的傅里叶展开(三角形式) 3.找到周期函数傅里叶展开的系数 结语 前言:再学习数学推导之前,popcorn建议读者感性的先去理解一 ...
- 十一长假我肝了这本超硬核PDF,现决定开源!!
写在前面 在 [冰河技术] 微信公众号中的[互联网工程]专题,更新了不少文章,有些读者反馈说,在公众号中刷 历史文章不太方便,有时会忘记自己看到哪一篇了,当打开一篇文章时,似乎之前已经看过了,但就是不 ...
- 【Nginx】冰河又一本超硬核Nginx PDF教程免费开源!!
写在前面 在 [冰河技术] 微信公众号中的[Nginx]专题,更新了不少文章,有些读者反馈说,在公众号中刷 历史文章不太方便,有时会忘记自己看到哪一篇了,当打开一篇文章时,似乎之前已经看过了, 但就是 ...
- 超硬核!苏州同程旅游学长给我的全面的面试知识库
超硬核!苏州同程旅游学长给我的全面的面试知识库 1.简介 新生和经验丰富的C#面试常见问题解答 2.什么是C#? 3.用示例说明C#中的注释类型 4.可以执行多个catch块吗? 5. public, ...
最新文章
- Java设计模式(十四):MVC设计模式
- layui网页html编辑器,layui使用富文本编辑器
- js图片转二进制流_V8是如何执行一段JS代码的?
- c语言dfs算法,DFS算法源程序
- Hystrix入门与分析(一):初识Hystrix
- 字节跳动单点恢复功能及 Regional CheckPoint 优化实践
- 易筋SpringBoot 2.2 | 第三十二篇:Redis Docker入门
- 《Go Web编程实战派——从入门到精通》学习笔记之第1章 Go基础入门
- SM2算法和RSA算法简介
- Linux安装dos环境,Ubuntu安装dos2unix工具
- 在家也可以免费下载知网文献,5种免费下载知网文献方法
- 模块参考资料-Cat.1模块选型手册-
- 问卷调查页面的设计与实现
- Python绘制一箭穿双心 动画代码
- 取redis中手机验证码,并验证是否正确
- docker开启远程访问后,重启失败的解决方案
- Verilog语言基础语法
- Wireshark分析实际报文理解SSL(TLS)协议
- 期末作业成品代码——绿色的餐饮美食网站(1页) HTML+CSS+JavaScript 学生DW网页设计作业成品 web课程设计网页规划与设计 计算机毕设网页设计源码
- 区块链技术+二维码,打造爱码物联产品质量溯源软件
热门文章
- #2002 无法登录 MySQL 服务器,phpMyAdmin
- 云和恩墨亮相CNCC 2020,zCloud打造国产时代数据库管理中台
- duck java_Duck类型和(java)接口概念
- 科技大佬的那些情史!
- 服务器会话视图没有显示内容,举个栗子!Tableau 技巧(77):通过服务器视图的全屏实现多媒体展示...
- 闭关修炼,看了老大的博客,才发现自己是多么的技术低,原来我就达到06年的他
- 计算机突然断电恢复供电后,电脑突然断电的坏处有哪些?
- 新员工加入企业微信的2种方法:邀请和被邀请
- 剑指offer(三)
- 音视频学习之ffmpeg时间戳相关整理(时间基tbr,tbn,tbc)