Nacos实现原理详解

沙海 2021年8月26日05:02:14Java评论44字数 3597阅读11分59秒阅读模式
摘要

智能摘要

智能摘要文章源自JAVA秀-https://www.javaxiu.com/42474.html

在AutoServiceRegistrationAutoConfiguration配置类中,可以看到注入了一个AutoServiceRegistration实例,该类的关系图如下所示。Server必须要确保注册的服务实例是健康的,而心跳检测就是服务健康检测的手段。方法的如下图所示,它主要通过定时任务不断检测当前服务下所有实例最后发送心跳包的时间。在这里请大家思考一一个问题,服务实例的最后心跳包更新时间是谁来触发的?文章源自JAVA秀-https://www.javaxiu.com/42474.html

原文约 2021 | 图片 34 | 建议阅读 5 分钟 | 评价反馈文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解

小哈学Java 文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

来源:https://blog.csdn.net/cold___play/article/details/108032204文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos架构

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • Provider APP:服务提供者文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • Consumer APP:服务消费者文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • Name Server:通过VIP(Virtual IP)或DNS的方式实现Nacos高可用集群的服务路由文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • Nacos Server:Nacos服务提供者,里面包含的Open API是功能访问入口,Conig Service、Naming Service 是Nacos提供的配置服务、命名服务模块。Consitency Protocol是一致性协议,用来实现Nacos集群节点的数据同步,这里使用的是Raft算法(Etcd、Redis哨兵选举)文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • Nacos Console:控制台文章源自JAVA秀-https://www.javaxiu.com/42474.html

注册中心的原理

  • 服务实例在启动时注册到服务注册表,并在关闭时注销文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 服务消费者查询服务注册表,获得可用实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 服务注册中心需要调用服务实例的健康检查API来验证它是否能够处理请求文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

SpringCloud完成注册的时机

在Spring-Cloud-Common包中有一个类org.springframework.cloud. client.serviceregistry .ServiceRegistry ,它是Spring Cloud提供的服务注册的标准。集成到Spring Cloud中实现服务注册的组件,都会实现该接口。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

该接口有一个实现类是NacoServiceRegistry。文章源自JAVA秀-https://www.javaxiu.com/42474.html

SpringCloud集成Nacos的实现过程:文章源自JAVA秀-https://www.javaxiu.com/42474.html

在spring-clou-commons包的META-INF/spring.factories中包含自动装配的配置信息如下:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

其中AutoServiceRegistrationAutoConfiguration就是服务注册相关的配置类:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

在AutoServiceRegistrationAutoConfiguration配置类中,可以看到注入了一个AutoServiceRegistration实例,该类的关系图如下所示。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

可以看出, AbstractAutoServiceRegistration抽象类实现了该接口,并且最重要的是NacosAutoServiceRegistration继承了AbstractAutoServiceRegistration。文章源自JAVA秀-https://www.javaxiu.com/42474.html

看到EventListener我们就应该知道,Nacos是通过Spring的事件机制继承到SpringCloud中去的。文章源自JAVA秀-https://www.javaxiu.com/42474.html

AbstractAutoServiceRegistration实现了onApplicationEvent抽象方法,并且监听WebServerInitializedEvent事件(当Webserver初始化完成之后) , 调用this.bind ( event )方法。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

最终会调用NacosServiceREgistry.register()方法进行服务注册。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

NacosServiceRegistry的实现 在NacosServiceRegistry.registry方法中,调用了Nacos Client SDK中的namingService.registerInstance完成服务的注册。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

跟踪NacosNamingService的registerInstance()方法:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

通过beatReactor.addBeatInfo()创建心跳信息实现健康检测, Nacos Server必须要确保注册的服务实例是健康的,而心跳检测就是服务健康检测的手段。文章源自JAVA秀-https://www.javaxiu.com/42474.html

serverProxy.registerService()实现服务注册文章源自JAVA秀-https://www.javaxiu.com/42474.html

心跳机制:

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

从上述代码看,所谓心跳机制就是客户端通过schedule定时向服务端发送一个数据包 ,然后启动-个线程不断检测服务端的回应,如果在设定时间内没有收到服务端的回应,则认为服务器出现了故障。Nacos服务端会根据客户端的心跳包不断更新服务的状态。文章源自JAVA秀-https://www.javaxiu.com/42474.html

注册原理:

Nacos提供了SDK和Open API两种形式来实现服务注册。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Open API:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

SDK:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

这两种形式本质都一样,底层都是基于HTTP协议完成请求的。所以注册服务就是发送一个HTTP请求:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

在这里插入图片描述文章源自JAVA秀-https://www.javaxiu.com/42474.html

对于nacos服务端,对外提供的服务接口请求地址为nacos/v1/ns/instance,实现代码咋nacos-naming模块下的InstanceController类中:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

在这里插入图片描述文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 从请求参数汇总获得serviceName(服务名)和namespaceId(命名空间Id)文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 调用registerInstance注册实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 创建一个控服务(在Nacos控制台“服务列表”中展示的服务信息),实际上是初始化一个serviceMap,它是一个ConcurrentHashMap集合文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • getService,从serviceMap中根据namespaceId和serviceName得到一个服务对象文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 调用addInstance添加服务实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 根据namespaceId、serviceName从缓存中获取Service实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 如果Service实例为空,则创建并保存到缓存中文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 通过putService()方法将服务缓存到内存文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • service.init()建立心跳机制文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • consistencyService.listen实现数据一致性监听文章源自JAVA秀-https://www.javaxiu.com/42474.html

    service.init ( ) 方法的如下图所示,它主要通过定时任务不断检测当前服务下所有实例最后发送心跳包的时间。如果超时,则设置healthy为false表示服务不健康,并且发送服务变更事件。在这里请大家思考一一个问题,服务实例的最后心跳包更新时间是谁来触发的?实际上前面有讲到, Nacos客户端注册服务的同时也建立了心跳机制。文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

putService方法,它的功能是将Service保存到serviceMap中:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

继续调用addInstance方法把当前注册的服务实例保存到Service中:文章源自JAVA秀-https://www.javaxiu.com/42474.html

总结:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos客户端通过Open API的形式发送服务注册请求 Nacos服务端收到请求后,做以下三件事:构建一个Service对象保存到ConcurrentHashMap集合中 使用定时任务对当前服务下的所有实例建立心跳检测机制 基于数据一致性协议服务数据进行同步 服务提供者地址查询 Open API:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

SDK:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

InstanceController中的list方法:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 解析请求参数文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 通过doSrvIPXT返回服务列表数据文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 根据namespaceId、serviceName获得Service实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 从Service实例中基于srvIPs得到所有服务提供者实例文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 遍历组装JSON字符串并返回文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos服务地址动态感知原理

可以通过subscribe方法来实现监听,其中serviceName表示服务名、EventListener表示监听到的事件:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

具体调用方式如下:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

或者调用selectInstance方法,如果将subscribe属性设置为true,会自动注册监听:文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos实现原理详解文章源自JAVA秀-https://www.javaxiu.com/42474.html

Nacos客户端中有一个HostReactor类,它的功能是实现服务的动态更新,基本原理是:文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 客户端发起时间订阅后,在HostReactor中有一个UpdateTask线程,每10s发送一次Pull请求,获得服务端最新的地址列表文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 对于服务端,它和服务提供者的实例之间维持了心跳检测,一旦服务提供者出现异常,则会发送一个Push消息给Nacos客户端,也就是服务端消费者文章源自JAVA秀-https://www.javaxiu.com/42474.html

  • 服务消费者收到请求之后,使用HostReactor中提供的processServiceJSON解析消息,并更新本地服务地址列表文章源自JAVA秀-https://www.javaxiu.com/42474.html

1. SpringBoot 操作 Redis的各种实现(以及Jedis、Redisson、Lettuce的区别比较)2. 小心Lombok用法中的坑3. 你真的会写for循环吗?来看看这些常见的for循环优化方式4. SpringCloud常见面试题(2021最新版)最近面试BAT,整理一份面试资料《Java面试BATJ通关手册》,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。获取方式:点“在看”,关注公众号并回复 Java 领取,更多内容陆续奉上。

文章有帮助的话,在看,转发吧。文章源自JAVA秀-https://www.javaxiu.com/42474.html

谢谢支持哟 (*^__^*)文章源自JAVA秀-https://www.javaxiu.com/42474.html

继续阅读
速蛙云 - 极致体验,强烈推荐!!!购买套餐就免费送各大视频网站会员!快速稳定、独家福利社、流媒体稳定解锁!速度快,全球上网、视频、游戏加速、独立IP均支持!基础套餐性价比很高!这里不多说,我一直正在使用,推荐购买:https://www.javaxiu.com/59919.html
weinxin
资源分享QQ群
本站是JAVA秀团队的技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默!
沙海
  • 版权声明:本站是JAVA秀团队的技术分享社区,我们会经常分享资源和教程。
  • 转载请注明:Nacos实现原理详解 - JAVA秀 ☜(ˆ▽ˆ)
匿名

发表评论

匿名网友 填写信息

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定