SpringCloud中的nacos配置中心分析

一、概述
nacos可以作为配置管理使用，为各个微服务之间提供统一的配置中心，方便管理所有服务的配置。

二、什么是配置中心？

配置中心：一般SpringBoot项目都使用在resources下创建类似application.yml之类的配置文件来管理整个项目的一些配置信息。

当微服务部署的实例越来越多时，这时候逐个修改配置效率非常低，也容易出错，那么提供统一的配置中心就可以集中管理各个服务配置了。

三、nacos配置中心原理解析
1.配置中心核心接口ConfigService获取配置
在这里插入图片描述
获取配置的主要方法是 NacosConfigService 类的 getConfig 方法，通常情况下该方法直接从本地文件中取得配置的值，如果本地文件不存在或者内容为空，则再通过 HTTP GET 方法从远端拉取配置，并保存到本地快照中。当通过 HTTP 获取远端配置时，Nacos 提供了两种熔断策略，一是超时时间，二是最大重试次数，默认重试三次。

2.nacos客户端获取服务配置

public String getConfig(String dataId, String group, long timeoutMs) throws NacosException {
        return this.getConfigInner(this.namespace, dataId, group, timeoutMs);
    }

具体实现

private String getConfigInner(String tenant, String dataId, String group, long timeoutMs) throws NacosException {
        group = this.blank2defaultGroup(group);
        ParamUtils.checkKeyParam(dataId, group);
        ConfigResponse cr = new ConfigResponse();
        cr.setDataId(dataId);
        cr.setTenant(tenant);
        cr.setGroup(group);
        String content = LocalConfigInfoProcessor.getFailover(this.worker.getAgentName(), dataId, group, tenant);
        String encryptedDataKey;
        if (content != null) {
            LOGGER.warn("[{}] [get-config] get failover ok, dataId={}, group={}, tenant={}, config={}", new Object[]{this.worker.getAgentName(), dataId, group, tenant, ContentUtils.truncateContent(content)});
            cr.setContent(content);
            encryptedDataKey = LocalEncryptedDataKeyProcessor.getEncryptDataKeyFailover(this.agent.getName(), dataId, group, tenant);
            cr.setEncryptedDataKey(encryptedDataKey);
            this.configFilterChainManager.doFilter

以下是读取本地配置具体实现。

public static String getFailover(String serverName, String dataId, String group, String tenant) {
        File localPath = getFailoverFile(serverName, dataId, group, tenant);
        if (localPath.exists() && localPath.isFile()) {
            try {
                return readFile(localPath);
            } catch (IOException var6) {
                LOGGER.error("[" + serverName + "] get failover error, " + localPath, var6);
                return null;
            }
        } else {
            return null;
        }
    }

当本地文件为空时，则需要去向这个服务端的配置中心发起http请求，最后会通过这个接口回调来判断这个响应的状态码。
基本实现调getServerConfig方法。

 public ConfigResponse getServerConfig(String dataId, String group, String tenant, long readTimeout, boolean notify) throws NacosException {
        if (StringUtils.isBlank(group)) {
            group = "DEFAULT_GROUP";
        }

        return this.agent.queryConfig(dataId, group, tenant, readTimeout, notify);
    }

内部调queryConfig方法获取远端配置，这里就不具体细说了。

3.nacos的服务配置监听
在整个容器启动完成后，就会去调用这个监听器，nacos在NacosContextRefresher类下实现监听。其实现了这个ApplicationListener这个接口，就是一个nacos的一个上下文的一个刷新流。

public NacosContextRefresher(NacosConfigManager nacosConfigManager, NacosRefreshHistory refreshHistory) {
        this.nacosConfigProperties = nacosConfigManager.getNacosConfigProperties();
        this.nacosRefreshHistory = refreshHistory;
        this.configService = nacosConfigManager.getConfigService();
        this.isRefreshEnabled = this.nacosConfigProperties.isRefreshEnabled();
    }

    public void onApplicationEvent(ApplicationReadyEvent event) {
        if (this.ready.compareAndSet(false, true)) {
            this.registerNacosListenersForApplications();
        }

    }

这个类里面，会调用一个onApplicationEvent的事件方法，里面就会去进行nacos的监听的一个注册。

private void registerNacosListenersForApplications() {
        if (this.isRefreshEnabled()) {
            Iterator var1 = NacosPropertySourceRepository.getAll().iterator();

            while(var1.hasNext()) {
                NacosPropertySource propertySource = (NacosPropertySource)var1.next();
                if (propertySource.isRefreshable()) {
                    String dataId = propertySource.getDataId();
                    this.registerNacosListener(propertySource.getGroup(), dataId);
                }
            }
        }

    }

这个方法会去获取nacos的全部的配置文件，然后在获取dataId 之后，通过这个dataId对这个服务进行一个监听。

其中registerNacosListener 方法的具体实现如下，当配置发生变化的时候，这个监听方法就会发起一个调用。

private void registerNacosListener(final String groupKey, final String dataKey) {
        String key = NacosPropertySourceRepository.getMapKey(dataKey, groupKey);
        Listener listener = (Listener)this.listenerMap.computeIfAbsent(key, (lst) -> {
            return new AbstractSharedListener() {
                public void innerReceive(String dataId, String group, String configInfo) {
                    NacosContextRefresher.refreshCountIncrement();
                    NacosContextRefresher.this.nacosRefreshHistory.addRefreshRecord(dataId, group, configInfo);
                    NacosContextRefresher.this.applicationContext.publishEvent(new RefreshEvent(this, (Object)null, "Refresh Nacos config"));
                    if (NacosContextRefresher.log.isDebugEnabled()) {
                        NacosContextRefresher.log.debug(String.format("Refresh Nacos config group=%s,dataId=%s,configInfo=%s", group, dataId, configInfo));
                    }

                }
            };
        });

        try {
            this.configService.addListener(dataKey, groupKey, listener);
            log.info("[Nacos Config] Listening config: dataId={}, group={}", dataKey, groupKey);
        } catch (NacosException var6) {
            log.warn(String.format("register fail for nacos listener ,dataId=[%s],group=[%s]", dataKey, groupKey), var6);
        }

    }

最后会去调用一个refresh方法，会进行一个环境的刷新，将新的参数和原来的参数进行一个比较，通过发布这个环境变更事件，对做出改变的值进行一个更新操作。

总结：
就是这个客户端进行启动的时候，就会优先拉取本地的配置，如果本地配置不存在，那么就会和这个服务端建立这个http请求，然后去拉取这个服务端的全部配置，就是配置中心的全部配置。在拉取到全部配置之后，会去获取每一个配置文件的dataId，然后通过这个id对服务端的每一个配置文件进行一个监听的操作。当服务端这边的配置文件出现修改的时候，就可以通过这个监听器进行感知，然后这个客户端也会对对应的配置文件进行修改，每一份修改的配置都会存储在这个nacos配置文件里面，会作为一个历史文件保留。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/551468.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

微信生态洗牌，私域拥抱公域的逐步试探

微信生态洗牌，私域拥抱公域的逐步试探

一直被人们奉为“私域神器”的微信，如今，变化越来越大了，微信的几次更新，透露出很多不一样的信息，在微信的很多使用场景中，都逐渐在向平台化公域流量分发的方向发展，不断的尝试从私域走向公域&a…
阅读更多...
2024年【起重机械指挥】考试题及起重机械指挥复审模拟考试

2024年【起重机械指挥】考试题及起重机械指挥复审模拟考试

题库来源：安全生产模拟考试一点通公众号小程序 起重机械指挥考试题是安全生产模拟考试一点通总题库中生成的一套起重机械指挥复审模拟考试，安全生产模拟考试一点通上起重机械指挥作业手机同步练习。2024年【起重机械指挥】考试题及起重机械指挥复审模拟…
阅读更多...
社科院与新加坡社科大学工商管理博士——在职读博行而不辍，未来可期

社科院与新加坡社科大学工商管理博士——在职读博行而不辍，未来可期

在职读博，对于许多人来说，既是一种挑战，也是一种机遇。它要求我们在繁忙的工作之余，还要抽出时间来深入研究学术，不断提升自己的专业素养。然而，正是这种行而不辍的精神，让我们能够在职业生涯中…
阅读更多...
C++类和对象：构造函数，析构函数，拷贝构造

C++类和对象：构造函数，析构函数，拷贝构造

文章目录 1.类的6个默认成员函数2. 构造函数2.1 概念2.2 特性 3.析构函数3.1 概念3.2 特性 4.拷贝构造 1.类的6个默认成员函数 一个类中什么都不写，就是空类。而空类实际上有成员，当一个类中什么都不写时，编译器会生成六个对应默认成员函数。…
阅读更多...
解读我国最新网络安全运维与数据处理安全规范：强化数字化时代安全基石

解读我国最新网络安全运维与数据处理安全规范：强化数字化时代安全基石

近日，全国网络安全标准化技术委员会秘书处公布了一系列重要的网络安全与数据安全相关技术规范草案，包括《网络安全技术 网络安全运维实施指南》、《网络安全技术 信息系统灾难恢复规范》以及《数据安全技术 政务数据处理安全要求》。这些规范旨在应对当前…
阅读更多...
JavaScript权威指南(第7版) 笔记 - 第 7 章 数组

JavaScript权威指南(第7版) 笔记 - 第 7 章 数组

能用代码说清楚的，绝不多废话！！！！！！ Linux创始人Linus的名言：Talk is cheap，show me the code ! ，博主技术博文会精心给出能说明问题的范例代码！…
阅读更多...
安装 k8s集群的问题：默认容器运行时从 Docker 改为 Containerd

安装 k8s集群的问题：默认容器运行时从 Docker 改为 Containerd

安装 k8s集群的问题：默认容器运行时从 Docker 改为 Containerd 1、背景2、容器运行时从 Docker 改为 Containerd2.1、安装 Containerd：2.2、生成 Containerd 的配置文件2.3 、创建 /etc/crictl.yaml 文件2.4 、配置 Containerd 服务开机自启 &#x1f49…
阅读更多...
算法与数据结构要点速学——排序算法

算法与数据结构要点速学——排序算法

排序算法 所有主要的编程语言都有一个内置的排序方法。假设并说排序成本为 O(n*log n)，通常是正确的，其中 n 是要排序的元素数。为了完整起见，这里有一个图表，列出了许多常见的排序算法及其完整性。编程语言实现的算法各不相同&a…
阅读更多...
【GDB调试技巧】提高gdb的调试效率

【GDB调试技巧】提高gdb的调试效率

目录 🌞gdb的启动 🌞gdb技巧 🌼1. gdb小技巧汇总 🌼2. 打印输出指定地址的值 🌼3. 查看当前执行到哪行代码代码内容 3.1 方式一：info line 结合 list 。 3.2 方式二：f 3.3 方式三&#…
阅读更多...
WebGIS面试题（第五期）

WebGIS面试题（第五期）

WebGIS面试题（第五期） 以下题目仅为部分题目，全部题目在公众号{GISer世界}，答案仅供参考 1、Cesium的核心组件有哪些？ Cesium的核心组件包括Viewer、Scene、Model、Geometry、Material和Camera等。其中，…
阅读更多...
Latex（从入门到入土）1

Latex（从入门到入土）1

第一章：初识Latex 1、安装Latex，当然可以安装官方的开放版本，也可以去找找别人发的资源。我这里只介绍我的学习经过。如果想下载最新的软件资源，我这里推荐微信公众号：软件智库，通过号主提供的网址是可以下…
阅读更多...
基于大数据的全国热门景点数据可视化分析系统

基于大数据的全国热门景点数据可视化分析系统

温馨提示：文末有 CSDN 平台官方提供的学长 QQ 名片 :) 1. 项目简介 本文将介绍如何使用Python中的Pandas库进行数据挖掘，并结合Flask Web框架实现一个旅游景点数据分析系统。该系统将包括以下功能模块：热门景点概况、景点星级与评分分析、景…
阅读更多...
Docker 学习笔记（十）：Centos7 中 Docker 部署 Redis 集群，打包 SpringBoot 微服务

Docker 学习笔记（十）：Centos7 中 Docker 部署 Redis 集群，打包 SpringBoot 微服务

一、前言 记录时间 [2024-4-17] 系列文章简摘： Docker 学习笔记（六）：挑战容器数据卷技术一文通，实战多个 MySQL 数据同步，能懂会用，初学必备 Docker 学习笔记（七）&#x…
阅读更多...
基于Copula函数的风光功率联合场景生成_任意修改生成的场景数目(附带Matlab代码)

基于Copula函数的风光功率联合场景生成_任意修改生成的场景数目(附带Matlab代码)

基于Copula函数的风光功率联合场景生成 削减为6个场景 部分展示削减为5个场景 部分展示 风光等可再生能源出力的不确定性和相关性给系统的设计带来了极大的复杂性，若忽略这些因素，势必会在系统规划阶段引入次优决策风险。因此，在确定系统最佳…
阅读更多...
Linux sort/uniq/wc

Linux sort/uniq/wc

文章目录 1. sort 排序将线程ID从大到小排序 2.uniq 临近去重3.wc word cnt 统计 1. sort 排序 将线程ID从大到小排序 grep -v是反向筛选，利用USER，排除掉首行 awk是打印第1 2列 sort -n是代码以数值大小做排序，不加的话会以字符排序。 -k是…
阅读更多...
Go 单元测试之HTTP请求与API测试

Go 单元测试之HTTP请求与API测试

文章目录 一、httptest1.1 前置代码准备1.2 介绍1.3 基本用法 二、gock2.1介绍2.2 安装2.3 基本使用2.4 举个例子2.4.1 前置代码2.4.2 测试用例 一、httptest 1.1 前置代码准备 假设我们的业务逻辑是搭建一个http server端，对外提供HTTP服务。用来处理用户登录请求…
阅读更多...
腾讯实验室推出类似 Sora 的长视频生成Mira；阿里巴巴推出强大的代码生成模型CodeQwen1.5

腾讯实验室推出类似 Sora 的长视频生成Mira；阿里巴巴推出强大的代码生成模型CodeQwen1.5

✨ 1: Mira 腾讯PCG ARC实验室推出Mira：类似 Sora 的长视频生成 Mira（Mini-Sora），是一个尝试生成高质量、长时视频的初步探索项目，以Sora风格进行长视频生成。与现有的文本到视频（Text-to-Video, T2V&a…
阅读更多...
2024年【高处安装、维护、拆除】试题及解析及高处安装、维护、拆除模拟试题

2024年【高处安装、维护、拆除】试题及解析及高处安装、维护、拆除模拟试题

题库来源：安全生产模拟考试一点通公众号小程序 2024年【高处安装、维护、拆除】试题及解析及高处安装、维护、拆除模拟试题，包含高处安装、维护、拆除试题及解析答案和解析及高处安装、维护、拆除模拟试题练习。安全生产模拟考试一点通结合国家高处安装…
阅读更多...
基于SSM+Jsp+Mysql的贝儿米幼儿教育管理系统

基于SSM+Jsp+Mysql的贝儿米幼儿教育管理系统

开发语言：Java框架：ssm技术：JSPJDK版本：JDK1.8服务器：tomcat7数据库：mysql 5.7（一定要5.7版本）数据库工具：Navicat11开发软件：eclipse/myeclipse/ideaMaven包…
阅读更多...
如何简单下载指定版本的jdk

如何简单下载指定版本的jdk

Oracle 官方提供的 Java Development Kit (JDK) 的归档站点。它主要用于存放历史版本的 JDK，供开发者下载和使用。 附上站点地址：Archived OpenJDK GA Releases 在这个站点可以找到各版本的jdk，简单实用~ 找到版本，点击tar.gz进…
阅读更多...
最新文章

Copyright @ 2022~2023