首页  流程图  详情

Nacos源码分析-服务注册与发现(AP模式)

2023-02-28 23:39:35   3  举报





Nacos

SpringCloudAlibaba

SpringBoot

Springcloud

作者其他创作

大纲/内容

keys.add(key)

bind(event)

ClientBeatCheckTask

如果某个实例超过15秒秒没有收到心跳则将它健康属性设置false

retrySync(syncTask)

putServiceAndInit(service)

DistroConsistencyServiceImpl.init()

ephemeralInstances = toUpdateInstances

/raft/datum/commit

调用Server实例注销接口（HttpMethod.DELETE）

异步任务更新内存注册表

createEmptyService

服务注册

AbstractAutoServiceRegistration

1、将注册实例更新到内存注册表

ephemeralConsistencyService

如果同步不成功重试

instance.setLastBeat(System.currentTimeMillis())

getRegistration()就是NacosRegistration

循环从阻塞队列tasks里拿实例数据处理

@bean

taskScheduler.run()

将注册实例信息更新到注册表内存结构里去

同步实例信息给集群其它节点

如果缓存为空，调用Server接口，获取最新服务数据

将新注册实例加到对应服务service实例列表里去

serviceManager.removeInstance

consistencyDelegate.put()

/distro/datum

返回的就是注册时写入实例属性

mapConsistencyService(key)

将service对应的全量实例instance写入内存注册表

service.srvIPs

同步写实例数据文件

serviceRegistry就是NacosServiceRegistry实例

getServiceInfo0

/instance

从nacos官方文档上找到客户端服务发现的代码，这里先看下底层逻辑，实际上，服务发现是在第一调用服务接口时根据服务名去服务端获取的，这个参考ribbon源码

NacosServiceRegistry

调用server的实实例同步接口（HttpMethod.PUT）

服务发现

实现

否

serviceManager.registerInstance

persistentConsistencyService

往阻塞队列queue里面放入注册实例数据

raftProxy.proxyPostLarge(将注册请求转发到集群的leader节点)

HttpClient.asyncHttpPostLarge

ApplicationListener

deleteIP(instance)

executor.submit(notifier)

consistencyService.onPut

阿里自己实现AP模式Distro协议

queue.offer(key)

taskDispatcher.addTask(key)

GlobalExecutor.submitTaskDispatch(taskScheduler)

putService(service)

NacosDiscoveryAutoConfiguration

如果实例不存在重新注册(如网络不通导致实例在服务端被下线或服务端重启临时实例丢失)

如果注册的实例达到一定数量就批量同步给nacos集群的其它节点，或者距离上一次节点同步达到一定时间也会开始批量同步

beatReactor.addBeatInfo

tasks.take()

源码精髓：nacos这个更新注册表内存方法里，为了防止读写并发冲突，大量的运用了CopyOnWrite思想防止并发读写冲突，具体做法就是把原内存结构复制一份，操作完最后再替换回真正的注册表内存里去。Eureka防止读写并发冲突用的方法是注册表的多级缓存结构，只读缓存，读写缓存，内存注册表，各级缓存之间定时同步，客户端感知的及时性不如nacos

serviceInfoMap（客户端实例缓存Map）

源码入口

如果是临时节点实例数据

调用Server的实例发送注册接口HttpMethod.PUT

创建内存注册表结构

if (dataSize == partitionConfig.getBatchSyncKeyCount() || (System.currentTimeMillis() - lastDispatchTime) > partitionConfig.getTaskDispatchPeriod()) {

client

instance.setHealthy(false)

InstanceController.register

发布服务变更事件

raftStore.write(datum)

queue.poll()

BeatTask

/instance/beat

NacosRegistration

if (instance.isEphemeral({添加一个延迟执行的定时心跳任务BeatTask}}

往阻塞队列task里放入注册表实例数据

2、同步实例信息到nacos server集群其它节点