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秒一檢測，仔細發(fā)現(xiàn)能看出每隔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提交執(zhí)行，遞歸，再執(zhí)行
                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服務端的配置文件是否發(fā)生變化，這也是nacos動態(tài)配置實現(xiàn)的原理，客戶端通過定時線程長輪詢達到動態(tài)配置的效果，可以看到這個日志的級別為INFO，我們把nacos的日志級別改為WARN，這樣就不會每次心跳檢測都打印get changedGroupKeys:[]了。