【深入理解SpringCloud微服务】深入理解nacos

【深入理解SpringCloud微服务】深入理解nacos

  • Nacos服务注册
  • 内存注册表
  • 内存注册表的更新
  • 通知客户端服务变更、服务同步、健康检查
  • 2.x版本nacos的变化

Nacos服务注册

spring-cloud-alibaba-nacos-discovery通过实现spring-cloud-commons规范定义的接口，完成nacos接入spring-cloud后的客户端自动注册，我们不研究Nacos如何实现spring-cloud-commons规范，只要知道最终是利用Spring的事件监听机制触发服务注册。

在这里插入图片描述

然后就会调用nacos的NamingService进行服务注册，所以真正的入口是这个NamingService。

nacos总体上也是CS结构：
在这里插入图片描述

有一个nacos服务端接收http请求，然后我们的微服务集成了一个nacos客户端，发送http请求给nacos服务端，这个nacos客户端就是NamingService。通过Spring的事件监听机制触发NamingService的调用，而NamingService通过HttpURLConnection发送http请求。

在这里插入图片描述

AbstractAutoServiceRegistration#onApplicationEvent：

    public void onApplicationEvent(WebServerInitializedEvent event) {this.bind(event);}public void bind(WebServerInitializedEvent event) {...this.start();...}public void start() {...this.register();...}protected void register() {this.serviceRegistry.register(this.getRegistration());}

上面的this.serviceRegistry就是NacosServiceRegistry，this.getRegistration()返回的就是NacosRegistration，然后this.serviceRegistry.register(this.getRegistration())就会进入NacosServiceRegistry的register方法。

NacosServiceRegistry#register

	@Overridepublic void register(Registration registration) {...namingService.registerInstance(serviceId, group, instance);...}

调用NamingService的registerInstance方法进行服务注册，里面就是向nacos服务端发起服务注册的http请求了。

然后nacos的InstanceController接收到http请求，调用ServiceManager更新内存注册表。

nacos使用了一个ServiceManager保存了内存注册表，当接收到服务注册请求时，nacos服务端会把服务实例信息写入到ServiceManager里面的内存注册表。

在这里插入图片描述

@RestController
@RequestMapping(UtilsAndCommons.NACOS_NAMING_CONTEXT + "/instance")
public class InstanceController {...@Autowiredprivate ServiceManager serviceManager;...@CanDistro@PostMapping@Secured(parser = NamingResourceParser.class, action = ActionTypes.WRITE)public String register(HttpServletRequest request) throws Exception {...//请求发送的是Instance信息，接收请求的时解析出来的也是Instancefinal Instance instance = parseInstance(request);//保存客户端注册信息serviceManager.registerInstance(namespaceId, serviceName, instance);return "ok";}...
}

内存注册表

Nacos的ServiceManager保存了一个内存注册表，是一个双层的ConcurrentHashMap，外层的key是namespace（nacos的命名空间），内层的key是group拼上serviceName（服务名），value则是一个Service对象。

在这里插入图片描述

    /*** Map(namespace, Map(group::serviceName, Service)).*/private final Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>();

Service里面并不是直接存放注册上来的服务实例信息，而是一个Map<String, Cluster>类型的clusterMap，Cluster代表集群，nacos这里把不同集群下的实例分组，把同一集群下的实例分到同一个Cluster里面，这样我们就可以就近选取同一集群下的实例。

在这里插入图片描述

Service#clusterMap

    //Service里面保存的又是一个Map，集群名称和Cluster实例的映射，Cluster里面才保存真正的服务实例private Map<String, Cluster> clusterMap = new HashMap<>();

Cluster里面才是真正存放注册上来的服务实例信息，有两个Set集合：

  • Set<Instance> persistentInstances： 持久化实例信息集合
  • Set<Instance> ephemeralInstances：非持久化实例信息集合

在这里插入图片描述

    @JsonIgnoreprivate Set<Instance> persistentInstances = new HashSet<>(); //持久实例集合@JsonIgnoreprivate Set<Instance> ephemeralInstances = new HashSet<>(); //临时实例集合

Instance里面存储的就是服务实例信息，什么ip地址端口号之类的。

内存注册表的更新

Eureka通过三级缓存解决了读写并发冲突，而Nacos则是通过写时复制（copy on write）解决读写并发冲突。

当有服务实例注册上来时，nacos会检查ServiceManger中的内存注册表是否有对应服务的Service对象，如果没有会创建一个空的Service对象放入到内存注册表，如果已经有对应服务的Service对象，则不需要创建。nacos不会马上去修改这个Service对象里面的服务实例信息，而是把该Service对象里面的所有Instance对象，连同新注册上来的Instance对象，收集到一个List中

在这里插入图片描述

这里只会收集所有临时实例，或者所有非临时实例，不会临时和非临时都全部收集上来。然后根据一定的规则生成一个key，把该key与前面的List存入一个内存的临时map中。然后把这个生成的key丢到一个tasks队列中。

在这里插入图片描述

后台会有一个线程轮询这个tasks队列，从队列中取得key，然后根据key从map中取出List，然后把List中的Instance按所属cluster进行分组。分好组后再逐一处理每一组中的Instance，同一组的Instance都是统一集群下的服务实例，再经过一定的处理后，最后会赋值到Cluster对象里面的两个Instance类型的Set集合中的其中一个（临时实例会赋值到ephemeralInstances，非临时实例赋值到persistentInstances），完成写时复制操作。

在这里插入图片描述

值得注意的是，这里nacos使用的了异步写内存注册表，性能是比Eureka要高的。

通知客户端服务变更、服务同步、健康检查

通知客户端服务变更这里与Eureka不一样，Eureka是开启了一个定时任务进行增量更新来感知注册中心服务端的变化。而nacos则是当有服务注册上来，会发送一个UDP请求，通知客户端有服务变更。

在这里插入图片描述

服务同步这nacos与Eureka做法差不多，也是采用了异步同步，不过nacos做了优化，它会攒够一批再一次性同步，也就是做了批量同步的优化。但是超过一定的期限，还是没有攒够一个批次的大小，还是会进行同步。

在这里插入图片描述

健康检查的定时任务是在创建Service的时候启动的，会定时对该Service里面的每个Instance实例进行检查，检查他们的客户端最后一次发送心跳的时间是否超过15s，如果是，则标记为不健康，如果超过30s，则进行服务下线（从内存注册表中剔除，并通知客户端）。

在这里插入图片描述

心跳也是由NamingService开启定时任务定时发送的，这个会在发送服务注册的http请求之前就会开启。

在这里插入图片描述

2.x版本nacos的变化

在nacos2.x以上的版本，如果是临时实例的注册，会走GRPC协议，如果是非临时实例的注册，会走http协议。
在这里插入图片描述
内存注册表的结构也发生了变化，那么与之对应的内存注册表读写的流程（也就是服务注册与服务发现的流程）也发生了变化。

ServiceManager里面不再直接存放双层内存注册表，而是放了一个Service自己与自己对于的map：ConcurrentHashMap<Service, Service> singletonRepository。

在这里插入图片描述

然后每一个连接上来的客户端，都会为它创建一个Client对象，有一个ClientManager管理这些Client对象。

在这里插入图片描述

然后Client里面有一个ConcurrentHashMap<Service, InstancePublishInfo>的map，key是注册上来的服务实例所属的Service，而value则是服务实例信息。

在这里插入图片描述
还有一个ClientServiceIndexesManager存放Service与所有对应的clientId之间的映射。
在这里插入图片描述

因为一个Service可能会有多个服务实例，每个服务实例注册上来时，都会创建一个Client，那么这里记录一个Service对应的有哪些服务实例，Service就可以拿到对应的clientId集合，进而拿到所有的Client对象，而Client对象中有存放了对应的服务实例信息，这样就可以拿到对应的服务实例信息。

于是服务发现的流程就是这样：

在这里插入图片描述

除了内存注册表以及服务注册与发现的变化外，服务同步、通知客户端服务变更、以及健康检查也发生了变化。

服务同步和通知客户端服务变更这两个操作也是异步的，这一点和1.x版本一样。由于2.x的nacos已经换成了GRPC协议，所以这里也是通过发送GRPC协议的请求进行处理，因为GRPC协议底层是长连接的，因此这里不需要再重复建立请求，只需要拿到对应的Connection连接对象，发送一个GRPC请求就可以。

在这里插入图片描述
1.x版本的nacos通过定时任务定时检测服务实例的最后心跳时间，如果超期了就进行服务下线。而2.x版本的nacos由于换成了GRPC协议的长连接，服务端和客户端之间没有再次建立请求的额外开销，因此增加了一个服务端主动探活的操作，如果客户端有响应，那么还是不会进行服务下线的。

在这里插入图片描述

2.x版本的nacos还对异步处理进行了封装，把事件监听机制封装到NotifyCenter中，把一些定时任务、延时任务、异步任务等的处理封装到了NacosTaskExecuteEngine中，这里就不细说了。

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

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

相关文章

昇思25天学习打卡营第11天|xiaoyushao

昇思25天学习打卡营第11天|xiaoyushao

今天分享ResNet50迁移学习。 在实际应用场景中&#xff0c;由于训练数据集不足&#xff0c;所以很少有人会从头开始训练整个网络。普遍的做法是&#xff0c;在一个非常大的基础数据集上训练得到一个预训练模型&#xff0c;然后使用该模型来初始化网络的权重参数或作为固定特征提…
阅读更多...
IT服务运营过程中的资源要素管理（至简）

IT服务运营过程中的资源要素管理（至简）

在IT服务运营管理过程中&#xff0c;所有资源要投入正式、连续、稳定运行&#xff0c;要保持规范化的管理和标准化的操作&#xff0c;具体包括工具管理、知识管理、服务台管理与评价、备件库管理等内容。 一、工具管理 1、工具的基本运营。见下表&#xff1a; 工具的基本运营…
阅读更多...
论文阅读：Deep_Generic_Dynamic_Object_Detection_Based_on_Dynamic_Grid_Maps

论文阅读：Deep_Generic_Dynamic_Object_Detection_Based_on_Dynamic_Grid_Maps

目录 概要 Motivation 整体框架流程 技术细节 小结 不足 论文地址&#xff1a;Deep Generic Dynamic Object Detection Based on Dynamic Grid Maps | IEEE Conference Publication | IEEE Xplore 概要 该文章提出了一种基于动态网格图&#xff08;Dynamic Grid Maps&a…
阅读更多...
一张图 介绍基础服务器类型

一张图 介绍基础服务器类型

阅读更多...
pyarmor，一个超厉害的 Python 库

pyarmor，一个超厉害的 Python 库

在当今的软件开发领域&#xff0c;代码保护是一个不可忽视的重要环节。pyarmor作为一个强大的Python代码保护工具&#xff0c;可以帮助我们轻松地对Python脚本进行加密和授权控制&#xff0c;确保源码的安全。本文将深入介绍pyarmor的特性、安装方法、基本功能以及高级功能&…
阅读更多...
操作系统面试知识点总结4

操作系统面试知识点总结4

#来自ウルトラマンメビウス&#xff08;梦比优斯&#xff09; 1 文件系统基础 1.1 文件的相关概念 文件是以计算机硬盘为载体的存储在计算机上的信息集合&#xff0c;可以是文本文档、图片、程序。 文件的结构&#xff1a;数据项、记录、文件&#xff08;有结构文件、无结构式…
阅读更多...
橙单前端项目下载编译遇到的问题与解决

橙单前端项目下载编译遇到的问题与解决

今天下载orange-admin前端项目&#xff0c;不过下载下来运行也出现一些问题。 1、运行出现下面一堆错误&#xff0c;如下&#xff1a; 2、对于下面这个错误 error Expected linebreaks to be LF but found CRLF linebreak-style 这就是eslint的报错了&#xff0c;可能是原作者…
阅读更多...
Python学习笔记44：游戏篇之外星人入侵(五)

Python学习笔记44：游戏篇之外星人入侵(五)

前言 上一篇文章中&#xff0c;我们成功的设置好了游戏窗口的背景颜色&#xff0c;并且在窗口底部中间位置将飞船加载出来了。 今天&#xff0c;我们将通过代码让飞船移动。 移动飞船 想要移动飞船&#xff0c;先要明白飞船位置变化的本质是什么。 通过上一篇文章&#xff0…
阅读更多...
新手小白的pytorch学习第十四弹------十一、十二、十三弹卷积神经网络CNN的习题

新手小白的pytorch学习第十四弹------十一、十二、十三弹卷积神经网络CNN的习题

习题编号目录 No 1No 2No 3No 4No 5No 6No 7No 8No 9No 10No 11No 12No 13 练习题主要就是 写代码&#xff0c;所以这篇文章大部分是代码哟~ No 1 What are 3 areas in industry where computer vision is currently being used? No 2 工业异常检测&#xff0c;目标检测 Sea…
阅读更多...
第三十四天 复合选择器之后代选择器

第三十四天 复合选择器之后代选择器

常用复合选择器包括 后代选择器、子选择器、并集选择器、伪类选择器 后代选择器 语法 选择器1 选择器2{属性:属性值;} 出现重复组可以用类名进行区别 后代选择器可以无限套娃 父子等级可以是人为创造的
阅读更多...
利用GPT4o Captcha工具和AI技术全面识别验证码

利用GPT4o Captcha工具和AI技术全面识别验证码

利用GPT4o Captcha工具和AI技术全面识别验证码 &#x1f9e0;&#x1f680; 摘要 GPT4o Captcha工具是一款命令行工具&#xff0c;通过Python和Selenium测试各种类型的验证码&#xff0c;包括拼图、文本、复杂文本和reCAPTCHA&#xff0c;并使用OpenAI GPT-4帮助解决验证码问…
阅读更多...
【C++】倍增LCA详解 + P3379 最近公共祖先题解

【C++】倍增LCA详解 + P3379 最近公共祖先题解

文章目录 1.暴力做法2.倍增做法问题1问题2 总结CodeEnd 这道题是一道求树上最近公共祖先的模板题。 1.暴力做法 我们先思考O(n)的暴力做法&#xff1a;&#xff08;这里的n是指树的最大深度&#xff0c;也可以近似于节点个数&#xff09; 我们假设我们要求的是lca(u,v)&#…
阅读更多...
Web Components标准化与浏览器兼容性

Web Components标准化与浏览器兼容性

Web Components是一套W3C标准&#xff0c;旨在提供一种构建可重用、封装良好的Web界面组件的方法。这套标准包括四个主要部分&#xff1a;Custom Elements、Shadow DOM、HTML Templates和HTML Imports&#xff08;后者已被废弃&#xff0c;通常被ES6 Modules替代&#xff09;。…
阅读更多...
性能调优本质：如何精准定位瓶颈并实现系统极致优化

性能调优本质：如何精准定位瓶颈并实现系统极致优化

目录 先入为主的反例 性能调优的本质 性能调优实操案例 性能调优相关文章 先入为主的反例 在典型的 ETL 场景中，我们经常需要对数据进行各式各样的转换，有的时候，因为业务需求太复杂，我们往往还需要自定义 UDF（User Defined Functions）来实现特定的转换逻辑。 但是…
阅读更多...
spring IOC DI -- IOC详解

spring IOC DI -- IOC详解

T04BF &#x1f44b;专栏: 算法|JAVA|MySQL|C语言 &#x1faf5; 今天你敲代码了吗 文章目录 4.2 Ioc 详解4.2.1 Bean的存储Controller(控制器存储)Service (服务存储)Repository(仓库存储)Component(组件存储)Configuration(配置存储) 4.2.2 为什么需要这么多类注解?4.2.3方法…
阅读更多...
追问试面试系列：线程池

追问试面试系列：线程池

hi 欢迎来到线程池系列，线程池在面试中出现的频率非常高。 先看面试题 关于线程池的追问试一共整理22问： ● 面试官：为什么要用线程池 ● 面试官：那怎么创建线程池？ ● 面试官：为什么不推荐使用Executors类创建线程池？ ● 面试官：ThreadPoolExecutor 有哪些常用的方…
阅读更多...
Vue如何让用户通过a链接点击下载一个excel文档

Vue如何让用户通过a链接点击下载一个excel文档

在Vue中&#xff0c;通过<a>标签让用户点击下载Excel文档&#xff0c;通常需要确保服务器支持直接下载该文件&#xff0c;并且你有一个可以直接访问该文件的URL。以下是一些步骤和示例&#xff0c;展示如何在Vue应用中实现这一功能。 1. 服务器端支持 首先&#xff0c;…
阅读更多...
AI学习指南机器学习篇- 标签传播算法的数学基础

AI学习指南机器学习篇- 标签传播算法的数学基础

AI学习指南机器学习篇- 标签传播算法的数学基础 引言 标签传播算法是一种常用的无监督学习算法&#xff0c;广泛应用于社区检测、聚类分析、图像分割等领域。本文将介绍标签传播算法背后的数学理论&#xff0c;包括图论、概率图模型等&#xff0c;同时探讨算法的收敛性和稳定…
阅读更多...
面试重点---快速排序

面试重点---快速排序

快排单趟 快速排序是我们面试中的重点&#xff0c;这个知识点也很抽象&#xff0c;需要我们很好的掌握&#xff0c;而且快速排序的代码也是非常重要&#xff0c;需要我们懂了还不行&#xff0c;必须要手撕代码&#xff0c;学的透彻。 在研究快速排序之前&#xff0c;我们首先…
阅读更多...
depcheck 前端依赖检查

depcheck 前端依赖检查

介绍 depcheck 是一款用于检测项目中 未使用依赖项 的工具。 depcheck 通过扫描项目文件&#xff0c;帮助你找出未被引用的依赖&#xff0c;从而优化项目。 优势&#xff1a; 简单易用: 仅需几个简单的命令&#xff0c;就能够扫描并列出未使用的依赖项&#xff0c;让你快速了…
阅读更多...
最新文章

Copyright @ 2022~2023