图文详述Nacos服务注册源码分析

╰半夏微凉° 2023-10-01 09:52 49阅读 0赞

## 一、Nacos服务注册流程图 ##

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16]

### 服务注册表serviceMap ###

/**
     * Map(namespace, Map(group::serviceName, Service)).
     */
    private final Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>();

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 1]

## 二、Nacos服务注册入口 ##

### 1、SpringBoot自动装配 ###

使用Nacos做为注册中心，首先要在pom中引入：

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>

嗯，然后呢？SpringBoot项目大家都知道有一个很重要的东西：spring.factories，这个是针对引入的jar包做自动装配用的；在SpringBoot项目运行时，SpringFactoriesLoader 类会去寻找`META-INF/spring.factories`文件，spring.factories用键值对的方式记录了所有需要加入容器的类，key为：`org.springframework.boot.autoconfigure.EnableAutoConfiguration`，value为各种`xxxAutoConfiguration`；或key为：`org.springframework.cloud.bootstrap.BootstrapConfiguration`，value为各种`xxxBootstrapConfiguration`。

大家对`EnableAutoConfiguration`都比较熟悉了，自动装配的撒；而`BootstrapConfiguration`可能会相对陌生一点，它呢是做自定义启动配置的，也就是说：所有的Bean都会在SpingApplicatin启动前加入到它的上下文中。

### 2、Nacos中的spring.factories ###

查看引入的nacos-discovery包的层级结构，找到spring.factories文件；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 2]  
打开这文件瞅一瞅：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
上面我有聊到`BootstrapConfiguration`是在SpringBoot项目启动时自动加载配置到SpingApplicatin的上下文中。  
我们进去点进去看一下这个类`NacosDiscoveryClientConfigServiceBootstrapConfiguration`：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 4]  
emmm，它好像啥也没干，就引入了两个自动配置类：`NacosDiscoveryClientAutoConfiguration`，`NacosDiscoveryAutoConfiguration`；咱也不知道哪个是和服务注册相关的，先都点进去看看撒。

（1）NacosDiscoveryClientAutoConfiguration：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 5]  
额额额，从命名来看，好像没有和注册相关的，先看看下一个类吧。

（2）NacosDiscoveryAutoConfiguration：

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 6]  
卧槽，这个好。这个类里能看到用注册register命名的方法；感觉就它了。

### 3、客户端自动注册入口类NacosDiscoveryClientAutoConfiguration ###

`NacosDiscoveryAutoConfiguration`类内部内部管理了三个类：`NacosServiceRegistry`（完成服务注册功能，实现ServiceRegistry接口），`NacosRegistration`（注册时用来存储nacos服务端的相关信息），`NacosAutoServiceRegistration`（自动注册功能）。

这个自动注册功能是怎么实现的呢？从类的命名上来看，感觉是在`NacosAutoServiceRegistration`中的，我们跟进去看一下：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 7]  
`NacosAutoServiceRegistration`类继承自`AbstractAutoServiceRegistration`类；  
![在这里插入图片描述][f7fc6eab9a004cc49b8081f36c3cd730.png]  
再看`AbstractAutoServiceRegistration`类实现了`ApplicationListener`接口。ApplicationListener接口实际是一个事件监听器，其监听`WebServerInitializedEvent`事件。

在`AbstractAutoServiceRegistration`类的bind()方法中会绑定一个事件，启动调用start()方法进行事件的绑定操作。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 8]  
start()方法中再调用register()方法实现注册功能，具体的register()内部逻辑由子类实现。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 9]  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 10]

> 这里和AQS一样，是典型模板方法设计模式。

go on，go on；我们接着看`ServiceRegistry`接口的实现类，点一下发现直接蹦到了`NacosServiceRegistry`类上；感觉对味了。

虽然我们找到了服务注册的入口，但是呢，其实`spring-cloud-commons`包中定义了一套服务注册规范，集成Spring Cloud实现服务注册的组件都会实现`ServiceRegistry`接口。

### 4、Nacos服务注册类NacosServiceRegistry ###

现在我们继续接着NacosServiceRegistry\#register()方法来看：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 11]  
先是组装服务实例信息，然后走入到了`NamingService`接口\#registerInstance()方法，我跟，我继续往里跟；点到`NamingService`接口的实现类`NacosNamingService`；

NacosNamingService类在初始化的时候会实例几个比较关键的类：

// 1）发送心跳的
    private BeatReactor beatReactor;
    
    // 2）事件分发器：订阅的服务发生改变时，Nacos服务端就会通知到当前Nacos Client端；
    //    Client端收到这个通知后，将通知的事件给到观察者，也就是我们自己实现的listener
    private EventDispatcher eventDispatcher;
    
    // 3）与Nacos服务端通信的
    private NamingProxy serverProxy;

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 12]

`NacosNamingService`\#registerInstance()方法套娃如下：

@Override
    public void registerInstance(String serviceName, Instance instance) throws NacosException {
        
        registerInstance(serviceName, Constants.DEFAULT_GROUP, instance);
    }
    
    
    @Override
    public void registerInstance(String serviceName, String groupName, Instance instance) throws NacosException {
        
    
        if (instance.isEphemeral()) {
        
            // 组装心跳信息
            BeatInfo beatInfo = new BeatInfo();
            beatInfo.setServiceName(NamingUtils.getGroupedName(serviceName, groupName));
            beatInfo.setIp(instance.getIp());
            beatInfo.setPort(instance.getPort());
            beatInfo.setCluster(instance.getClusterName());
            beatInfo.setWeight(instance.getWeight());
            beatInfo.setMetadata(instance.getMetadata());
            beatInfo.setScheduled(false);
            long instanceInterval = instance.getInstanceHeartBeatInterval();
            beatInfo.setPeriod(instanceInterval == 0 ? DEFAULT_HEART_BEAT_INTERVAL : instanceInterval);
            
            // 1）发送心跳
            beatReactor.addBeatInfo(NamingUtils.getGroupedName(serviceName, groupName), beatInfo);
        }
    
        // 2）注册服务    
        serverProxy.registerService(NamingUtils.getGroupedName(serviceName, groupName), groupName, instance);
    }

这里有两个重要的点：

> 1、如果实例节点是临时节点的话（默认是临时的），会组装一个心跳信息，然后通过`BeatReactor`组件`发送心跳到服务端`，也就是`服务续约`；  
> 2、调用`ServerProxy`组件`注册服务`到服务端，即`服务上线`。

在聊服务续约和服务注册之前，我们先看一下serviceName的组成，其实就是就是上面传递下来的groupName和serviceName用@@拼接起来作为新的serviceName，以达到Group层的数据隔离。

NamingUtils.getGroupedName(serviceName, groupName)
    
    // NamingUtils
    public static String getGroupedName(String serviceName, String groupName) {
        
            return groupName + Constants.SERVICE_INFO_SPLITER + serviceName;
        }

#### 1）Client服务续约 ####

即Nacos Client端定时发送心跳到服务端。  
在`BeatReactor`\#addBeatInfo()方法中，会启动一个定时任务，立即执行BeatTask这个任务。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 13]  
我们接着来看BeatTask这个Runnable接口的实现类，是如何运行的？  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 14]

我们可以看到它主要展现两个能力：

> （1）调用`NamingProxy`向Nacos服务端发送心跳；  
> （2）再开启一个定时任务，延时5S再持续发送心跳到Nacos服务端，即默认每5s向Nacos服务端发送一次心跳。

发送心跳就很简单了，直接采用`HTTP接口调用`的方式，调用服务端的`/nacos/v1/ns/instance/beat`接口。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 15]

#### 2）Client服务注册 ####

在`NamingProxy`\#registerService()方法中直接做HTTP请求调用Nacos Server的接口`/nacos/v1/ns/instance`做服务注册：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 16]

public static String WEB_CONTEXT = "/nacos";
    
    public static String NACOS_URL_BASE = WEB_CONTEXT + "/v1/ns";
    
    public static String NACOS_URL_INSTANCE = NACOS_URL_BASE + "/instance";

### 5、Nacos Server端如何接收心跳、服务注册请求 ###

上面我们聊到了Nacos Client端分别调用服务端的`/nacos/v1/ns/instance/beat`、`/nacos/v1/ns/instance`接口进行服务续约和服务注册，下面我们聊一下服务端对这个两个请求是如何处理的？

#### 0）先找入口 ####

Nacos Client通过`NamingProxy`类调用Nacos Server，以开源框架的命名规范来看，Nacos Server的源码中应该有个和naming相关命名的模块；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 17]  
接着往下展开，找到controllers包下的`InstanceController`：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 18]

#### 1）Server端接收服务注册请求 ####

`InstanceController#register()`方法是Nacos Server接收服务注册请求的入口：

@CanDistro
    @PostMapping
    @Secured(parser = NamingResourceParser.class, action = ActionTypes.WRITE)
    public String register(HttpServletRequest request) throws Exception {
        
        
        final String namespaceId = WebUtils
                .optional(request, CommonParams.NAMESPACE_ID, Constants.DEFAULT_NAMESPACE_ID);
        final String serviceName = WebUtils.required(request, CommonParams.SERVICE_NAME);
        NamingUtils.checkServiceNameFormat(serviceName);
        
        final Instance instance = HttpRequestInstanceBuilder.newBuilder()
                .setDefaultInstanceEphemeral(switchDomain.isDefaultInstanceEphemeral()).setRequest(request).build();
        // 真正注册服务的地方，serviceName为注册的服务名，namespaceId默认为public
        getInstanceOperator().registerInstance(namespaceId, serviceName, instance);
        return "ok";
    }

其中namespaceId可以做一层数据隔离；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 19]  
我们接着往里看`getInstanceOperator().registerInstance()`：  
![在这里插入图片描述][a8e828b405c043a4b8b2ea6e38c71a33.png]  
InstanceOperator接口有两个实现类，分别是：`InstanceOperatorClientImpl`，`InstanceOperatorServiceImpl`，由于我这里是作为服务端，我们关注`InstanceOperatorServiceImpl`；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 20]

> 1、组装服务的实例信息，包含：IP、Port  
> 2、调用ServiceManager的registerInstanc()方法，完成真正的服务注册操作。

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 21]

ServiceManager\#registerInstanc()方法中主要做四件事：

> 1、如果服务不存在，则创建一个服务；  
> 2、从本地缓存《Map(namespace, Map(group::serviceName, Service))》中获取服务信息；  
> 3、校验服务不能为null；  
> 4、将服务的实例信息添加到DataStore的dataMap缓存中

##### （1）创建服务 #####

这里的操作也很简单，套娃套娃套娃，不对是封装、抽象。最终将服务信息保存到本地缓存serviceMap中。

public void createEmptyService(String namespaceId, String serviceName, boolean local) throws NacosException {
        
        createServiceIfAbsent(namespaceId, serviceName, local, null);
    }
    
    public void createServiceIfAbsent(String namespaceId, String serviceName, boolean local, Cluster cluster)
            throws NacosException {
        
        Service service = getService(namespaceId, serviceName);
        if (service == null) {
        
            
            Loggers.SRV_LOG.info("creating empty service {}:{}", namespaceId, serviceName);
            service = new Service();
            service.setName(serviceName);
            service.setNamespaceId(namespaceId);
            service.setGroupName(NamingUtils.getGroupName(serviceName));
            // now validate the service. if failed, exception will be thrown
            service.setLastModifiedMillis(System.currentTimeMillis());
            service.recalculateChecksum();
            if (cluster != null) {
        
                cluster.setService(service);
                service.getClusterMap().put(cluster.getName(), cluster);
            }
            service.validate();
    
            // 存储服务信息和初始化，点进去
            putServiceAndInit(service);
            if (!local) {
        
                addOrReplaceService(service);
            }
        }
    }
    
    private void putServiceAndInit(Service service) throws NacosException {
        
        putService(service);
        service = getService(service.getNamespaceId(), service.getName());
        // 服务初始化，会做健康检查
        service.init();
    
        // 添加两个监听器，使用Raft协议和 Distro协议维护数据一致性的，，包括：Nacos Client感知服务提供者实例变更
        consistencyService
                .listen(KeyBuilder.buildInstanceListKey(service.getNamespaceId(), service.getName(), true), service);
        consistencyService
                .listen(KeyBuilder.buildInstanceListKey(service.getNamespaceId(), service.getName(), false), service);
        Loggers.SRV_LOG.info("[NEW-SERVICE] {}", service.toJson());
    }
    
    // ”服务注册“操作，也就是将服务信息保存到本地缓存serviceMap中。
    public void putService(Service service) {
        
        if (!serviceMap.containsKey(service.getNamespaceId())) {
        
            serviceMap.putIfAbsent(service.getNamespaceId(), new ConcurrentSkipListMap<>());
        }
        serviceMap.get(service.getNamespaceId()).putIfAbsent(service.getName(), service);
    }

注意：在service.init()初始化服务时，会启动一个定时任务做不健康服务的`服务剔除`：

/**
     * Service#init()
     */
    public void init() {
        
        // 开始一个定时任务，对不健康的服务实例做服务下线/剔除，点进去
        HealthCheckReactor.scheduleCheck(clientBeatCheckTask);
        for (Map.Entry<String, Cluster> entry : clusterMap.entrySet()) {
        
            entry.getValue().setService(this);
            entry.getValue().init();
        }
    }
    
    @JsonIgnore
    private ClientBeatCheckTask clientBeatCheckTask = new ClientBeatCheckTask(this);

走到`HealthCheckReactor.scheduleCheck()`方法中，会延时5s开启一个固定延时5s的FixedDelay类型的定时任务执行服务剔除操作；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 22]  
![在这里插入图片描述][463e6c91256a425f8037d689323a2304.png]

另外：由于`ClientBeatCheckTask`不是`NacosHealthCheckTask`的实现类，所以定时任务中执行的方法为`ClientBeatCheckTask`中的run()方法；  
![在这里插入图片描述][eed7efb7ef9a41d2875e5b215c2a7d84.png]  
看一下`ClientBeatCheckTask`的run()方法：

> 通过判断当前时间和实例最后一次心跳时间的间隔是否大于阈值（默认15s），决定是否进行服务剔除/下线；  
> ![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 23]

##### （2）从本地缓存Map中获取服务信息 #####

从本地缓存serviceMap中获取服务信息，没别的啥操作

public Service getService(String namespaceId, String serviceName) {
        
       // 如果namespaceId没有的话
        if (serviceMap.get(namespaceId) == null) {
        
            return null;
        }
        // 点进去
        return chooseServiceMap(namespaceId).get(serviceName);
    }
    
    public Map<String, Service> chooseServiceMap(String namespaceId) {
        
        return serviceMap.get(namespaceId);
    }

##### （3）校验服务不能为null #####

一个单纯的判空处理；

public void checkServiceIsNull(Service service, String namespaceId, String serviceName) throws NacosException {
        
        if (service == null) {
        
            throw new NacosException(NacosException.INVALID_PARAM,
                    "service not found, namespace: " + namespaceId + ", serviceName: " + serviceName);
        }
    }

##### （4）\*\*服务实例信息"持久化" #####

将服务的相应实例信息保存到DataStore的serviceMap中；由于存在多个服务实例同时注册的场景，所以要加一个synchronized锁。

public void addInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips)
            throws NacosException {
        
        
        String key = KeyBuilder.buildInstanceListKey(namespaceId, serviceName, ephemeral);
        
        Service service = getService(namespaceId, serviceName);
        
        synchronized (service) {
        
            List<Instance> instanceList = addIpAddresses(service, ephemeral, ips);
            
            Instances instances = new Instances();
            instances.setInstanceList(instanceList);
    
            // 保存服务信息，key为namespaceId和serviceName的结合体，点进去
            consistencyService.put(key, instances);
        }
    }

`ConsistencyService`是一个接口，由于我们默认是采用`ephemeral`方式（在聊Nacos Client时我们也有提到，服务端见`Instance#isEphemeral()` 或 `SwitchDomain#isDefaultInstanceEphemeral()`），所以以临时Client为例，我们看一下`DistroConsistencyServiceImpl`；**如果是持久client，则关注RaftConsistencyServiceImpl。**  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 24]

@Override
    public void put(String key, Record value) throws NacosException {
        
        // 服务实例信息持久化，点进去
        onPut(key, value);
        // If upgrade to 2.0.X, do not sync for v1.
        if (ApplicationUtils.getBean(UpgradeJudgement.class).isUseGrpcFeatures()) {
        
            return;
        }
    
        // Nacos集群间数据同步
        distroProtocol.sync(new DistroKey(key, KeyBuilder.INSTANCE_LIST_KEY_PREFIX), DataOperation.CHANGE,
                DistroConfig.getInstance().getSyncDelayMillis());
    }

进入到`DistroConsistencyServiceImpl`类的onPut()方法：

public void onPut(String key, Record value) {
        
        
        if (KeyBuilder.matchEphemeralInstanceListKey(key)) {
        
            Datum<Instances> datum = new Datum<>();
            datum.value = (Instances) value;
            datum.key = key;
            datum.timestamp.incrementAndGet();
            // 往DataStore的dataMap中添加数据，点进去
            dataStore.put(key, datum);
        }
    
        // 如果listener中没有这个key的话直接返回，key是在创建Service时添加进去的，见ServiceManager#putServiceAndInit()方法
        if (!listeners.containsKey(key)) {
        
            return;
        }
    
        // 通知Nacos client服务端服务实例信息发生变更，这里是先添加任务；点进去
        notifier.addTask(key, DataOperation.CHANGE);
    }

###### 1. 往DataStore的dataMap中添加数据 ######

@Component
    public class DataStore {
        
        
        private Map<String, Datum> dataMap = new ConcurrentHashMap<>(1024);
        
        public void put(String key, Datum value) {
        
            // 单纯的往一个Map缓存放一下数据
            dataMap.put(key, value);
        }
    }

###### 2. 进入到Notifier类内部，通知服务实例信息变更 ######

进入到DistroConsistencyServiceImpl的内部类`Notifier`，先看其addTask()方法：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 25]  
![在这里插入图片描述][371886888b5b43b58af622977c853260.png]  
最重要的一步将服务实例信息添加到tasks任务队列中，按常理来说到这也就结束了；但是添加到任务队列之后呢，怎么处理嘞？  
我们注意到`DistroConsistencyServiceImpl`中有一个`@PostConstruct`修饰的init()方法，也就是说在`DistroConsistencyServiceImpl`类构造器执行之后会执行这个方法`启动Notifier通知器`:  
![在这里插入图片描述][0a765a51de1d4c6aac697165beb08afc.png]  
![在这里插入图片描述][cc583cd2da534a618e180e1bc5d72ac4.png]  
我们走入`Notifer#run()`方法：

首先从tasks任务丢列中取出任务，调用自己的handle()方法处理任务：  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 26]  
handle()方法中调用监听器listener的onChange()/onDelete()方法执行相应通知数据更新、删除的逻辑。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 27]  
下面我着重看一下通知数据变更的onChange()方法：

`RecordListener`是一个接口，它有三个实现，我们进入到它的实现类`Service`中；  
![在这里插入图片描述][41cc37888e6d49cba9263335a38a0f70.png]  
着重看一下updateIPs()方法，其他代码不涉及到主链路；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 28]  
遍历要注册的instance集合，采用一个临时的Map记录clusterName和Instance实例的对应关系，然后更新clusterMap<clusterName, Cluster>：

> 维护`Cluster`中实例的代码大家感兴趣可以点进去看看，主要思想还是比对新老数据，找出新的instance，与挂掉的instance，最后更新 cluster对象里面的存放临时节点的集合`或 存放永久节点的集合`。

最后调用PushService通知单客户端服务信息发生变更。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 29]

OK，fine！Nacos服务注册，服务端主要是将服务信息和服务的实例信息保存到两个Map（serviceMap、dataMap）中；启动一个延时5s执行的定时任务做服务剔除/下线；`Notifier`做普通服务集群实例信息维护，调用PushService通知客户端服务信息发生变更。

#### 2）Server端接收心跳请求 ####

`InstanceController#beat()`方法是Nacos Server接收心跳请求的入口：

其内部调用`InstanceOperator`接口的handleBeat()方法做心跳判断；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 30]  
`InstanceOperator`有两个实现类，我们这里讨论的是服务端如何处理客户端的心跳请求，因此我们看`InstanceOperatorServiceImpl`类；  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 31]  
![在这里插入图片描述][9a9718db28cc4305aaecc82c0f45f135.png]  
`InstanceOperatorServiceImpl`\#handleBeat()：

> 1、如果服务还没有注册，就先注册；  
> 2、接着获取服务信息，校验服务不能为null；  
> 3、最后，调用`Service#processClientBeat()`处理客户端心跳；

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 32]

`Service#processClientBeat()`中启动一个只执行一次的任务：  
![在这里插入图片描述][cd27f76d3acb43968d8d6c3b7fa987a9.png]  
![在这里插入图片描述][cfd0e75bfc4e4f7680a909f4e3a069cc.png]  
![在这里插入图片描述][5785cacbe5a5450dbe0001e457579407.png]  
任务的逻辑体现在`ClientBeatProcessor`\#run()方法中：

> 1、更新实例的最后一次心跳时间，进而决定服务是否需要下线/剔除；  
> 2、如果服务之前是不可用的，则设置服务为可用的，并调用`PushService`通知客户端；

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 33]

服务端对于心跳的处理，主要两件事：维护心跳的最后一次时间，如果服务变为可用状态则通知客户端；另外在服务注册创建Service服务时会启动一个固定延时5S执行的定时任务做服务的剔除，其中以心跳时间为根本逻辑。

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/05098d3c73b742cdafef6098d47c2e8d.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/3b55e215a0d5448a801aaca2ce100d37.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/4763464c9b8e4efaa3d607865cf948e1.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/058d6fc09a834c3d800ee93e72f71041.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/dd833a126fba4461abf85ebdf1df3419.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/206e4f9d48ef4d2990fe3396a43cb533.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/d4bae685920841f38789f227ec999fd2.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/46ba88544e514d2f9d62b7e3b87c75e0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[f7fc6eab9a004cc49b8081f36c3cd730.png]: https://img-blog.csdnimg.cn/f7fc6eab9a004cc49b8081f36c3cd730.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 8]: https://img-blog.csdnimg.cn/69ec2713d72f4eb9b705a1201cc4b419.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 9]: https://img-blog.csdnimg.cn/ce07bbb13d984c2cbe5209a1cf428314.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 10]: https://img-blog.csdnimg.cn/43dc82f1fb9a41eea7c46712d035b2cf.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 11]: https://img-blog.csdnimg.cn/e0a132a3615a4e3aaaa83b23ebe91856.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 12]: https://img-blog.csdnimg.cn/7f5c317a97214a959b462afa8efc75b5.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 13]: https://img-blog.csdnimg.cn/fcb886262e92445bbff57c5b963e8a5b.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 14]: https://img-blog.csdnimg.cn/6e8b139e51ff40eaaefffe218ad03754.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 15]: https://img-blog.csdnimg.cn/1d10fa39daea4f12917f7384a78e5aca.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 16]: https://img-blog.csdnimg.cn/f7b389ff81bf435caca4b72ebe5cf9e0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 17]: https://img-blog.csdnimg.cn/a275b527d6e540d2ab8312e2d2247bf2.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 18]: https://img-blog.csdnimg.cn/a17c2e54c21646369abf61442d1e6bf0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 19]: https://img-blog.csdnimg.cn/3bab3b0359ff40fdb24f86164f702f63.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[a8e828b405c043a4b8b2ea6e38c71a33.png]: https://img-blog.csdnimg.cn/a8e828b405c043a4b8b2ea6e38c71a33.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 20]: https://img-blog.csdnimg.cn/75091bdd9dc9403c9b570d792785e6aa.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 21]: https://img-blog.csdnimg.cn/740b3caf10d24c5984807bc8ebc7d961.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 22]: https://img-blog.csdnimg.cn/3c80296a689e4cdc94e7deed17f5817f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[463e6c91256a425f8037d689323a2304.png]: https://img-blog.csdnimg.cn/463e6c91256a425f8037d689323a2304.png
[eed7efb7ef9a41d2875e5b215c2a7d84.png]: https://img-blog.csdnimg.cn/eed7efb7ef9a41d2875e5b215c2a7d84.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 23]: https://img-blog.csdnimg.cn/7459ca2120a740ecaeb594411515a674.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 24]: https://img-blog.csdnimg.cn/601f56d7d11f40b6b7652a3701259be5.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 25]: https://img-blog.csdnimg.cn/654bf8d6f15e47b69ce8ccf3c19d0fc6.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[371886888b5b43b58af622977c853260.png]: https://img-blog.csdnimg.cn/371886888b5b43b58af622977c853260.png
[0a765a51de1d4c6aac697165beb08afc.png]: https://img-blog.csdnimg.cn/0a765a51de1d4c6aac697165beb08afc.png
[cc583cd2da534a618e180e1bc5d72ac4.png]: https://img-blog.csdnimg.cn/cc583cd2da534a618e180e1bc5d72ac4.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 26]: https://img-blog.csdnimg.cn/8f8b355d405a4cd4831792df6a51e1a7.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 27]: https://img-blog.csdnimg.cn/88586cd76f564b10bdbd0c54285f1478.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[41cc37888e6d49cba9263335a38a0f70.png]: https://img-blog.csdnimg.cn/41cc37888e6d49cba9263335a38a0f70.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 28]: https://img-blog.csdnimg.cn/df4f21cdcd004ed19340d7e4d83cd9ec.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 29]: https://img-blog.csdnimg.cn/58a56e30883143638ee1aad2b6d42aa2.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 30]: https://img-blog.csdnimg.cn/b4be0067498b4a4f9e51fdf7cf15dde8.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 31]: https://img-blog.csdnimg.cn/cb143eabba814738b2d46be07e4b7ac1.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[9a9718db28cc4305aaecc82c0f45f135.png]: https://img-blog.csdnimg.cn/9a9718db28cc4305aaecc82c0f45f135.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 32]: https://img-blog.csdnimg.cn/3ee5fe86f54d4a109d52f7bc335ef429.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16
[cd27f76d3acb43968d8d6c3b7fa987a9.png]: https://img-blog.csdnimg.cn/cd27f76d3acb43968d8d6c3b7fa987a9.png
[cfd0e75bfc4e4f7680a909f4e3a069cc.png]: https://img-blog.csdnimg.cn/cfd0e75bfc4e4f7680a909f4e3a069cc.png
[5785cacbe5a5450dbe0001e457579407.png]: https://img-blog.csdnimg.cn/5785cacbe5a5450dbe0001e457579407.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5qWg546W5p-S_size_20_color_FFFFFF_t_70_g_se_x_16 33]: https://img-blog.csdnimg.cn/c94be63314f34c5bb19c51ca71ba4f47.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5qWg546W5p-S,size_20,color_FFFFFF,t_70,g_se,x_16