Nacos后台频繁打印get changedGroupKeys:[]的问题及解决

 更新时间:2024年01月09日 14:40:30   作者:"小王"  
这篇文章主要介绍了Nacos后台频繁打印get changedGroupKeys:[]的问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

一、问题描述

在使用Nacos作为注册中心情况下,客户端启动后频繁打印get changedGroupKeys:[]

c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]
c.a.n.client.config.impl.ClientWorker    : get changedGroupKeys:[]

先贴解决方案,再来分析原因

二、解决

nacos配置中加上禁用心跳日志

logging:
  level:
    com.alibaba.nacos.client.config.impl: WARN

在这里插入图片描述

三、问题分析

从日志可以看出 get changedGroupKeys:[] 是从c.a.n.client.config.impl.ClientWorker对象中打印出来的

贴出ClientWorker类中打印get changedGroupKeys:[]方法代码:

public class ClientWorker {
	//长轮询任务,检测服务端配置文件是否更改,30秒超时
	class LongPollingRunnable implements Runnable {
        private int taskId;

        public LongPollingRunnable(int taskId) {
            this.taskId = taskId;
        }

        @Override
        public void run() {

            List<CacheData> cacheDatas = new ArrayList<CacheData>();
            List<String> inInitializingCacheList = new ArrayList<String>();
            try {
                // check failover config
                for (CacheData cacheData : cacheMap.get().values()) {
                    if (cacheData.getTaskId() == taskId) {
                        cacheDatas.add(cacheData);
                        try {
                        	//检查本地配置
                            checkLocalConfig(cacheData);
                            if (cacheData.isUseLocalConfigInfo()) {
                                cacheData.checkListenerMd5();
                            }
                        } catch (Exception e) {
                            LOGGER.error("get local config info error", e);
                        }
                    }
                }

                // check server config
                List<String> changedGroupKeys = checkUpdateDataIds(cacheDatas, inInitializingCacheList);
                
                //可以看出这里打印的心跳日志 get changedGroupKeys:[]
                LOGGER.info("get changedGroupKeys:" + changedGroupKeys);

                for (String groupKey : changedGroupKeys) {
                    String[] key = GroupKey.parseKey(groupKey);
                    String dataId = key[0];
                    String group = key[1];
                    String tenant = null;
                    if (key.length == 3) {
                        tenant = key[2];
                    }
                    try {
                    	//30秒超时,30秒一检测,仔细发现能看出每隔30秒打印一遍get changedGroupKeys:[]心跳日志
                        String[] ct = getServerConfig(dataId, group, tenant, 3000L);
                        CacheData cache = cacheMap.get().get(GroupKey.getKeyTenant(dataId, group, tenant));
                        cache.setContent(ct[0]);
                        if (null != ct[1]) {
                            cache.setType(ct[1]);
                        }
                        LOGGER.info("[{}] [data-received] dataId={}, group={}, tenant={}, md5={}, content={}, type={}",
                            agent.getName(), dataId, group, tenant, cache.getMd5(),
                            ContentUtils.truncateContent(ct[0]), ct[1]);
                    } catch (NacosException ioe) {
                        String message = String.format(
                            "[%s] [get-update] get changed config exception. dataId=%s, group=%s, tenant=%s",
                            agent.getName(), dataId, group, tenant);
                        LOGGER.error(message, ioe);
                    }
                }
                for (CacheData cacheData : cacheDatas) {
                    if (!cacheData.isInitializing() || inInitializingCacheList
                        .contains(GroupKey.getKeyTenant(cacheData.dataId, cacheData.group, cacheData.tenant))) {
                        cacheData.checkListenerMd5();
                        cacheData.setInitializing(false);
                    }
                }
                inInitializingCacheList.clear();
				//方法的最后会再把LongPollingRunnable提交执行,递归,再执行
                executorService.execute(this);

            } catch (Throwable e) {

                // If the rotation training task is abnormal, the next execution time of the task will be punished
                LOGGER.error("longPolling error : ", e);
                executorService.schedule(this, taskPenaltyTime, TimeUnit.MILLISECONDS);
            }
        }
    }

}

分析:

从ClientWorker 代码中分析出,nacos客户端和服务端会通过心跳来检测nacos服务端的配置文件是否发生变化,这也是nacos动态配置实现的原理,客户端通过定时线程长轮询达到动态配置的效果,可以看到这个日志的级别为INFO,我们把nacos的日志级别改为WARN,这样就不会每次心跳检测都打印get changedGroupKeys:[]了。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • java数据结构算法稀疏数组示例详解

    java数据结构算法稀疏数组示例详解

    这篇文章主要为大家介绍了java数据结构算法稀疏数组示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-06-06
  • java开放地址法和链地址法解决hash冲突的方法示例

    java开放地址法和链地址法解决hash冲突的方法示例

    这篇文章主要介绍了java开放地址法和链地址法解决hash冲突的方法示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • Java正则表达式如何匹配特定html标签内的内容

    Java正则表达式如何匹配特定html标签内的内容

    这篇文章主要给大家介绍了关于Java正则表达式如何匹配特定html标签内的内容的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • Log4j日志记录框架配置及用法解析

    Log4j日志记录框架配置及用法解析

    这篇文章主要介绍了Log4j日志记录框架配置及用法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • 利用java获取某个文件夹下的所有文件

    利用java获取某个文件夹下的所有文件

    这篇文章主要给大家介绍了关于如何利用java获取某个文件夹下的所有文件的相关资料,在从事web开发工作中,经常需要对本地某一个目录下的文件进行处理,需要的朋友可以参考下
    2023-07-07
  • Java调用打印机的2种方式举例(无驱/有驱)

    Java调用打印机的2种方式举例(无驱/有驱)

    我们平时使用某些软件或者在超市购物的时候都会发现可以使用打印机进行打印,这篇文章主要给大家介绍了关于Java调用打印机的2种方式,分别是无驱/有驱的相关资料,需要的朋友可以参考下
    2023-11-11
  • Spring框架JavaMailSender发送邮件工具类详解

    Spring框架JavaMailSender发送邮件工具类详解

    这篇文章主要为大家详细介绍了Spring框架JavaMailSender发送邮件工具类,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-04-04
  • JAVA module-info.java文件详解

    JAVA module-info.java文件详解

    这篇文章主要介绍了JAVA module-info.java文件详解,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-01-01
  • Java IO流之字符缓冲流实例详解

    Java IO流之字符缓冲流实例详解

    这篇文章主要介绍了Java IO流之字符缓冲流,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-05-05
  • java解析sina视频

    java解析sina视频

    本文介绍了一个java解析sina视频地址的例子,从这个例子中可以学习到java使用sax解析xml的方法,大家可以参考修改成其它功能
    2014-01-01

最新评论