Nacos 服务注册源码分析（1.4.2）

NacosRegistration

DistroConsistencyServiceImpl#put

获取 instnce

CP 模式采用 Reft 协议

raftStore.updateTerm(local.term.get());

Notifier#run

服务注册，通过 Registration 构建 instance

自动过期

写入内存

添加当前实例到 service

获取服务的 ip. 端口等信息

服务注册

循环 take

group

instance.setLastBeat(System.currentTimeMillis());

获取 servie

HealthCheckReactor.scheduleNow(clientBeatProcessor);

KeyBuilder.matchEphemeralKey(key) ? ephemeralConsistencyService : persistentConsistencyService

Nacos Client1.4.2

同步到其他服务节点

5s 发送一次心跳

刷新 service 中的 instance 列表

更新 instance 的 lastBeat

获取 service 对象通过 namespaceId 和 serviceName

BeatTask#run

Spring 事件机制，启动过程中会调用该方法

发心跳

Instance

添加实例变更到队列

RaftConsistencyServiceImpl#put

获取当前服务的所有 instance 实例

发给主节点

InstanceController#register

this.start()

register()

NacosServiceRegistryAutoConfiguration

DefaultPublisher#run

如果当前服务没有注册，创建新的服务信息

ClientBeatProcessor#run

是否定时发送心跳

创建 schedule

维持心跳（5秒一次）

解析 Instance 对象

执行 run 方法

判断

#onApplicationEvent()

> 30s 无心跳

调用 RecordListener 的 ONCHANG 事件

NacosAutoServiceRegistration

serviceRegistry.register(getRegistration())

Nacos Server1.4.2

ClientBeatCheckTask#run

Service#init

ApplicationContextAware

deleteIp(instance);

HealthCheckReactor.scheduleCheck(clientBeatCheckTask);

发送心跳

instance.isEphemeral()

POST://v1/ns/instance/beat

5 秒钟执行一次

service.processClientBeat(clientBeat);

RaftController#onPublish

parseInstance(request)

getIpAddress(request);

立即执行 shedule 去更新心跳

extends

implements

handle(pair);

POST://v1/ns/instance

namespace

HttpClient.asyncHttpPostLarge

过半机制，大于 1/2 + 1 的节点写入成功才返回成功

final CountDownLatch latch = new CountDownLatch(peers.majorityCount());

发布成功事件

是否是 leader

注册

listener.onDelete(datumKey);

Service

数据持久化

AbstractAutoServiceRegistration

DELETE 事件

NacosServiceRegistry

!isLeader()

删除实例

AP 模式采用 Distro 协议