Day3——Nacos自动服务注册原理（三）

╰+攻爆jí腚メ 2022-12-29 14:29 195阅读 0赞

### 文章目录 ###

*  一. 问题背景
 *  二. 前言
 *  三. 回顾
 *  四. 客户端的心跳机制
 *  五. nacos服务端的心跳检测机制
 *   *  5.1 理解service、instance、cluster（重要）
     *  5.2 服务端的心跳机制
 *  六. 总结

# 一. 问题背景 #

昨天研究了[Day2——Nacos自动服务注册原理（二）][Day2_Nacos]，虽然知道了如何自动服务注册，但是nacos服务端会检测服务实例的健康状态，若实例不健康，则会将该实例剔除，这是心跳检测机制。因此今天继续研究，内容是心跳机制

# 二. 前言 #

1.  心跳机制会在一个循环内发送更加多的url请求
2.  **关于本篇博客，还是推荐了解心跳机制的流程即可，不必纠结在源码实现细节，毕竟源码会因springboot的版本不同而不同。**
3.  **本文将从nacos客户端、服务端来讲解自动服务注册的流程**
4.  [前往gitee下载nacos客户端源码工程][gitee_nacos]用来研究nacos自动服务注册的源码，[前往nacos的github页面下载][nacos_github]，用来启动nacos

# 三. 回顾 #

[Day2——Nacos自动服务注册原理（二）][Day2_Nacos]

# 四. 客户端的心跳机制 #

客户端的心跳机制，可以叫做 **心跳续约**，而服务端的心跳机制可以叫做 **健康检查**。

首先从客户端的核心服务注册方法入手，如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 1]  
**解释：reactor设计模式是event-driven architecture的一种实现方式,处理多个客户端并发的向服务端请求服务的场景。**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 4]  
**总结：schedule虽然只会执行一次；但是在BeatTask线程里面又再调用了schedule()方法，所以是无限循环**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 5]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 7]  
**总结：客户端的心跳机制，其实也是发送http请求。但是底层是利用了一个线程池，开启一个线程去发送心跳。并且线程里面又再次调用了一次开启线程的方法。如果要对spring系统做扩展，实现心跳机制，那么我们可以直接仿照定义心跳线程任务的代码去实现**

内容大概如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70 1]

# 五. nacos服务端的心跳检测机制 #

## 5.1 理解service、instance、cluster（重要） ##

要了解服务端的心跳检测机制，必须要搞清楚service、instance、cluster之间的关系。先做一个了解，否则后面很难理解源码。

Service.java

public class Service extends xxx implements Record, RecordListener<Instances> { 
    	/** * 省略其他无关内容 */
    	
    	private Map<String, Cluster> clusterMap = new HashMap<>();
    }

解释：Service维护了一个名为clusterMap的Map。 Service实现了`Record`接口，`RecordListener<Instances>`，所以Service也是一个监听器，他对Instances有兴趣。

再了解Instances，如下：

public class Instances implements Record { 
        // 省略其他无关代码
        
    	private List<Instance> instanceList = new ArrayList<>();
    }

解释：Instances维护了一个实例列表

Cluster.java

public class Cluster extends xxx implements Cloneable { 
        // 持久化的实例
    	@JsonIgnore
        private Set<Instance> persistentInstances = new HashSet<>();
        
        // 临时的实例
        @JsonIgnore
        private Set<Instance> ephemeralInstances = new HashSet<>();
        
        // 服务
    	@JsonIgnore
        private Service service;
    
     	// 元数据
    	private Map<String, String> metadata = new ConcurrentHashMap<>();
    }

总结：了解大概即可，后面还会更深入研究  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 8]

## 5.2 服务端的心跳机制 ##

我们从服务端的服务注册的核心方法`InstanceController#register()`切入。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 9]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 10]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 11]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 12]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 13]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 14]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 15]

**总结：nacos服务端的心跳检测也是使用了定时任务开启线程来处理（具体实现未深入研究，但是源码其实就是根据各种状态去判断客户端是否健康），服务端处理服务注册的过程中用了service，clusterMap，instances这三级关系来维护服务与它的实例们。**

# 六. 总结 #

1.  nacos的客户端心跳机制是开启了线程定时发送心跳信息给服务端。
2.  nacos的服务端心跳机制也是开启线程定时监听客户端的各种状态从而判断是否健康。
3.  nacos用了service，clusterMap，instances来维护服务与它的实例们的关系。

[Day2_Nacos]: https://blog.csdn.net/qq_40634846/article/details/111563263
[gitee_nacos]: https://gitee.com/zilianggan/register-customize
[nacos_github]: https://github.com/alibaba/nacos
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/d961087c1bed464f8208c657c1d757ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/b146c419c0c144f78e861d8961647b4a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/7aa75dacf1a8408f8d7b20687ace35ac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/226ca49bee424dfe90543359a1f066e6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/677fa03200ec4bea87c32db7d2a6fe59.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221120/55a56f780ef94f9f8d0c5cc0eaf0c540.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221120/928f9f5725034064aee11b3a3c28e0b3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221120/cb6b2f2f1d4045b180e959a28ac60d39.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70]: /images/20221120/68b69fd096c04c76a238ffd2bb1541dc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70 1]: /images/20221120/ed305889d53b498f9fe69f126321e402.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221120/50bf17cbe44845ae9106933ead435fa5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 9]: /images/20221120/b49a224f289b4dc1b4a73a9c9ed678ea.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 10]: /images/20221120/0c4930e18b7c46d688b29b6f138f0a4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 11]: /images/20221120/535ed65961d143918f8f960226eb280c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 12]: /images/20221120/3a888452e3e74c868bb5dad754152e19.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 13]: /images/20221120/ce780214f5ae42599c68ed0ed75af4b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 14]: /images/20221120/011ae7b69c964d49b7d82864f7256d22.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNjM0ODQ2_size_16_color_FFFFFF_t_70_pic_center 15]: /images/20221120/bc4e0811f90143acbe92c18d5610523b.png