Nacos动态配置原理分析_nacos动态配置原理,nacos配置中心动态刷新原理

java

需积分: 50 3.6k 浏览量更新于2023-05-25 评论收藏 2.01MB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

Nacos动态配置原理分析

一、流程分析

1、入口：NacosConfigAutoConfiguration

首先看一下spring-cloud-starter-alibaba-nacos-discovery项目的结构

看spring.factories中内容，优先加载装配的配置

NacosConfigAutoConfiguration 自动装配配置，进行Bean的初始化

org.springframework.cloud.bootstrap.BootstrapConfiguration=\

org.springframework.cloud.alibaba.nacos.NacosConfigBootstrapConfiguration

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\

org.springframework.cloud.alibaba.nacos.NacosConfigAutoConfiguration,\

org.springframework.cloud.alibaba.nacos.endpoint.NacosConfigEndpointAutoConfigur

ation

org.springframework.boot.diagnostics.FailureAnalyzer=\

org.springframework.cloud.alibaba.nacos.diagnostics.analyzer.NacosConnectionFail

ureAnalyzer

3、@RefreshScope配置热更新实现原理

RefreshScope：自定义Bean的工作区域，spring默认有单例、原型，还支持扩展Bean Scope,

RefreshScope其中一种

RefreshScope作用：可在Bean运行期间动态刷新

properties.load(new StringReader(data));

return properties;

}

else if (fileExtension.equalsIgnoreCase("yaml")

|| fileExtension.equalsIgnoreCase("yml")) {

YamlPropertiesFactoryBean yamlFactory = new

YamlPropertiesFactoryBean();

yamlFactory.setResources(new

ByteArrayResource(data.getBytes()));

return yamlFactory.getObject();

}

catch (NacosException e) {

log.error("get data from Nacos error,dataId:{}, ", dataId, e);

}

catch (Exception e) {

log.error("parse data from Nacos error,dataId:{},data:{},", dataId,

data, e);

}

return EMPTY_PROPERTIES;

}

private void registerNacosListener(final String group, final String dataId) {

// 默认匿名监听器

 Listener listener = listenerMap.computeIfAbsent(dataId, i -> new Listener()

{

   @Override

   public void receiveConfigInfo(String configInfo) {

     refreshCountIncrement();

     String md5 = "";

     if (!StringUtils.isEmpty(configInfo)) {

       try {

         MessageDigest md = MessageDigest.getInstance("MD5");

         md5 = new BigInteger(1, md.digest(configInfo.getBytes("UTF-

8")))

           .toString(16);

       }

       catch (NoSuchAlgorithmException | UnsupportedEncodingException

e) {

         log.warn("[Nacos] unable to get md5 for dataId: " + dataId,

e);

       }

     }

     refreshHistory.add(dataId, md5);

     //发布刷新事件

     applicationContext.publishEvent(

       new RefreshEvent(this, null, "Refresh Nacos config"));

剩余22页未读，继续阅读

学无止路

粉丝: 1422
资源: 8

会员权益专享

Nacos动态配置原理分析

评论0

会员权益专享

最新资源

Nacos动态配置原理分析

评论0

nacos动态配置原理

整合Nacos动态刷新数据源

nacos配置中心动态刷新

gateway nacos 动态路由

nacos如何动态刷新配置

nacos注册中心原理

springboot集成nacos的配置

spring nacos怎么配置

nacos 配置两个数据库

springboot读取nacos配置

Nacos配置中心的作用是什么

nacos配置中心使用教程

nacos nameing模块源码分析

springboot整合nacos配置

springboot nacos配置中心

springcloud中nacos配置时有哪些属性

Nacos配置中心如何使用

SpringCloud集合Nacos数据库配置文件存在哪里？

nacos 配置pgsql

会员权益专享

最新资源