首页  流程图  详情

Alibaba Nacos服务配置中心

2022-01-27 11:42:09   5  举报





Alibaba Nacos服务配置中心源码图

架构设计图

nacos配置中心

Nacos集群架构简图

作者其他创作

大纲/内容

this.context.publishEvent(new RefreshScopeRefreshedEvent())

PropertySourceLocator#locateCollection

ConfigFactory.createConfigService(properties)

根据变化的dataid调用nacos server端获取最新配置，并更新本地快照

refreshEnvironment()

长轮询

轮询接口，长连接处理

排出除了SYSTEM.JNDI.SERVLET系统环境变量之外的所有变量

LocalConfigInfoProcessor.getFailover

更新配置，Spring Cloud的配置

loadNacosPropertySource

NacosContextRefresher

准备上下文

executorService.execute(new LongPollingRunnable(i))

readFile(localPath)

用户通过nacos-console后台管理页面修改了配置，点击了发布

run

allSubs.add(this)

NacosConfigProperties

loadApplicationConfiguration

ContextRefresher

响应配置发生变化的key

运行监听器

调用NacosConfig的构造器

implements

全量dump配置信息

NacosConfigService

allSubs.remove(ClientLongPolling.this)

优先使用本地配置

MetricsHttpAgent#httpGet

ConfigController#getConfig

NacosConfigAutoConfiguration

客户端工作类

nacosConfigManager.getConfigService()

addListener

LegacyContextRefresher#updateEnvironment()

ContextRefresher#refresh()

NotifyCenter.publishEvent(event)

handle((RefreshEvent) event)

如果未获取到配置信息则远程调用配置中心获取配置信息

NacosConfigManager

/nacos/v1/cs/configs

PropertiesPropertySourceLoader#load

将数据库中所有ConfigInfo查询出来写到服务器的磁盘中

ConfigServletInner#doGetConfig

persistService.findConfigMaxId()

加载顺序：1.${spring.application.name}(微服务名称)2.${spring.application.name}.文件扩展名3.${spring.application.name}.${profile}.文件扩展名优先级：3>2>1

加载nacos配置中心的配置信息

保存结果到本地文件

检查变更配置

NacosRefreshProperties

context.publishEvent(new ApplicationReadyEvent)

NacosConfigBootstrapConfiguration

Spring Boot应用启动

spring-cloud-context:3.0.4.jar!/META-INF/spring.factories

spring-cloud-alibaba-nacos-config:2.2.5.RELEASE.jar!/META-INF/spring.factories

两个线程池：1.只有一个线程的线程池，用来执行定时任务，每隔10ms执行一次checkConfigInfo()2.线程数等处理器个数的线程池，用来执行ClientWorker.LongPollingRunnable#run

YamlPropertySourceLoader#load

Header参数：Long-Pulling-Timeout：

ApplicationListener

从mysql数据库查询分页配置信息

ConfigCacheService.dump

准备环境信息

NacosPropertySourceLocator#locate

客户端

实际会调用

源码入口

发布RefreshEvent事件，监听器是RefreshEventListener

NacosRestTemplate#get

同步其它集群节点更新配置

AbstractSharedListener#innerReceive

当前MD5不致的，生成响应信息直接返回

prepareEnvironment

ConfigController#listener

配置中心配置类，对应bootstrap.properties中的配置信息

获取新的参数值，并和之前的参数进行比较找出改变的参数值

@PostConstruct

NacosRestTemplate#postForm

ConfigService

查询mysql，获取最大的主键量

dumpAllProcessor.process(new DumpAllTask())

PropertySourceLoader#load

触发ConfigDataChangeEvent事件

loadNacosData

发起远程调用其它集群节点

注册监听器

监听ApplicationReadyEvent事件，并注册一个nacoslistener用来监听nacos config配置修改后发布一个spring refreshEvent用来刷新配置和应用

MetricsHttpAgent#httpPost

获取配置中心服务ConfigService

正常插入

NotifyCenter.registerSubscriber

发布环境改变事件，参数值为改变的key

NacosConfigService(Properties properties)

处理ApplicationReadyEvent事件

checkConfigInfo()

longPollingService.addLongPollingClient

如果存在配置文件，读取配置文件信息

/nacos/v1/cs/configs/listener

listeners.running(context)

刷新容器

ConfigServletInner#doPollingConfig

ClientWorker.LongPollingRunnable

从队列中移除当前任务

是否刷新配置，默认true

向nacos server发送一个长连接（30s超时时间）返回nacos server有更新过的dataIds

发布应用准备事件 ApplicationReadyEvent

异常更新

ClientLongPolling clientSub = iter.next()

持久化到mysql

MetricsHttpAgent

addConfigFilesToEnvironment()

获取配置并且注册监听器

用来存储标记了@RefreshScope的注解的类的容器

Runnable#run()

PropertySourceLocator

Spring Boot提供的加载配置文件的接口

在Spring cloud context包中实现，通过SPI机制加载：SpringApplication在初始化的时候通过SpringFactoriesLoader加载ApplicationContextInitializer类型的实现类到initializers中

executeAsyncInvoke()

ApplicationContextInitializer#initialize

EventPublishingRunListener#running

用来向nacos server发起请求的代理

发起远程调用

发布配置

比较客户端的md5和server端的是否一致，不一致放到changeGroups里

applicationContext.publishEvent(new RefreshEvent())

subscriber.onEvent(event)

加载共享配置，对应spring.cloud.nacos.config.shared-configs

NacosRefreshHistory

注意：不是去查mysql，而是去查本地磁盘的缓存，所以直接修改mysql配置是不行的，修改配置需要发布ConfigDataChangeEvent事件，触发本地文件和内存的更新

dumpConfigInfo(dumpAllProcessor)

nacosPropertySourceBuilder.build

updateConfigInfo

ConfigExecutor.scheduleLongPolling

NacosConfigService#getConfigInner

registerNacosListenersForApplications()

ConfigFileApplicationListener.Loader#load()

将配置保存到磁盘文件中

写入到服务器磁盘

检查本地配置（ check failover config）

无论配置有没有更新，最终都会响应，

clientSub.sendResponse(Arrays.asList(groupKey))

isRefreshEnabled()

DumpService#dumpOperate

ExternalStoragePersistServiceImpl.insertOrUpdate

用来触发刷新过程的对象

loadExtConfiguration(composite)

服务端push模式

删除配置

DumpService

ClientWorker

NacosPropertySourceLocator

从队列取任务执行

ConfigController#publishConfig

LocalConfigInfoProcessor.saveSnapshot

MD5Util.compareMd5

Naocs配置中心服务

删除监听器

AsyncNotifyService#run()

RefreshEventListener

为每个dataId注册监听器

延迟29.5s执行

LongPollingService#DataChangeTask#run()

ConfigExecutor.executeLongPolling

ConfigChangePublisher.notifyConfigChange(new ConfigDataChangeEvent())

RefreshScope

cacheMap中缓存着需要刷新的配置，将cacheMap中的数量以3000分一个组，分别创建一个LongPollingRunnable用来监听配置更新

DefaultPublisher#notifySubscriber

写入磁盘

cacheData.checkListenerMd5()

支持长轮询

响应到客户端

不支持长轮询

服务端

用于分页，每次取1000条配置刷进磁盘和内存

获取到配置文件

persistService.findAllConfigInfoFragment

refreshContext

LongPollingService#LongPollingService#onEvvent

extract(this.context.getEnvironment().getPropertySources())

removeConfig

缓存配置信息的MD5到内存中，并发布LocalDataChangeEventg事件

ExternalDumpService

处理RefreshEvent事件

SmartApplicationListener

persistService.insertOrUpdate

SpringApplicationBuilder.run()

SELECT max(id) FROM config_info

ClientLongPolling被提交给scheduler执行，可以拆分成4个步骤:1.创建—个调度的任务，调度的延时时间为29.5s⒉.将该ClientLongPolling自身的实例添加到一个allSubs中去3.延时时间到了之后，首先将该ClientLongPolling自身的实例从 allSubs 中移除4.获取服务端中保存的对应客户端请求的 groupKeys，检查是否发生变更，将结果写入response返回给客户端

sendResponse(changedGroups)

LongPollingService.ClientLongPolling#run()

Subscriber#onEvent

this.scope.refreshAll()

restTemplate.get

Nacos在启动时将所有配置文件信息Dump到磁盘上

handle((ApplicationReadyEvent) event)

listener.receiveConfigInfo(contentTmp)

SpringApplication.run()

PropertySourceBootstrapConfiguration#initialize

每隔10ms执行一次定时任务

java.lang.Runnable#run()