NacosConfigService大致的结构

NacosConfigManager

上篇说了，BootstrapApplicationListener监听方法里会进行NacosConfigBootstrapConfiguration的注册，然后里面有个比较重要的注入对象NacosConfigManager。我们来看看他的构造方法做了什么。

createConfigService创建配置服务

因为是第一次，所以会创建，这里你会发现他给NacosConfigManager类对象上锁了，防止多线程多次创建NacosConfigManager而重复创建配置服务，不多啰嗦继续。

NacosConfigProperties的assembleConfigServiceProperties一些初始化配置

NacosFactory的createConfigService

其实就是反射出NacosConfigService，然后获取有参构造方法，反射创建实例。

        public static ConfigService createConfigService(Properties properties) throws NacosException {
            return ConfigFactory.createConfigService(properties);
        }
    
        public static ConfigService createConfigService(Properties properties) throws NacosException {
            try {
                Class<?> driverImplClass = Class.forName("com.alibaba.nacos.client.config.NacosConfigService");
                Constructor constructor = driverImplClass.getConstructor(Properties.class);
                ConfigService vendorImpl = (ConfigService) constructor.newInstance(properties);
                return vendorImpl;
            } catch (Throwable e) {
                throw new NacosException(NacosException.CLIENT_INVALID_PARAM, e);
            }
        }

NacosConfigService构造方法

里面有几个组件，ServerHttpAgent做http请求的代理，MetricsHttpAgent包装了ServerHttpAgent，加了计时的功能，ClientWorker做配置文件检查。

        public NacosConfigService(Properties properties) throws NacosException {
            String encodeTmp = properties.getProperty(PropertyKeyConst.ENCODE);
            if (StringUtils.isBlank(encodeTmp)) {
                encode = Constants.ENCODE;//默认设置utf-8
            } else {
                encode = encodeTmp.trim();
            }
            initNamespace(properties);
            agent = new MetricsHttpAgent(new ServerHttpAgent(properties));
            agent.start();
            worker = new ClientWorker(agent, configFilterChainManager, properties);
        }

ServerHttpAgent

ServerListManager用来管理注册中心集群列表，SecurityProxy用来安全验证的，默认没有用户名就没启用，登录验证直接返回true。另外这里会启一个调度任务，每5秒执行登录验证，但是内部还有个令牌时间判断的，超时了才会去验证。

        public ServerHttpAgent(Properties properties) throws NacosException {
            serverListMgr = new ServerListManager(properties);
            securityProxy = new SecurityProxy(properties);
            namespaceId = properties.getProperty(PropertyKeyConst.NAMESPACE);
            init(properties);//设置编码，密码，最大重试次数
            securityProxy.login(serverListMgr.getServerUrls());//代理登录
            //单线程调度执行器
            ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1, new ThreadFactory() {
                @Override
                public Thread newThread(Runnable r) {
                    Thread t = new Thread(r);
                    t.setName("com.alibaba.nacos.client.config.security.updater");
                    t.setDaemon(true);
                    return t;
                }
            });
            //无延迟开始调度,每5秒一次
            executorService.scheduleWithFixedDelay(new Runnable() {
                @Override
                public void run() {
                    securityProxy.login(serverListMgr.getServerUrls());
                }
            }, 0, securityInfoRefreshIntervalMills, TimeUnit.MILLISECONDS);
        }

包装的MetricsHttpAgent：

ClientWorker

http代理就是MetricsHttpAgent对象，有个过滤器管理器ConfigFilterChainManager，默认里面没有过滤器，可以addFilter自己加。这里也开启了一个单线程的执行器，执行checkConfigInfo检查配置任务，每10毫秒一次，去检查当前的配置数量，如果超过一个轮询任务的限制数量，默认3000个，就开启一个新的任务去做。

        public ClientWorker(final HttpAgent agent, final ConfigFilterChainManager configFilterChainManager, final Properties properties) {
            this.agent = agent;
            this.configFilterChainManager = configFilterChainManager;
    
         
            init(properties);
    		
            executor = Executors.newScheduledThreadPool(1, new ThreadFactory() {
                @Override
                public Thread newThread(Runnable r) {
                    Thread t = new Thread(r);
                    t.setName("com.alibaba.nacos.client.Worker." + agent.getName());
                    t.setDaemon(true);
                    return t;
                }
            });
    		//有cpu核数的线程，用来做长轮询的，每次检查配置，如果LongPollingRunnable任务的配置缓存超过一定数量，默认3000个，就要去开启一个新任务去检查配置
            executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
                @Override
                public Thread newThread(Runnable r) {
                    Thread t = new Thread(r);
                    t.setName("com.alibaba.nacos.client.Worker.longPolling." + agent.getName());
                    t.setDaemon(true);
                    return t;
                }
            });
    		//配置检查
            executor.scheduleWithFixedDelay(new Runnable() {
                @Override
                public void run() {
                    try {
                        checkConfigInfo();
                    } catch (Throwable e) {
                        LOGGER.error("[" + agent.getName() + "] [sub-check] rotate check error", e);
                    }
                }
            }, 1L, 10L, TimeUnit.MILLISECONDS);
        }

先介绍下这个，其他的后面说。

好了，今天就到这里了，希望对学习理解有帮助，大神看见勿喷，仅为自己的学习理解，能力有限，请多包涵。

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】即可免费领取。

阅读全文

Spring Cloud 2.2.2 源码之旅

Spring Cloud 2.2.2 源码之二十六nacos客户端获取配置原理一