Fix the configuration file loading issue #4556 #4541

core/src/main/java/com/alibaba/nacos/core/listener/StartingApplicationListener.java

@@ -23,9 +23,12 @@
 import com.alibaba.nacos.common.executor.ThreadPoolManager;
 import com.alibaba.nacos.common.notify.NotifyCenter;
 import com.alibaba.nacos.sys.env.EnvUtil;
+import com.alibaba.nacos.sys.file.FileChangeEvent;
+import com.alibaba.nacos.sys.file.FileWatcher;
 import com.alibaba.nacos.sys.file.WatchFileCenter;
 import com.alibaba.nacos.sys.utils.DiskUtils;
 import com.alibaba.nacos.sys.utils.InetUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.boot.env.OriginTrackedMapPropertySource;
@@ -36,6 +39,8 @@
 import java.io.IOException;
 import java.nio.file.Paths;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
@@ -55,7 +60,9 @@ public class StartingApplicationListener implements NacosApplicationListener {
 
     private static final String LOCAL_IP_PROPERTY_KEY = "nacos.local.ip";
 
-    private static final String FIRST_PRE_PROPERTIES = "first_pre";
+    private static final String NACOS_APPLICATION_CONF = "nacos_application_conf";
+
+    private static final Map<String, Object> SOURCES = new ConcurrentHashMap<>();
 
     private ScheduledExecutorService scheduledExecutorService;
 
@@ -100,7 +107,6 @@ public void started(ConfigurableApplicationContext context) {
 
     @Override
     public void running(ConfigurableApplicationContext context) {
-        removePreProperties(context.getEnvironment());
     }
 
     @Override
@@ -109,7 +115,7 @@ public void failed(ConfigurableApplicationContext context, Throwable exception)
 
         logFilePath();
 
-        LOGGER.error("Startup errors : {}", exception);
+        LOGGER.error("Startup errors :", exception);
         ThreadPoolManager.shutdown();
         WatchFileCenter.shutdown();
         NotifyCenter.shutdown();
@@ -128,13 +134,38 @@ private void injectEnvironment(ConfigurableEnvironment environment) {
 
     private void loadPreProperties(ConfigurableEnvironment environment) {
         try {
-            environment.getPropertySources().addLast(new OriginTrackedMapPropertySource(FIRST_PRE_PROPERTIES,
-                    EnvUtil.loadProperties(EnvUtil.getApplicationConfFileResource())));
+            SOURCES.putAll(EnvUtil.loadProperties(EnvUtil.getApplicationConfFileResource()));
+            environment.getPropertySources()
+                    .addLast(new OriginTrackedMapPropertySource(NACOS_APPLICATION_CONF, SOURCES));
+            registerWatcher();
         } catch (IOException e) {
             throw new NacosRuntimeException(NacosException.SERVER_ERROR, e);
         }
     }
 
+    private void registerWatcher() {
+        try {
+            WatchFileCenter.registerWatcher(EnvUtil.getConfPath(), new FileWatcher() {
+                @Override
+                public void onChange(FileChangeEvent event) {
+                    try {
+                        Map<String, ?> tmp = EnvUtil.loadProperties(EnvUtil.getApplicationConfFileResource());
+                        SOURCES.putAll(tmp);
+                    } catch (IOException ignore) {
+
+                    }
+                }
+
+                @Override
+                public boolean interest(String context) {
+                    return StringUtils.contains(context, "application.properties");
+                }
+            });
+        } catch (NacosException ignore) {
+
+        }
+    }
+
     private void initSystemProperty() {
         if (EnvUtil.getStandaloneMode()) {
             System.setProperty(MODE_PROPERTY_KEY_STAND_MODE, "stand alone");
@@ -152,10 +183,6 @@ private void initSystemProperty() {
         System.setProperty(LOCAL_IP_PROPERTY_KEY, InetUtils.getSelfIP());
     }
 
-    private void removePreProperties(ConfigurableEnvironment environment) {
-        environment.getPropertySources().remove(FIRST_PRE_PROPERTIES);
-    }
-
     private void logClusterConf() {
         if (!EnvUtil.getStandaloneMode()) {
             try {

distribution/bin/startup.cmd

@@ -21,8 +21,7 @@ rem added double quotation marks to avoid the issue caused by the folder names c
 rem removed the last 5 chars(which means \bin\) to get the base DIR.
 set BASE_DIR="%BASE_DIR:~0,-5%"
 
-set DEFAULT_SEARCH_LOCATIONS="classpath:/,classpath:/config/,file:./,file:./config/"
-set CUSTOM_SEARCH_LOCATIONS=file:%BASE_DIR%/conf/,%DEFAULT_SEARCH_LOCATIONS%
+set CUSTOM_SEARCH_LOCATIONS=file:%BASE_DIR%/conf/
 
 set MODE="cluster"
 set FUNCTION_MODE="all"
@@ -84,7 +83,7 @@ set "NACOS_OPTS=%NACOS_OPTS% -Dnacos.home=%BASE_DIR%"
 set "NACOS_OPTS=%NACOS_OPTS% -jar %BASE_DIR%\target\%SERVER%.jar"
 
 rem set nacos spring config location
-set "NACOS_CONFIG_OPTS=--spring.config.location=%CUSTOM_SEARCH_LOCATIONS%"
+set "NACOS_CONFIG_OPTS=--spring.config.additional-location=%CUSTOM_SEARCH_LOCATIONS%"
 
 rem set nacos log4j file location
 set "NACOS_LOG4J_OPTS=--logging.config=%BASE_DIR%/conf/nacos-logback.xml"

distribution/bin/startup.sh

@@ -78,8 +78,7 @@ done
 export JAVA_HOME
 export JAVA="$JAVA_HOME/bin/java"
 export BASE_DIR=`cd $(dirname $0)/..; pwd`
-export DEFAULT_SEARCH_LOCATIONS="classpath:/,classpath:/config/,file:./,file:./config/"
-export CUSTOM_SEARCH_LOCATIONS=file:${BASE_DIR}/conf/,${DEFAULT_SEARCH_LOCATIONS}
+export CUSTOM_SEARCH_LOCATIONS=file:${BASE_DIR}/conf/
 
 #===========================================================================================
 # JVM Configuration
@@ -117,7 +116,7 @@ JAVA_OPT="${JAVA_OPT} -Dloader.path=${BASE_DIR}/plugins/health,${BASE_DIR}/plugi
 JAVA_OPT="${JAVA_OPT} -Dnacos.home=${BASE_DIR}"
 JAVA_OPT="${JAVA_OPT} -jar ${BASE_DIR}/target/${SERVER}.jar"
 JAVA_OPT="${JAVA_OPT} ${JAVA_OPT_EXT}"
-JAVA_OPT="${JAVA_OPT} --spring.config.location=${CUSTOM_SEARCH_LOCATIONS}"
+JAVA_OPT="${JAVA_OPT} --spring.config.additional-location=${CUSTOM_SEARCH_LOCATIONS}"
 JAVA_OPT="${JAVA_OPT} --logging.config=${BASE_DIR}/conf/nacos-logback.xml"
 JAVA_OPT="${JAVA_OPT} --server.max-http-header-size=524288"
 

sys/src/main/java/com/alibaba/nacos/sys/env/EnvUtil.java

@@ -366,9 +366,10 @@ public static Resource getApplicationConfFileResource() {
     }
 
     private static Resource getCustomFileResource() {
-        String path = getProperty("spring.config.location");
+        String path = getProperty("spring.config.additional-location");
+        InputStream inputStream = null;
         if (StringUtils.isNotBlank(path) && path.contains(FILE_PREFIX)) {
-            String[] paths = path.split(",");
+            String[] paths = path.split(",", -1);
             path = paths[paths.length - 1].substring(FILE_PREFIX.length());
             return getRelativePathResource(path, "application.properties");
         }

sys/src/main/java/com/alibaba/nacos/sys/env/NacosAutoRefreshPropertySourceLoader.java

@@ -38,6 +38,7 @@
  *
  * @author <a href="mailto:liaochuntao@live.com">liaochuntao</a>
  */
+@Deprecated
 public class NacosAutoRefreshPropertySourceLoader implements PropertySourceLoader {
 
     private final Map<String, Object> properties = new ConcurrentHashMap<>(16);

sys/src/main/resources/META-INF/spring.factories

@@ -1,6 +1,5 @@
 # PropertySource Loaders
-org.springframework.boot.env.PropertySourceLoader=\
-  com.alibaba.nacos.sys.env.NacosAutoRefreshPropertySourceLoader
+
 # EnvironmentPostProcessor
 org.springframework.boot.env.EnvironmentPostProcessor=\
 com.alibaba.nacos.sys.env.NacosDefaultPropertySourceEnvironmentPostProcessor