Nacos服务健康检查与服务变动事件发布源码解析

我就是我 2024-03-08 08:03 106阅读 0赞

#### 目录 ####

*  1 快速入门使用
 *  2 源码解析
 *   *  2.1 环境准备
     *  2.2 查看实例列表源码分析
     *  2.3 nacos与zk的不同 :
     *  2.4 nacos服务发现
     *  2.5 nacos的心跳机制和服务健康检查的逻辑

--------------------

## 1 快速入门使用 ##

![在这里插入图片描述][57d6899018e64f789a2331293f69b4f4.png]

SpringCloud Nacos配置中心：`https://blog.csdn.net/ZGL_cyy/article/details/113621565`  
SpringCloud Nacos实战应用: `https://blog.csdn.net/ZGL_cyy/article/details/130873488`

## 2 源码解析 ##

### 2.1 环境准备 ###

下载源码或者安装包

你可以通过源码和发行包两种方式来获取 Nacos。

从 Github 上下载源码方式

git clone https://github.com/alibaba/nacos.git
    cd nacos/
    mvn -Prelease-nacos -Dmaven.test.skip=true clean install -U  
    ls -al distribution/target/
    
    // change the $version to your actual path
    cd distribution/target/nacos-server-$version/nacos/bin

nacos提供了一些api, 其中有一个api就是用来发现服务的

`https://nacos.io/zh-cn/docs/open-api.html`

![在这里插入图片描述][10900c188cdd46da9e92c362c243417b.png]

### 2.2 查看实例列表源码分析 ###

![在这里插入图片描述][1346c08d07564cd28be1a4e0df60ae3d.png]  
nacos通过springboot的自动装配, 在项目启动时候通过nacos提供的api去nacos服务端拉取服务

查看源码 :

![在这里插入图片描述][e2670cbb14764cc6960b36303103845a.png]

进入NacosDiscoveryAutoConfiguration类查看, 看一下自动装配的源码

![在这里插入图片描述][7afaf3f23f7a4addb49b0806f2925e98.png]

进入this.namingService().selectInstances方法

![在这里插入图片描述][a816071e56e5490881f46af433952519.png]

![在这里插入图片描述][54dbe4ef9eaa429897d30061c7a3a40a.png]

为什么springboot刚启动, 第一次调用注册的服务速度会慢? 就是因为nacos的服务是懒加载的, 我们只有请求了一次服务, nacos才会去服务端将所有注册的服务获取到(上面if中的逻辑), 当我们第二次调用时, 已经获取到服务了, 只需要调用就可以了, 所有第一次请求的速度比较慢

### 2.3 nacos与zk的不同 : ###

总所周知, zk底层采用netty长连接的方式发送心跳, 来判断服务端的服务是否挂掉, 而nacos则是采用短连接 + 周期性线程池(请求服务列表api)的方式来判断服务是否挂掉

上面已经说了nacos服务发现的原理, 让我们来看看第一次服务发现 与周期性服务发现的代码实现

### 2.4 nacos服务发现 ###

**服务第一次发现 :**

![在这里插入图片描述][a3d74cc1d65141f8847b27f8e61f422e.png]

![在这里插入图片描述][7f4c1aeadfdc480399fb398766738eb0.png]

![在这里插入图片描述][a1d1c72ccb67454698809e722e8676d1.png]

**周期性服务发现 :**

![在这里插入图片描述][f154bfad96ac4279a12708557800a5c2.png]

进入this.scheduleUpdateIfAbsent方法

![在这里插入图片描述][2a020b6b840c447a88f0947e06ae95c4.png]

![在这里插入图片描述][035d34e87e134c99b099b4be454d5f7d.png]

进入this.updateService(this.serviceName, this.clusters);

![在这里插入图片描述][6efe6d36d9ff4b96a851d0388e27f997.png]

![在这里插入图片描述][887e1cd118e04994a105323ca2ca103d.png]

服务发现就此结束

### 2.5 nacos的心跳机制和服务健康检查的逻辑 ###

接下来一起看一下nacos的心跳机制和服务健康检查的逻辑

从nacos的服务注册开始查看(注册的源码分析上一篇有所讲解), nacos的客户端服务注册过程中有这样一行代码

![在这里插入图片描述][8b1a251cae864f5aae1598ee88e0a416.png]

分别进入两个方法

![在这里插入图片描述][cb71e63a56e944aa906c41031b837b51.png]

![在这里插入图片描述][461b3ef788014e6197b0e09e49a4fe7b.png]

此次是一个延时线程池, 过了5秒之后,去执行run方法, 接下来进入run方法

![在这里插入图片描述][44e8c0077f8f432398602d90f1c6403f.png]

进入serverProxy.sendBeat方法

![在这里插入图片描述][b382c58836644d3c83b81bf5f1e88b33.png]

![在这里插入图片描述][eea4ca8ce9424780840acfab0d2c8f68.png]

发送实例心跳, nacos在服务注册的时候, 就会通过线程池延时五秒发送心跳, 此处只发送了一次心跳, 按照我们的理解, 应该是持续发送心跳的, 那么接下来继续看run方法中的另一个方法

![在这里插入图片描述][047572815d314984b6d15f7dd465e6e3.png]

通过反复的执行run方法, 来达到每隔5s中发送一次心跳的功能

到此nacos的客服端服务注册完成, 接下来查看一下nacos服务端是如何持续的进行心跳检测的 :

由于方法层次太多就不贴图了, 方法调用路径

InstanceController.register -> 
    getInstanceOperator().registerInstance(namespaceId, serviceName, instance); -> InstanceOperatorServiceImpl.registerInstance -> serviceManager.registerInstance(namespaceId, serviceName, coreInstance); -> createEmptyService(namespaceId, serviceName, instance.isEphemeral()); -> createServiceIfAbsent(namespaceId, serviceName, local, null); -> putServiceAndInit(service); ->
    service.init(); ->

最终进入init()方法

![在这里插入图片描述][b50a3ec2fea84648b4097f5ae8e66bbb.png]

此处又可以看见一个线程池, 进入scheduleCheck方法

![在这里插入图片描述][fa4f7c5fe332407486afaddbf0546d03.png]

接下来进入run方法查看 (他的子类ClientBeatCheckTask类中)

![在这里插入图片描述][d61c3d9a7c8d415f8ecb9c4f8b3e58ed.png]

![在这里插入图片描述][42ab7a4952f24825ad92d81f9795755d.png]

到此为止, 发送心跳和服务的健康状态检查源代码查看完毕

现在大家可能有这样一个疑问, 如果一个服务新注册到nacos服务端, 那么服务发现者们只有在5s之后拉取服务的时候才会发现有新的服务, 那么就会有一个5s的延时发现服务, 其实这样是可以接受的, 但是nacos对此也进行了优化, 如果一个新的服务注册到nacos服务端, 注册完成之后,nacos会利用事件发布, 给所有的服务发现者发送事件, 让服务发现者可以更快的发现服务

[57d6899018e64f789a2331293f69b4f4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/c4226ae97e554d6d866f48007e55d6f6.png
[10900c188cdd46da9e92c362c243417b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/dd010f55ec54435f858bc71c136e6f16.png
[1346c08d07564cd28be1a4e0df60ae3d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/7996bbaa91364600a7f26f43b1e03104.png
[e2670cbb14764cc6960b36303103845a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/60b6558787064004837f32c6032c2cb2.png
[7afaf3f23f7a4addb49b0806f2925e98.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/020433e3011f4e7da9b4d2ce7411f28d.png
[a816071e56e5490881f46af433952519.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/d7c750707fb240df8ef8f05f4da51825.png
[54dbe4ef9eaa429897d30061c7a3a40a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/2580aeb68427470288f11883fde876ad.png
[a3d74cc1d65141f8847b27f8e61f422e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/9db18a924c7f43dfa54867a290a94e5d.png
[7f4c1aeadfdc480399fb398766738eb0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/80c9250c2cce4ee087c89131e4fa82f2.png
[a1d1c72ccb67454698809e722e8676d1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/15594c320fa14e99859221f3c658837b.png
[f154bfad96ac4279a12708557800a5c2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/3027f49db7f244a2bf391eb9cc8fa5dc.png
[2a020b6b840c447a88f0947e06ae95c4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/80d678ba0cf448179712e5f7362509dd.png
[035d34e87e134c99b099b4be454d5f7d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/15462e7ac3844daab9163ef8dbf97d7c.png
[6efe6d36d9ff4b96a851d0388e27f997.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/16a5dd97727b46709be749ef2623e64e.png
[887e1cd118e04994a105323ca2ca103d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/5c1eb533d0d942769924e6087c8e4e9b.png
[8b1a251cae864f5aae1598ee88e0a416.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/e22c74a6f7c04c139fe2cde69d288984.png
[cb71e63a56e944aa906c41031b837b51.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/c83a894e2a5a465a8e714e69bc434eb6.png
[461b3ef788014e6197b0e09e49a4fe7b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/e2b4f3f24c2e470c8f40dad025bafd3e.png
[44e8c0077f8f432398602d90f1c6403f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/7efa2067fdb64214b30dce7b5ce0b2fa.png
[b382c58836644d3c83b81bf5f1e88b33.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/f3b10b283f624e4daf17b5525b8208c3.png
[eea4ca8ce9424780840acfab0d2c8f68.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/a1927ce038f645c8b2f8de69436c0d69.png
[047572815d314984b6d15f7dd465e6e3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/cede5cb0d18d4200896229721f80cc49.png
[b50a3ec2fea84648b4097f5ae8e66bbb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/ef4590a376194122a8d6cd6f198e3fd1.png
[fa4f7c5fe332407486afaddbf0546d03.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/ecff42745f6740bea32a9b7607f720ed.png
[d61c3d9a7c8d415f8ecb9c4f8b3e58ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/b0ea50b7902a40c281a4ca15f142b18f.png
[42ab7a4952f24825ad92d81f9795755d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/97d76d12b67b4f5d8f0d9d675ad5edd8.png