解读nacos获取配置文件的大致过程
作者:jsenht
这篇文章主要介绍了nacos获取配置文件的大致过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
一、spring 体系相关类
(主要借助spring的api,自动注入配置信息)
com.alibaba.nacos.spring.core.env.AbstractNacosPropertySourceBuilder com.alibaba.nacos.spring.core.env.NacosPropertySourcePostProcessor com.alibaba.nacos.spring.util.config.NacosConfigLoader
主要是将ConfigService(实现类NacosConfigService)
获取的配置信息添加到environment.getPropertySources()
二、配置
1、获取配置文件
获取配置文件由ConfigService的getConfig接口提供,
实现类的核心流程就是根据配置的nacos地址使用,当然会有一些优先级之类的处理
网络请求由com.alibaba.nacos.client.config.impl.ClientWorker的getServerConfig处理
(getServerConfig->HttpAgent(MetricsHttpAgent)->HttpAgent(ServerHttpAgent)->HttpSimpleClient->HttpURLConnection);
2、监听配置更新
拉取数据其实是在NacosConfigService创建的时候就开始的
NacosConfigService创建的时候
Nacos创建ClientWorker成员变量
worker = new ClientWorker(agent, configFilterChainManager);
然后在worker的构造函数启动time task:
executor.scheduleWithFixedDelay(new Runnable() { public void run() { try { checkConfigInfo(); } catch (Throwable e) { log.error(agent.getName(), "NACOS-XXXX", "[sub-check] rotate check error", e); } } }, 1L, 10L, TimeUnit.MILLISECONDS); executorService.execute(new LongPollingRunnable(i)); List<String> changedGroupKeys = checkUpdateDataIds(cacheDatas, inInitializingCacheList); checkUpdateConfigStr(sb.toString(), isInitializingCacheList)
checkUpdateConfigStr最终会调用http请求,http请求将本地配置文件的md5计算后传给nacos服务器,服务器根据MD5
计算返回变动了的配置文件的列表,client在根据这个结果拉取配置文件,
nacos的配置监听使用异步 Servlet 技术,默认在配置相同的情况下,会等待30秒,不然会立刻获取配置信息
com.alibaba.nacos.config.server.controller.ConfigServletInner
nacos在这里处理异步返回的结果
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。