nacos注册源码

 2020-11-15 18:15:38







nacos注册源码

nacos

举报

猜你喜欢

大纲/内容

queue.offer(key)

taskDispatcher.addTask(key)

NacosDiscoveryAutoConfiguration

taskScheduler.run()

WebServerInitializedEvent

利用CountDownLatch实现了一个简单的raft协议写入数数据的逻辑，必须集群半数以上节点写入成功才会给客户端返回成功

阿里自己实现的CP模式的简单Raft协议

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

TaskDispatcher.init()

GlobalExecutor.submitTaskDispatch(taskScheduler)

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

/raft/datum/commit

@Bean

/distro/datum

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

NacosRegistration

start

GlobalExecutor.submitDistroNotifyTask(notifier)

AbstractAutoServiceRegistration

创建内存注册表结构

继承

同步写实例数据到文件

addInstance

notifier.run()

InstanceController.register

beatReactor.addBeatInfo

将临时的注册实例更新到了cluster的ephemeralInstances属性上去，服务发现查找临时实例最终从内存里找到的就是这个属性

GlobalExecutor.submitDataSync

双层map结构

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

putServiceAndInit(service)

serverProxy.registerService

consistencyService.put()

ephemeralInstances = toUpdateInstances

putService(service)

persistentConsistencyService

DistropConsistencyServieImpl.init()

serviceRegistry.register(this.getRegistration())

如果是临时化实例

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

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

DelegateConsistencyServiceImpl.put

执行实例数据批量同步任务

源码精髓:很多开源框架为了提升操作性能，会大量使用这种异步任务及内存队列操作，这些操作本身并不需要写入之后立即成功，用这种方式对提升操作性能有很大帮助

本节点是否leader

如果是持久化实例

NacosAutoServiceRegistration

mapConsistencyService(key)

sprint-cloud-starter-alibaba-nacos-discovery.jar里面的sprint.factories的NacosDiscoveryAutoConfiguration

源码精髓：集群数据同步的一种方案，异步批量同步

raftStore.write(datum)

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