【源码分析】Nacos如何是现在CP模式下基于Raft协议的节点注册逻辑

小咪咪 2024-03-23 20:23 3阅读 0赞

而对于持久节点，有一个Raft协议的实现  
![在这里插入图片描述][07fb148689484ea69e9f70820128e80c.png]

我们知道Raft算法作为一个CP协议，它通过的是Leader节点来向各个节点进行数据的同步。  
所以会先判断当前节点是否是Leader节点，如果不是则将请求转发到Leader节点进行处理。  
![在这里插入图片描述][40a73f26bf8941cdae2b8c646c590228.png]

而如果就是Leader节点，那么我们会先将数据写入到内存中，然后再写入到磁盘中。  
![在这里插入图片描述][9693eff8ed0b474dbc8473849c835e49.png]  
![在这里插入图片描述][34a250ef2a9e4fe189f318fcd9820776.png]

可以看到这里又调用了notifier的addTask方法  
![在这里插入图片描述][2e2d83f1d3af46018fe418a0fe5fb148.png]

那么之后的流程还是一样的，会根据放入的key去更新内存中的数据，并且最后这里的持久化策略会选择  
![在这里插入图片描述][d8884642b3824b08a91ac870a7bc66af.png]  
![在这里插入图片描述][ca87625cdf8d4015b49a19ab95d246fb.png]

这里会选择else里面的逻辑。  
在这里需要考虑的一个问题是，我们使用的是Raft协议，Raft协议是基于选择Leader节点来进行数据同步的，那么也就是需要保证集群中是存在一个Leader节点的。而选举规则为 总节点数/2+1。  
所以如果集群中只有三个节点，其中一个节点挂了，那么就只有两个节点是没办法选择出一个Leader的，这样子就会出问题。  
也就是Nacos还得设计一个策略，来解决只有两个节点的时候也可以进行数据同步，而更少的时候则需要进行阻塞。  
Nacos采用的是CountDownLaunch这种计数器的方式。  
![在这里插入图片描述][876615a41be647dcb3bb023a3e6e36c1.png]  
![在这里插入图片描述][d1fc6ccf61724163a6abef46153c20ac.png]  
![在这里插入图片描述][11c5c8ac1c4345848a4c9aa3cb3e1722.png]

上面的逻辑很明确了，主节点会直接把数据落盘，而从节点，则会向他们发送一个请求让他们去写盘，并且写盘成功之后会回调方法，那么计数器就会-1，只要最后计数器为0，那么就不会报错并且释放锁，否则就报错然后释放锁。

[07fb148689484ea69e9f70820128e80c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/3de469bb9a5a4907921854f07859e0fe.png
[40a73f26bf8941cdae2b8c646c590228.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/b6ee0b292acb41c28cd3c36a4d9b14fa.png
[9693eff8ed0b474dbc8473849c835e49.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/6f8ea92e4022437cabf2faa792889614.png
[34a250ef2a9e4fe189f318fcd9820776.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/959883a586ff445c8100aa4ff0725668.png
[2e2d83f1d3af46018fe418a0fe5fb148.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/4db728399217401f9bc057e4ca2d05dc.png
[d8884642b3824b08a91ac870a7bc66af.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/4875985c3652462eb84febffd2a443c0.png
[ca87625cdf8d4015b49a19ab95d246fb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/98d8486089f9488dad5c838ca7a2bb3d.png
[876615a41be647dcb3bb023a3e6e36c1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/7bb5650dad0e44be8d2b3f9f91ead3c4.png
[d1fc6ccf61724163a6abef46153c20ac.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/e4548e7e332e4b6396f3100c79fc181c.png
[11c5c8ac1c4345848a4c9aa3cb3e1722.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/6ac1c66abf2d4b808216eee004ad0d10.png