从实现原理来讲,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服务端会根据客户端的心跳包不断更新服务的状态。
注册原理:
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中:
总结:
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进阶技术(学习资料分享)
Java面试题宝典
加入Spring技术开发社区
PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧!
从实现原理来讲,Nacos 为什么这么强相关推荐
- 微型计算机的逻辑元素,微机原理及应用 宋廷强 微型计算机原理及应用.ppt
您所在位置:网站首页 > 海量文档  > 计算机 > 计算机原理 微机原理及应用 宋廷强 微型计算机原理及应用.ppt ...
- Zookeeper原理及实战开发-余强-专题视频课程
Zookeeper原理及实战开发-77788人已学习 课程介绍 hadoop大数据 zookeeper原理及实战开发的一个课程内容. 学习此课程 开发理解任何分布式应用程序的话应该都是 ...
- SpringCloudAlibaba:Nacos实现原理详解
欢迎关注方志朋的博客,回复"666"获面试宝典 Nacos 架构 Provider APP:服务提供者 Consumer APP:服务消费者 Name Server:通过VIP(V ...
- Nacos实现原理详解
欢迎关注方志朋的博客,回复"666"获面试宝典 来源:https://blog.csdn.net/cold___play/article/details/108032204 Nac ...
- adaboost训练 之 强分类器训练原理
最近看opencv中adaboost训练强分类器源码,记录下自己对adaboost训练强分类器的原理理解. adaboost训练强分类器的基本流程: 1.初始化训练样本的类别与权重分布. 2.迭代循环 ...
- 超硬核,Nacos实现原理详细讲解
点击关注公众号,实用技术文章及时了解 来源:blog.csdn.net/cold___play /article/details/108032204 Nacos架构 Provider APP:服务提供 ...
- 面试官:你能说说 Nacos 的实现原理吗?
点击上方"Java基基",选择"设为星标" 做积极的人,而不是积极废人! 每天 14:00 更新文章,每天掉亿点点头发... 源码精品专栏 原创 | Java ...
- 微服务注册中心 Nacos 实现原理详解!
Nacos 架构 Provider APP:服务提供者 Consumer APP:服务消费者 Name Server:通过VIP(Virtual IP)或DNS的方式实现Nacos高可用集群的服务路由 ...
- SpringCloudAlibaba注册中心与配置中心之利器Nacos实战与源码分析(下)
源码资料 文档资料 <<Nacos架构与原理>>书籍于2021.12.21发布,并在Nacos官方网站非常Nice的提供其电子书的下载.我们学习Nacos源码更多是要吸取其优秀 ...
最新文章
- Kendo Web UI Grid里时间格式转换
- Leetcode每日一题:面试题 08.02. 迷路的机器人
- 手把手教你最好用的数据分析方法,会用的没几个
- Autolayout的简单介绍和示例代码
- JAVA – 虚函数、抽象函数、抽象类、接口_对比C++
- angularjs1-2,作用域、代码压缩
- 又一款程序员摸鱼神器来了?上班也可以在VSCode看股票 基金实时数据
- iOS关于上传iTunes store一直卡住终极解决方案
- 动漫头像1000张萌妹子图片,可以做高清头像壁纸
- Android Intent FLAG标识
- 苹果MFI认证步骤汇总
- [HNOI2004]宠物收养所(简单理解,用set写的)
- OpenGL VBO, PBO与FBO
- turtle-绘制简易瞄准镜
- 利用AlphaFold进行蛋白质结构预测
- 阿里云视频点播Demo
- 如何在web项目中访问HTML页面
- OKRs,自由之风劲吹,发挥无限创造力 | Chatopera
- 泰坦尼克号数据挖掘项目实战——Task7 模型融合
- BCI Competition 2008 – Graz dataset A个人翻译(附MATLAB安装BioSig)
热门文章
- 新一批国产游戏版号下发:共53款 腾讯、网易在列
- 马云:青山不改绿水长流,后会有期
- 微信或正测试“发送语音过程”转文字功能 部分安卓用户可用
- 再见!“一代神机”iPhone 6或将于今年5月停产 iPhone 7/8降至3500档
- 2019年第一批重点作品版权保护预警名单公布 都是贺岁档
- 「软件测试」刚从腾讯面试出来,留下了这些面试笔记
- 到底该不该跳槽?告诉你三条底层逻辑
- 还不会使用linux?快来通过VMware安装centos系统吧~
- Android Studio 无法浏览插件市场
- php的limit分页,用php数组的array_slice分页和用limit查询分页哪个效率更高?