从实现原理来讲，Nacos 为什么这么强？

今天来分享一下Nacos注册中心的底层原理，从服务注册到服务发现，非常细致,再讲Nacos之前，先来讲一下服务注册和发现。我们知道，现在微服务架构是目前开发的一个趋势。服务消费者要去调用多个服务提供者组成的集群。这里需要做到以下几点：,因此需要引入服务注册中心，它具有以下几个功能：,而Nacos致力于解决微服务中的统一配置，服务注册和发现等问题。Nacos集成了注册中心和配置中心。其相关特性包括：,Nacos支持基于DNS和RPC的服务发现，即服务消费者可以使用DNS或者HTTP的方式来查找和发现服务。Nacos提供对服务的实时的健康检查，阻止向不健康的主机或者服务实例发送请求。Nacos支持传输层（Ping/TCP）、应用层（HTTP、Mysql）的健康检查。,动态配置服务可以以中心化、外部化和动态化的方式管理所有环境的应用配置和服务配置。,支持权重路由，让开发者更容易的实现中间层的负载均衡、更灵活的路由策略、流量控制以及DNS解析服务。,Nacos允许开发者从微服务平台建设的视角来管理数据中心的所有服务和元数据。如：服务的生命周期、静态依赖分析、服务的健康状态、服务的流量管理、路由和安全策略等。,以下是Nacos的架构图：,,其中分为这么几个模块：,OpenAPI：功能访问入口。,Config Service、Naming Service：Nacos提供的配置服务、名字服务模块。,Consistency Protocol：一致性协议，用来实现Nacos集群节点的数据同步，使用Raft算法实现。,其中包含：,小总结：,这里对其原理做一个大致的介绍，在后文则从源码角度进行分析。,首先，服务注册的功能体现在：,Nacos服务注册和发现的实现原理的图如下：,,前提（在本地或者虚机上先启动好Nacos） 这一部分从2个角度来讲Nacos是如何实现的：,首先看下一个包：spring-cloud-commons,,这个ServiceRegistry接口是SpringCloud提供的服务注册的标准，集成到SpringCloud中实现服务注册的组件，都需要实现这个接口。来看下它的结构：,那么对于Nacos而言，该接口的实现类是NacosServiceRegistry，该类在这个pom包下：,,再回过头来看spring-cloud-commons包:,,spring.factories主要是包含了自动装配的配置信息，如图：,,在我之前的文章里我有提到过，在spring.factories中配置EnableAutoConfiguration的内容后，项目在启动的时候，会导入相应的自动配置类，那么也就允许对该类的相关属性进行一个自动装配。那么显然，在这里导入了AutoServiceRegistrationAutoConfiguration这个类，而这个类顾名思义是服务注册相关的配置类。,该类的完整代码如下：,这里做一个分析，AutoServiceRegistrationAutoConfiguration中注入了AutoServiceRegistration实例，该类的关系图如下：,,我们先来看一下这个抽象类AbstractAutoServiceRegistration：,这里实现了ApplicationListener接口，并且传入了WebServerInitializedEvent作为泛型，啥意思嘞，意思是：,对于register（）方法，主要调用的是Nacos Client SDK中的NamingService下的registerInstance（）方法完成服务的注册。,再来看一下心跳监测的方法addBeatInfo（）：,心跳检查如果正常，即代表这个需要注册的服务是健康的，那么执行下面的注册方法registerInstance（）：,下面直接Debug走一遍。两个前提（这里不再展开）：,案例1：用Debug来理解Nacos服务注册流程,1.项目初始化后，根据上文说法，会执行抽象类AbstractAutoServiceRegistration下面的onApplicationEvent（）方法，即事件被监听到。,,2.作为抽象类的子类实现NacosAutoServiceRegistration，监听到Web服务启动后， 开始执行super.register（）方法。,,3.执行NacosServiceRegistry下的register（）方法（super），前面说过，集成到SpringCloud中实现服务注册的组件，都需要实现ServiceRegistry这个接口，而对于Nacos而言，NacosServiceRegistry就是具体的实现子类。执行注册方法需要传入的三个参数：,,而registerInstance（）主要做两件事：,,服务健康的检查：,,检查通过后，发送OpenAPI进行服务的注册：,,服务注册小总结：,这里来做一个大框架式的梳理（也许前面写的有点乱，这里通过几个问答的形式来进行总结）,问题1：Nacos的服务注册为什么和spring-cloud-commons这个包扯上关系？,回答：,1.首先，Nacos的服务注册肯定少不了pom包：spring-cloud-starter-alibaba-nacos-discovery吧。,2.这个包下面包括了spring-cloud-commons包，那么这个包有什么用？,3.spring-cloud-commons中有一个接口叫做ServiceRegistry，而集成到SpringCloud中实现服务注册的组件，都需要实现这个接口。,4.因此对于需要注册到Nacos上的服务，也需要实现这个接口，那么具体的实现子类为NacosServiceRegistry。,问题2：为什么我的项目加了这几个依赖，服务启动时依旧没有注册到Nacos中？,回答：1.本文提到过，进行Nacos服务注册的时候，会有一个事件的监听过程，而监听的对象是WebServer，因此，这个项目需要是一个Web项目！,2.因此查看你的pom文件中是否有依赖：spring-boot-starter-web。,问题3：除此之外，spring-cloud-commons这个包还有什么作用？,回答：,1.这个包下的spring.factories文件中，配置了相关的服务注册的置类，即支持其自动装配。,2.这个配置类叫做AutoServiceRegistrationAutoConfiguration。其注入了类AutoServiceRegistration，而NacosAutoServiceRegistration是该类的一个具体实现。,3.当WebServer初始化的时候，通过绑定的事件监听器，会实现监听，执行服务的注册逻辑。,说白了：,接下来就对Nacos注册的流程进行一个总结：,有一点我们需要清楚：Nacos服务的发现发生在什么时候。例如：微服务发生远程接口调用的时候。一般我们在使用OpenFeign进行远程接口调用时，都需要用到对应的微服务名称，而这个名称就是用来进行服务发现的。,举个例子：,接下来直接开始讲重点，Nacos在进行服务发现的时候，会调用NacosServerList类下的getServers()方法：,接下来来看一下NacosNamingService.selectInstances（）方法：,该方法最终会调用到其重载方法：,这里应该重点关注this.hostReactor这个对象，它里面比较重要的是几个Map类型的存储结构：,再看一看它的getServiceInfo（）方法：,来看下scheduleUpdateIfAbsent（）方法：,案例：用Debug来理解Nacos服务发现流程,1.进行远程接口调用，触发服务的发现，调用NacosServerList的getServers（）方法。传入的serviceId和对应Feign接口上的接口@FeignClient中的名称一致。,,例如，我这里调用的Feign接口是：,这里可以看出来，返回的是一个Instance类型的List，对应的服务也发现并返回了。,,2.这里则调用了NacosNamingService的selectInstances（）方法，我这里的subscribe值是true，即代表我这个消费者直接订阅了这个服务，因此最终的信息是从本地Map中获取，即Nacos维护了一个注册列表。,,3.再看下HostReactor的getServiceInfo（）方法：最终所需要的结果是从serviceInfoMap中获取，并且通过多个Map进行维护服务实例，若存在数据的变化，还会通过强制睡眠5秒钟的方式来等待数据的更新。,,4.无论怎样都会调用this.scheduleUpdateIfAbsent(serviceName, clusters)方法：,,5.通过scheduleUpdateIfAbsent（）方法定时的获取实时的实例数据，并且负责维护本地的服务注册列表，若服务发生更新，则更新本地的服务数据。,,服务发现小总结：,经常有人说过，Nacos有个好处，就是当一个服务挂了之后，短时间内不会造成影响，因为有个本地注册列表，在服务不更新的情况下，服务还能够正常的运转，其原因如下：,最后，服务发现的流程就是：,本地Map–>serviceInfoMap，,更新Map–>updatingMap,异步更新结果Map–>futureMap,,最终的结果从serviceInfoMap当中获取。,HostReactor类中的getServiceInfo（）方法通过this.scheduleUpdateIfAbsent() 方法和updateServiceNow（）方法实现服务的定时更新和立刻更新。,而对于scheduleUpdateIfAbsent（）方法，则通过线程池来进行异步的更新，将回调的结果（Future）保存到futureMap中，并且发生提交线程任务时，还负责更新本地注册列表中的数据。