【源码分析】Nacos自动注册源码分析

淡淡的烟草味﹌ 2024-03-23 18:56 53阅读 0赞

#### 文章目录 ####

*  服务注册（AP协议）
 *  服务发现（CP协议）
 *  Nacos是如何整合到SpringCloudAlibaba的？

## 服务注册（AP协议） ##

Nacos提供了NamingService的registerInstance方法来提供服务注册的功能。  
因此只要我们能获取到这个NamingService即可完成服务的注册。  
![在这里插入图片描述][3ee169045941447faecd5edef73fcb21.png]

我们可以通过NacosFactory的方式来获取到NamingService以及配置中心ConfigService。  
![在这里插入图片描述][957d51bd37c745318af70d64994ed3c4.png]

而这个注册中心的底层获取方式其实就是通过反射的方式来重建一个注册中心类。  
![在这里插入图片描述][ee2c2f894a674b0ab3e557dc1809fec7.png]

所以我们可以按照如下方式注册并且获得注册中心的所有实例，并且监听注册中心对应实例的变化，代码如下：

public class RegisterMain {
        
        public static void main(String[] args) throws NacosException {
        
            NamingService namingService = NacosFactory.createNamingService("123.249.97.220:8848");
            namingService.registerInstance("config-center","localhost",8808);
            namingService.registerInstance("config-center","localhost",8809);
    
            List<Instance> allInstances = namingService.getAllInstances("config-center");
            System.out.println(allInstances);
            System.out.println("---------------");
            namingService.subscribe("config-center", new EventListener() {
        
                @Override
                public void onEvent(Event event) {
        
                    NamingEvent namingEvent = (NamingEvent) event;
                    System.out.println("监听器监听到服务变更，服务名称为："+namingEvent.getServiceName());
                    System.out.println("监听器监听到服务变更，当前实例列表为："+namingEvent.getInstances());
                }
            });
            while(true){
        
    
            }
        }
    }

具体注册实例的方法如下，此时Nacos会根据创建的是否是短实例来选择使用grpcproxy或者httpproxy代理来注册实例。  
![在这里插入图片描述][5f3464bfa0154b8188055f2182b35c75.png]  
![在这里插入图片描述][76f7b293618347ed95965d9592de32d9.png]  
![在这里插入图片描述][d530eb05e7ef420480febbf768b58f12.png]  
其实大概可以看出服务注册就是向服务端发送了一个POST请求并且进行服务的注册。

## 服务发现（CP协议） ##

我们从注册中心获取服务的时候，肯定是要保证服务的一致性的，不然有些服务挂机了，你还能获取到他的实例，结果发个请求都是报错，所以服务发现选择的是CP协议，也就是Raft。  
服务发现的getAllInstances其实底层也可以想到一定是和上面一套一样的流程。  
![在这里插入图片描述][4dadfc190d1e45c9baae8be88616f55b.png]

我们选择httpclientproxy来查看，可以发现底层就是一个get请求  
![在这里插入图片描述][e592aea4501e436da1e672851ded9815.png]

## Nacos是如何整合到SpringCloudAlibaba的？ ##

我们知道，SpringBoot基于Spring提供了一个扩展点，直接使用Spring来整合第三方是非常复杂的。  
而有了SpringBoot之后，基于SpringBoot的约定优于配置的思想，我们只需要将我们需要自动加载的类编写在spring.factories文件中即可。在SpringBoot2.7之后更是改变了自动注入的方式，变得更为简单。  
![在这里插入图片描述][cc3d2f32a574415fbf262e196a08fe2e.png]

此时就可以看到Nacos的注册服务已经被加载了  
![在这里插入图片描述][ea184ae985c845998440a2ae18ae3d36.png]  
![在这里插入图片描述][7d6bee7e30fc46c29d44400399d66d56.png]

所以上面的一套流程可以理解为：我们引入了Nacos作为注册中心之后。  
SpringBoot会自动加载我们的配置类，然后这个配置类包含我们的注册中心的配置，也就是已经为我们提供好了注册方法。那么此时我们的问题就变为了，如何在当前服务启动后，自动的调用NacosServiceRegistry的register方法来将当前服务注册到注册中心去。  
在上面那个bean中用于完成配置属性的封装，而在下面那个bean中则完成我们的服务的自动注册，从名称中也可以看出，Nacos自动注册服务。  
![在这里插入图片描述][e23c8e8f114944bf9206704cdec6532a.png]

我们现在重点看NacosAutoServiceRegistration这个类。  
我们点开这个类中发现其继承关系如下：  
![在这里插入图片描述][4870949a91e84e11a57dcd17e4d0aef5.png]

重点就在于这个ApplicationListener了，我们知道，Spring在完成容器创建之后，会调用AbstractApplicationContext的refresh方法，而这个方法会注册监听器并且发布一个事件。  
![在这里插入图片描述][da65a54a51c54ccda616c3417ad7dc9a.png]  
而这个事件就是容器刷新事件。  
![在这里插入图片描述][175ff3a5e3ec4cf3bf24ad6c4329672a.png]  
而这个事件最后就会触发Web容器初始化事件，从而触发对应的监听器  
![在这里插入图片描述][7c9839c7c72842918bd586cbd595041d.png]  
而这个事件发布之后，就会被我们的监听器所监听到并且执行对应的逻辑，如下：  
![在这里插入图片描述][ea6e8905895c4525be687be9d5c4258a.png]  
![在这里插入图片描述][21f02612152a4c9d93bc9c43dd07050d.png]  
可以发现这里的事件处理包含了一个由Nacos提供的自动注册类来完成。原因就是由于上面的Nacos的自动注册类实现了ApplicationListener  
![在这里插入图片描述][bf2055d6be1444a89dbf564abdc1fcf9.png]  
![在这里插入图片描述][eabff8730eb24a578abe05a206eefe04.png]  
之后start方法将会进行注册  
![在这里插入图片描述][0a91b2784fd04d38b6ce70fb9d53f554.png]  
而这个register方法，就会调用其实现的具体的注册方法  
![在这里插入图片描述][73cc6df527ff44e498f008449a17a675.png]  
此方法即NacosServiceRegistry提供的register方法，而他已经在我们引入Nacos-discovery这个依赖的时候就已经完成了自动注入。  
![在这里插入图片描述][121a75edb3984435b3a3bb7d90590b79.png]  
我们知道SpringCloud其实是一种SPI思想，他只是负责提供一群接口，而其他的厂家基于这个接口来实现具体的方法，Alibaba就是其中的一种，所以可以看到NacosServiceRegistry其实就是实现了SpringCloud提供的接口而已。  
![在这里插入图片描述][d81e4747d57448bdb860c0a550c5636c.png]

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

[3ee169045941447faecd5edef73fcb21.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/32e7e4a783fe42e0a73e97e98505f5b2.png
[957d51bd37c745318af70d64994ed3c4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/fafb388a03434abc8410a4e34650d350.png
[ee2c2f894a674b0ab3e557dc1809fec7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/11ed354200b946f8b3397fa34a98ab96.png
[5f3464bfa0154b8188055f2182b35c75.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/b0968e4b7cfe4788ada971154b7a9c5f.png
[76f7b293618347ed95965d9592de32d9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/7b9d468f938f4dd6b32cca77adf4f8a0.png
[d530eb05e7ef420480febbf768b58f12.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/31ed7c406d37406993071aa9995ff0a1.png
[4dadfc190d1e45c9baae8be88616f55b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/4a32279b932c4cccb9c32aa4dc20c497.png
[e592aea4501e436da1e672851ded9815.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/a8db4e8296c64f1e940b28d2ab8004c8.png
[cc3d2f32a574415fbf262e196a08fe2e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/627d65ec99474effbb9470c25dce9e35.png
[ea184ae985c845998440a2ae18ae3d36.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/b70dfa84f63f495f9bbec51230565605.png
[7d6bee7e30fc46c29d44400399d66d56.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/ba5d436269c84225bb99d212f2f75517.png
[e23c8e8f114944bf9206704cdec6532a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/a7e3fbc497da44ea81d8e2522a8ea88a.png
[4870949a91e84e11a57dcd17e4d0aef5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/ff0a0c5930704f11abd78080d26001a6.png
[da65a54a51c54ccda616c3417ad7dc9a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/c6844fd375f4498a9190c71f81eb2508.png
[175ff3a5e3ec4cf3bf24ad6c4329672a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/bcc1d1235b7d45d9946359af6f839134.png
[7c9839c7c72842918bd586cbd595041d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/0009d0575588418ab9eaa0f41f60228b.png
[ea6e8905895c4525be687be9d5c4258a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/fec105d5163249dd9d773a67feca0859.png
[21f02612152a4c9d93bc9c43dd07050d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/b0e41ad214e54aa8a74d416dc72ad08a.png
[bf2055d6be1444a89dbf564abdc1fcf9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/191774970931405bb86c3ffefff293fe.png
[eabff8730eb24a578abe05a206eefe04.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/c6c61d3feb764386b55b3c254089ab4f.png
[0a91b2784fd04d38b6ce70fb9d53f554.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/6d9478e3674b400faac42f644a4c2687.png
[73cc6df527ff44e498f008449a17a675.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/aacc97cbf3344da986036bb535d76381.png
[121a75edb3984435b3a3bb7d90590b79.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/4b0aabdb61184d5e88d6310661c063db.png
[d81e4747d57448bdb860c0a550c5636c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/bdd3f6c19dcf4ef7a4d8d3feecc4071e.png
[a347b640a4104398a1c7c21acdfbc58f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/9cb0acc81d46411fb2422a86d1c45e57.png