feat:support consul config data. (#1401)

Co-authored-by: Haotian Zhang <skyebefreeman@qq.com>

CHANGELOG.md

@@ -22,3 +22,4 @@
 - [feat:support consul service update task.](https://github.com/Tencent/spring-cloud-tencent/pull/1397)
 - [fix:fix app starting failed when user using custom OpenAPI bean.](https://github.com/Tencent/spring-cloud-tencent/pull/1398)
 - [fix: memory cost too many when using wildcard feign calls](https://github.com/Tencent/spring-cloud-tencent/pull/1400)
+- [feat:support consul config data.](https://github.com/Tencent/spring-cloud-tencent/pull/1401)

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/PolarisConfigBootstrapAutoConfiguration.java

@@ -36,6 +36,7 @@ import org.springframework.cloud.context.properties.ConfigurationPropertiesRebin
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
+import org.springframework.context.annotation.Primary;
 import org.springframework.core.env.Environment;
 
 /**
@@ -84,6 +85,7 @@ public class PolarisConfigBootstrapAutoConfiguration {
 	}
 
 	@Bean
+	@Primary
 	@ConditionalOnMissingBean(search = SearchStrategy.CURRENT)
 	@ConditionalOnReflectRefreshType
 	public ConfigurationPropertiesRebinder affectedConfigurationPropertiesRebinder(

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/adapter/PolarisConfigFileLocator.java

@@ -117,6 +117,9 @@ public class PolarisConfigFileLocator implements PropertySourceLocator {
 	}
 
 	private void initInternalConfigFiles(CompositePropertySource compositePropertySource) {
+		if (!polarisConfigProperties.isInternalEnabled()) {
+			return;
+		}
 		List<ConfigFileMetadata> internalConfigFiles = getInternalConfigFiles();
 
 		for (ConfigFileMetadata configFile : internalConfigFiles) {

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/adapter/PolarisConfigPropertyAutoRefresher.java

@@ -18,14 +18,17 @@
 
 package com.tencent.cloud.polaris.config.adapter;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import com.tencent.cloud.polaris.config.config.PolarisConfigProperties;
 import com.tencent.cloud.polaris.config.logger.PolarisConfigLoggerContext;
+import com.tencent.polaris.configuration.api.core.ConfigKVFile;
 import com.tencent.polaris.configuration.api.core.ConfigKVFileChangeListener;
 import com.tencent.polaris.configuration.api.core.ConfigPropertyChangeInfo;
+import com.tencent.polaris.configuration.client.internal.CompositeConfigFile;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -79,8 +82,18 @@ public abstract class PolarisConfigPropertyAutoRefresher implements ApplicationL
 
 		// register polaris config publish event
 		for (PolarisPropertySource polarisPropertySource : polarisPropertySources) {
-			registerPolarisConfigPublishChangeListener(polarisPropertySource);
+			if (polarisPropertySource.getConfigKVFile() instanceof CompositeConfigFile) {
-			customRegisterPolarisConfigPublishChangeListener(polarisPropertySource);
+				CompositeConfigFile configKVFile = (CompositeConfigFile) polarisPropertySource.getConfigKVFile();
+				for (ConfigKVFile cf : configKVFile.getConfigKVFiles()) {
+					PolarisPropertySource p = new PolarisPropertySource(cf.getNamespace(), cf.getFileGroup(), cf.getFileName(), cf, new HashMap<>());
+					registerPolarisConfigPublishChangeListener(p);
+					customRegisterPolarisConfigPublishChangeListener(p);
+				}
+			}
+			else {
+				registerPolarisConfigPublishChangeListener(polarisPropertySource);
+				customRegisterPolarisConfigPublishChangeListener(polarisPropertySource);
+			}
 		}
 	}
 
@@ -93,6 +106,7 @@ public abstract class PolarisConfigPropertyAutoRefresher implements ApplicationL
 	}
 
 	public void registerPolarisConfigPublishChangeListener(PolarisPropertySource polarisPropertySource) {
+		LOGGER.info("{} will register polaris config publish listener", polarisPropertySource.getPropertySourceName());
 		polarisPropertySource.getConfigKVFile()
 				.addChangeListener((ConfigKVFileChangeListener) configKVFileChangeEvent -> {
 

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/adapter/PolarisPropertySource.java

@@ -20,6 +20,7 @@ package com.tencent.cloud.polaris.config.adapter;
 
 import java.util.Map;
 
+import com.tencent.cloud.polaris.config.utils.PolarisPropertySourceUtils;
 import com.tencent.polaris.configuration.api.core.ConfigKVFile;
 
 import org.springframework.core.env.MapPropertySource;
@@ -40,7 +41,7 @@ public class PolarisPropertySource extends MapPropertySource {
 	private final ConfigKVFile configKVFile;
 
 	public PolarisPropertySource(String namespace, String group, String fileName, ConfigKVFile configKVFile, Map<String, Object> source) {
-		super(namespace + "-" + group + "-" + fileName, source);
+		super(PolarisPropertySourceUtils.generateName(namespace, group, fileName), source);
 
 		this.namespace = namespace;
 		this.group = group;
@@ -64,7 +65,7 @@ public class PolarisPropertySource extends MapPropertySource {
 		return namespace + "-" + group + "-" + fileName;
 	}
 
-	ConfigKVFile getConfigKVFile() {
+	public ConfigKVFile getConfigKVFile() {
 		return configKVFile;
 	}
 

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/config/PolarisConfigProperties.java

@@ -91,6 +91,11 @@ public class PolarisConfigProperties {
 	 */
 	private String localFileRootPath = "./polaris/backup/config";
 
+	/**
+	 * If internal config file enabled.
+	 */
+	private boolean internalEnabled = true;
+
 	public boolean isEnabled() {
 		return enabled;
 	}
@@ -179,6 +184,14 @@ public class PolarisConfigProperties {
 		this.localFileRootPath = localFileRootPath;
 	}
 
+	public boolean isInternalEnabled() {
+		return internalEnabled;
+	}
+
+	public void setInternalEnabled(boolean internalEnabled) {
+		this.internalEnabled = internalEnabled;
+	}
+
 	@Override
 	public String toString() {
 		return "PolarisConfigProperties{" +
@@ -193,6 +206,7 @@ public class PolarisConfigProperties {
 				", groups=" + groups +
 				", dataSource='" + dataSource + '\'' +
 				", localFileRootPath='" + localFileRootPath + '\'' +
+				", internalEnabled=" + internalEnabled +
 				'}';
 	}
 }

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/PolarisAdaptorTsfConfigAutoConfiguration.java

@@ -27,7 +27,6 @@ import com.tencent.tsf.consul.config.watch.TsfConsulConfigRefreshEventListener;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
@@ -46,8 +45,7 @@ public class PolarisAdaptorTsfConfigAutoConfiguration {
 
 	{
 		System.setProperty("spring.cloud.polaris.config.refresh-type", "refresh_context");
-		LOGGER.info(
+		LOGGER.info("PolarisAdaptorTsfConfigAutoConfiguration init set spring.cloud.polaris.config.refresh-type to refresh_context");
-				"[SCTT Config] PolarisAdaptorTsfConfigAutoConfiguration init set spring.cloud.polaris.config.refresh-type to refresh_context");
 	}
 
 	@Bean
@@ -65,7 +63,7 @@ public class PolarisAdaptorTsfConfigAutoConfiguration {
 	 */
 	@Bean
 	@ConditionalOnMissingBean
-	@ConditionalOnExpression("${spring.cloud.consul.config.enabled:true} == false and ${tsf.config.instance.released-config.lookup.enabled:true} == true")
+	@ConditionalOnProperty(name = "tsf.config.instance.released-config.lookup.enabled", matchIfMissing = true)
 	public PolarisAdaptorTsfConfigController polarisAdaptorTsfConfigController() {
 		return new PolarisAdaptorTsfConfigController();
 	}

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/PolarisAdaptorTsfConfigBootstrapConfiguration.java

@@ -22,7 +22,6 @@ import com.tencent.cloud.polaris.config.ConditionalOnPolarisConfigEnabled;
 
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Import;
 
 /**
  * @author juanyinyang
@@ -32,7 +31,6 @@ import org.springframework.context.annotation.Import;
 @ConditionalOnProperty("spring.cloud.polaris.enabled")
 @ConditionalOnTsfEnabled
 @ConditionalOnPolarisConfigEnabled
-@Import(PolarisAdaptorTsfConfigAutoConfiguration.class)
 public class PolarisAdaptorTsfConfigBootstrapConfiguration {
 
 

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/adaptor/PolarisAdaptorTsfConfigExtensionLayer.java

@@ -17,8 +17,8 @@
 
 package com.tencent.cloud.polaris.config.tsf.adaptor;
 
-import java.util.Arrays;
+import java.util.ArrayList;
-import java.util.HashSet;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -30,14 +30,13 @@ import com.tencent.cloud.polaris.config.adapter.PolarisConfigPropertyAutoRefresh
 import com.tencent.cloud.polaris.config.adapter.PolarisPropertySource;
 import com.tencent.cloud.polaris.config.adapter.PolarisPropertySourceManager;
 import com.tencent.cloud.polaris.config.enums.ConfigFileFormat;
-import com.tencent.cloud.polaris.config.tsf.cache.PolarisPropertyCache;
 import com.tencent.cloud.polaris.config.tsf.encrypt.EncryptConfig;
+import com.tencent.cloud.polaris.config.utils.PolarisPropertySourceUtils;
 import com.tencent.polaris.configuration.api.core.ConfigFileGroup;
-import com.tencent.polaris.configuration.api.core.ConfigFileGroupChangeListener;
-import com.tencent.polaris.configuration.api.core.ConfigFileGroupChangedEvent;
 import com.tencent.polaris.configuration.api.core.ConfigFileMetadata;
 import com.tencent.polaris.configuration.api.core.ConfigFileService;
 import com.tencent.polaris.configuration.api.core.ConfigKVFile;
+import com.tencent.polaris.configuration.client.internal.CompositeConfigFile;
 import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -100,16 +99,41 @@ public class PolarisAdaptorTsfConfigExtensionLayer implements PolarisConfigCusto
 	@Override
 	public void initConfigFiles(Environment environment, CompositePropertySource compositePropertySource,
 			ConfigFileService configFileService) {
-		String tsfApplicationId = environment.getProperty(TSF_APPLICATION_ID);
+		String tsfApplicationId = "";
-		String tsfGroupId = environment.getProperty(TSF_GROUP_ID);
+		String tsfGroupId = "";
-		String tsfNamespaceId = environment.getProperty(TSF_NAMESPACE_ID);
+		String tsfNamespaceId = "";
-		String polarisAdaptorTsfConfigFormat = environment.getProperty(POLARIS_ADAPTOR_TSF_CONFIG_FORMAT);
+		String polarisAdaptorTsfConfigFormat = "";
+		if (environment != null) {
+			tsfApplicationId = environment.getProperty(TSF_APPLICATION_ID);
+			tsfGroupId = environment.getProperty(TSF_GROUP_ID);
+			tsfNamespaceId = environment.getProperty(TSF_NAMESPACE_ID);
+			polarisAdaptorTsfConfigFormat = environment.getProperty(POLARIS_ADAPTOR_TSF_CONFIG_FORMAT);
+		}
+		else {
+			tsfApplicationId = System.getProperty(TSF_APPLICATION_ID);
+			if (StringUtils.isEmpty(tsfApplicationId)) {
+				tsfApplicationId = System.getenv(TSF_APPLICATION_ID);
+			}
+			tsfGroupId = System.getProperty(TSF_GROUP_ID);
+			if (StringUtils.isEmpty(tsfGroupId)) {
+				tsfGroupId = System.getenv(TSF_GROUP_ID);
+			}
+			tsfNamespaceId = System.getProperty(TSF_NAMESPACE_ID);
+			if (StringUtils.isEmpty(tsfNamespaceId)) {
+				tsfNamespaceId = System.getenv(TSF_NAMESPACE_ID);
+			}
+			polarisAdaptorTsfConfigFormat = System.getProperty(POLARIS_ADAPTOR_TSF_CONFIG_FORMAT);
+			if (StringUtils.isEmpty(polarisAdaptorTsfConfigFormat)) {
+				polarisAdaptorTsfConfigFormat = System.getenv(POLARIS_ADAPTOR_TSF_CONFIG_FORMAT);
+			}
+		}
+
 		LOGGER.info(
-				"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer initConfigFiles start, tsfNamespaceId:{}, tsfApplicationId:{}, tsfGroupId:{}",
+				"PolarisAdaptorTsfConfigExtensionLayer initConfigFiles start, tsfNamespaceId:{}, tsfApplicationId:{}, tsfGroupId:{}",
 				tsfNamespaceId, tsfApplicationId, tsfGroupId);
 		loadAllPolarisConfigFile(compositePropertySource, configFileService,
 				tsfNamespaceId, tsfApplicationId, tsfGroupId, polarisAdaptorTsfConfigFormat);
-		LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer initConfigFiles end");
+		LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer initConfigFiles end");
 	}
 
 	private void loadAllPolarisConfigFile(CompositePropertySource compositePropertySource,
@@ -128,126 +152,142 @@ public class PolarisAdaptorTsfConfigExtensionLayer implements PolarisConfigCusto
 				compositePropertySource, configFileService, pubConfigGroup);
 	}
 
-	private PolarisPropertySource loadPolarisPropertySource(String namespace, String group, String fileName,
+	private PolarisPropertySource loadPolarisPropertySource(String configFileGroupNamespace, String configFileGroupName,
-			String polarisAdaptorTsfConfigFormat, ConfigFileService configFileService) {
+			List<ConfigFileMetadata> configFileMetadataList, String polarisAdaptorTsfConfigFormat,
-		ConfigKVFile configKVFile;
+			ConfigFileService configFileService) {
-		if (StringUtils.isNotBlank(polarisAdaptorTsfConfigFormat)) {
+		List<ConfigKVFile> configKVFiles = new ArrayList<>();
-			switch (polarisAdaptorTsfConfigFormat) {
+
-			case "properties":
+		for (ConfigFileMetadata configFileMetadata : configFileMetadataList) {
-				configKVFile = configFileService.getConfigPropertiesFile(namespace, group, fileName);
+			ConfigKVFile configKVFile;
-			case "yaml":
+			String namespace = configFileMetadata.getNamespace();
-			default:
+			String group = configFileMetadata.getFileGroup();
+			String fileName = configFileMetadata.getFileName();
+			if (StringUtils.isNotBlank(polarisAdaptorTsfConfigFormat)) {
+				switch (polarisAdaptorTsfConfigFormat) {
+				case "properties":
+					configKVFile = configFileService.getConfigPropertiesFile(namespace, group, fileName);
+					break;
+				case "yaml":
+				default:
+					configKVFile = configFileService.getConfigYamlFile(namespace, group, fileName);
+				}
+			}
+			// unknown extension is resolved as yaml file
+			else if (ConfigFileFormat.isYamlFile(fileName) || ConfigFileFormat.isUnknownFile(fileName)) {
 				configKVFile = configFileService.getConfigYamlFile(namespace, group, fileName);
 			}
-		}
+			else if (ConfigFileFormat.isPropertyFile(fileName)) {
-		// unknown extension is resolved as yaml file
+				configKVFile = configFileService.getConfigPropertiesFile(namespace, group, fileName);
-		else if (ConfigFileFormat.isYamlFile(fileName) || ConfigFileFormat.isUnknownFile(fileName)) {
+			}
-			configKVFile = configFileService.getConfigYamlFile(namespace, group, fileName);
+			else {
-		}
+				LOGGER.warn("Unsupported config file. namespace = {}, group = {}, fileName = {}", namespace,
-		else if (ConfigFileFormat.isPropertyFile(fileName)) {
+						group, fileName);
-			configKVFile = configFileService.getConfigPropertiesFile(namespace, group, fileName);
-		}
-		else {
-			LOGGER.warn("[SCTT Config] Unsupported config file. namespace = {}, group = {}, fileName = {}", namespace,
-					group, fileName);
 
-			throw new IllegalStateException("Only configuration files in the format of properties / yaml / yaml"
+				throw new IllegalStateException("Only configuration files in the format of properties / yaml / yaml"
-					+ " can be injected into the spring context");
+						+ " can be injected into the spring context");
+			}
+			configKVFiles.add(configKVFile);
 		}
 
+		CompositeConfigFile compositeConfigFile = new CompositeConfigFile(configKVFiles);
+
 		Map<String, Object> map = new ConcurrentHashMap<>();
-		for (String key : configKVFile.getPropertyNames()) {
+		for (String key : compositeConfigFile.getPropertyNames()) {
-			String value = configKVFile.getProperty(key, null);
+			String value = compositeConfigFile.getProperty(key, null);
 			if (EncryptConfig.needDecrypt(value)) {
-				LOGGER.debug("[SCTT Config] Need Decrypt {}: {}", key, value);
+				LOGGER.debug("Need Decrypt {}: {}", key, value);
 				value = EncryptConfig.getProvider()
 						.decrypt(EncryptConfig.realContent(value), EncryptConfig.getPassword());
 			}
 			map.put(key, value);
 		}
 
-		return new PolarisPropertySource(namespace, group, fileName, configKVFile, map);
+		if (LOGGER.isDebugEnabled()) {
+			LOGGER.debug("namespace='" + configFileGroupNamespace + '\''
+					+ ", group='" + configFileGroupName + '\'' + ", fileName='" + compositeConfigFile + '\''
+					+ ", map='" + map + '\'');
+		}
+
+		return new PolarisPropertySource(configFileGroupNamespace, configFileGroupName, "", compositeConfigFile, map);
 	}
 
 	private void loadPolarisConfigFile(String namespace, String tsfApplicationId, String tsfGroupId,
 			String polarisAdaptorTsfConfigFormat, CompositePropertySource compositePropertySource,
 			ConfigFileService configFileService, String configGroup) {
 		LOGGER.debug(
-				"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer loadPolarisConfigFile start, namespace:{}, group:{}",
+				"PolarisAdaptorTsfConfigExtensionLayer loadPolarisConfigFile start, namespace:{}, group:{}",
 				namespace, configGroup);
 		ConfigFileGroup configFileGroup = configFileService.getConfigFileGroup(namespace, configGroup);
 		if (configFileGroup == null) {
 			throw new IllegalStateException(
-					"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer configFileGroup is null");
+					"PolarisAdaptorTsfConfigExtensionLayer configFileGroup is null");
 		}
 		List<ConfigFileMetadata> configFileMetadataList = configFileGroup.getConfigFileMetadataList();
 		if (!CollectionUtils.isEmpty(configFileMetadataList)) {
-			LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer getConfigFileMetadataList:{}",
+			LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer getConfigFileMetadataList:{}",
 					configFileMetadataList);
-			for (ConfigFileMetadata configFile : configFileMetadataList) {
+		}
-				PolarisPropertySource polarisPropertySource = loadPolarisPropertySource(configFile.getNamespace(),
+		else {
-						configFile.getFileGroup(), configFile.getFileName(), polarisAdaptorTsfConfigFormat,
+			LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer getConfigFileMetadataList empty. file = {}:{}",
-						configFileService);
+					configFileGroup.getNamespace(), configFileGroup.getNamespace());
+		}
+		PolarisPropertySource polarisPropertySource = loadPolarisPropertySource(namespace, configGroup,
+				configFileMetadataList, polarisAdaptorTsfConfigFormat, configFileService);
 
-				compositePropertySource.addPropertySource(polarisPropertySource);
+		compositePropertySource.addPropertySource(polarisPropertySource);
 
-				PolarisPropertySourceManager.addPropertySource(polarisPropertySource);
+		PolarisPropertySourceManager.addPropertySource(polarisPropertySource);
+
+		LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer Load and inject polaris config file from config group:{}. file = {}",
+				configGroup, polarisPropertySource.getConfigKVFile());
 
-				LOGGER.info(
-						"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer Load and inject polaris config file from config group:{}. file = {}",
-						configGroup, configFile);
-			}
-		}
 
 		String namespaceConfigGroup = namespace + "-" + configGroup;
 		// 用ConcurrentHashSet保证不重复添加ConfigFileGroupChangeListener
 		if (registedConfigFileGroupListenerSets.add(namespaceConfigGroup)) {
-			LOGGER.info(
+			LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer configFileGroup addChangeListener namespaceConfigGroup:{}",
-					"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer configFileGroup addChangeListener namespaceConfigGroup:{}",
 					namespaceConfigGroup);
-			configFileGroup.addChangeListener(new ConfigFileGroupChangeListener() {
+			configFileGroup.addChangeListener(event -> {
-
+				try {
-				@Override
+					LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer receive onChange event:{}",
-				public void onChange(ConfigFileGroupChangedEvent event) {
+							event);
-					try {
+					List<ConfigFileMetadata> oldConfigFileMetadataList = event.getOldConfigFileMetadataList();
-						LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer receive onChange event:{}",
+					List<ConfigFileMetadata> newConfigFileMetadataList = event.getNewConfigFileMetadataList();
-								event);
+
-						List<ConfigFileMetadata> configFileMetadataList = event.getConfigFileMetadataList();
+					List<String> toUnregister = calculateUnregister(oldConfigFileMetadataList, newConfigFileMetadataList);
-						if (CollectionUtils.isEmpty(configFileMetadataList)) {
+					toUnregister.forEach(registedPolarisPropertySets::remove);
-							LOGGER.info(
+
-									"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer receive configFileMetadataList is empty");
+					if (CollectionUtils.isEmpty(newConfigFileMetadataList)) {
-							return;
+						LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer receive configFileMetadataList is empty");
-						}
+					}
-						boolean needRefreshAll = false;
+					else {
-						for (ConfigFileMetadata configFile : configFileMetadataList) {
+						PolarisPropertySource polarisPropertySource1 = loadPolarisPropertySource(
-							PolarisPropertySource polarisPropertySource = loadPolarisPropertySource(
+								event.getConfigFileGroupMetadata().getNamespace(),
-									configFile.getNamespace(), configFile.getFileGroup(), configFile.getFileName(),
+								event.getConfigFileGroupMetadata().getFileGroupName(),
-									polarisAdaptorTsfConfigFormat, configFileService);
+								newConfigFileMetadataList, polarisAdaptorTsfConfigFormat, configFileService);
+						// 用ConcurrentHashSet保证不重复注册PolarisConfigPublishChangeListener
+						CompositeConfigFile configKVFile = (CompositeConfigFile) polarisPropertySource1.getConfigKVFile();
+						for (ConfigKVFile cf : configKVFile.getConfigKVFiles()) {
 							LOGGER.info(
-									"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer Load and inject polaris config file from onChange event config group:{}. file = {}",
+									"PolarisAdaptorTsfConfigExtensionLayer Load and inject polaris config file from onChange event config group:{}. file = {}",
-									configGroup, configFile);
+									configGroup, cf);
-							// 用ConcurrentHashSet保证不重复注册PolarisConfigPublishChangeListener
+							PolarisPropertySource p = new PolarisPropertySource(cf.getNamespace(), cf.getFileGroup(), cf.getFileName(), cf, new HashMap<>());
-							if (executeRegisterPublishChangeListener(polarisPropertySource)) {
+							if (executeRegisterPublishChangeListener(p)) {
-								polarisConfigPropertyAutoRefresher.registerPolarisConfigPublishChangeListener(
+								polarisConfigPropertyAutoRefresher.registerPolarisConfigPublishChangeListener(p);
-										polarisPropertySource);
-								needRefreshAll = true;
 							}
 						}
-						if (needRefreshAll) {
-							LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer start refresh All Config");
-							polarisConfigPropertyAutoRefresher.refreshConfigurationProperties(null);
-						}
-					}
-					catch (Exception e) {
-						LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer receive onChange exception:",
-								e);
 					}
+					LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer start refresh All Config");
+					polarisConfigPropertyAutoRefresher.refreshConfigurationProperties(null);
+				}
+				catch (Exception e) {
+					LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer receive onChange exception:",
+							e);
 				}
 			});
 		}
 
-		LOGGER.info(
+		LOGGER.info("PolarisAdaptorTsfConfigExtensionLayer loadPolarisConfigFile end, namespace:{}, group:{}",
-				"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer loadPolarisConfigFile end, namespace:{}, group:{}",
 				namespace, configGroup);
 	}
 
@@ -256,10 +296,7 @@ public class PolarisAdaptorTsfConfigExtensionLayer implements PolarisConfigCusto
 	 */
 	@Override
 	public void executeAfterLocateConfigReturning(CompositePropertySource compositePropertySource) {
-		PolarisPropertyCache.getInstance().clear();
+
-		PolarisPropertyCache.getInstance().getCache()
-				.addAll(new HashSet<>(Arrays.asList(compositePropertySource.getPropertyNames())));
-		LOGGER.info("[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer executeAfterLocateConfigReturning finished");
 	}
 
 	/**
@@ -268,7 +305,7 @@ public class PolarisAdaptorTsfConfigExtensionLayer implements PolarisConfigCusto
 	@Override
 	public void initRegisterConfig(PolarisConfigPropertyAutoRefresher polarisConfigPropertyAutoRefresher) {
 		LOGGER.info(
-				"[SCTT Config] PolarisAdaptorTsfConfigExtensionLayer initRegisterConfig polarisConfigPropertyAutoRefresher:{}",
+				"PolarisAdaptorTsfConfigExtensionLayer initRegisterConfig polarisConfigPropertyAutoRefresher:{}",
 				polarisConfigPropertyAutoRefresher.getClass());
 		this.polarisConfigPropertyAutoRefresher = polarisConfigPropertyAutoRefresher;
 	}
@@ -281,9 +318,27 @@ public class PolarisAdaptorTsfConfigExtensionLayer implements PolarisConfigCusto
 		boolean isRegisterSuccess = registedPolarisPropertySets.add(polarisPropertySource.getPropertySourceName());
 		if (isRegisterSuccess) {
 			// 已防止重复注册，仅打印注册成功的即可
-			LOGGER.info("[SCTT Config] start to register configFile polarisConfigPublishChangeListener:{}",
+			LOGGER.info("start to register configFile polarisConfigPublishChangeListener:{}",
 					polarisPropertySource);
 		}
 		return isRegisterSuccess;
 	}
+
+	private List<String> calculateUnregister(List<ConfigFileMetadata> oldConfigFileMetadataList, List<ConfigFileMetadata> newConfigFileMetadataList) {
+		List<String> newNameList = new ArrayList<>();
+		for (ConfigFileMetadata configFileMetadata : newConfigFileMetadataList) {
+			newNameList.add(PolarisPropertySourceUtils.generateName(configFileMetadata.getNamespace(),
+					configFileMetadata.getFileGroup(), configFileMetadata.getFileName()));
+		}
+
+		List<String> toUnregister = new ArrayList<>();
+		for (ConfigFileMetadata configFileMetadata : oldConfigFileMetadataList) {
+			String oldName = (PolarisPropertySourceUtils.generateName(configFileMetadata.getNamespace(),
+					configFileMetadata.getFileGroup(), configFileMetadata.getFileName()));
+			if (!newNameList.contains(oldName)) {
+				toUnregister.add(oldName);
+			}
+		}
+		return toUnregister;
+	}
 }

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/controller/PolarisAdaptorTsfConfigController.java

@@ -18,11 +18,15 @@
 package com.tencent.cloud.polaris.config.tsf.controller;
 
 
+import java.util.Arrays;
 import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
-import com.tencent.cloud.polaris.config.tsf.cache.PolarisPropertyCache;
+import com.tencent.cloud.polaris.config.adapter.PolarisPropertySource;
+import com.tencent.cloud.polaris.config.adapter.PolarisPropertySourceManager;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -44,7 +48,7 @@ public class PolarisAdaptorTsfConfigController {
 	Environment environment;
 
 	public PolarisAdaptorTsfConfigController() {
-		LOG.info("[SCTT Config] init PolarisAdaptorTsfConfigController");
+		LOG.info("init PolarisAdaptorTsfConfigController");
 	}
 
 	/**
@@ -52,7 +56,13 @@ public class PolarisAdaptorTsfConfigController {
 	 */
 	@RequestMapping("/tsf/innerApi/config/findAllConfig")
 	public Map<String, Object> findAllConfig() {
-		Set<String> keys = PolarisPropertyCache.getInstance().getCache();
+		List<PolarisPropertySource> propertySourceList = PolarisPropertySourceManager.getAllPropertySources();
+
+		Set<String> keys = new HashSet<>();
+		for (PolarisPropertySource propertySource : propertySourceList) {
+			keys.addAll(Arrays.asList(propertySource.getPropertyNames()));
+		}
+
 		return keys.stream()
 				.collect(HashMap::new, (map, key) -> map.put(key, environment.getProperty(key)), HashMap::putAll);
 	}

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/encrypt/ConfigEncryptAESProvider.java

@@ -30,7 +30,7 @@ public class ConfigEncryptAESProvider extends ConfigEncryptProvider {
 			return EncryptAlgorithm.AES256.encrypt(content, password);
 		}
 		catch (Exception e) {
-			log.error("[SCTT Config] Error on encrypting.", e);
+			log.error("Error on encrypting.", e);
 			throw e;
 		}
 	}
@@ -41,7 +41,7 @@ public class ConfigEncryptAESProvider extends ConfigEncryptProvider {
 			return EncryptAlgorithm.AES256.decrypt(encryptedContent, password);
 		}
 		catch (Exception e) {
-			log.error("[SCTT Config] Error on decrypting.", e);
+			log.error("Error on decrypting.", e);
 			throw e;
 		}
 	}

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/tsf/encrypt/EncryptAlgorithm.java

@@ -71,7 +71,7 @@ public class EncryptAlgorithm {
 				return new String(enryptedContent);
 			}
 			catch (Exception e) {
-				throw new RuntimeException("[SCTT Encrypt] Failed encrypt.", e);
+				throw new RuntimeException("Failed encrypt.", e);
 			}
 		}
 
@@ -110,7 +110,7 @@ public class EncryptAlgorithm {
 				return new String(result);
 			}
 			catch (Exception e) {
-				throw new RuntimeException("[SCTT Encrypt] Failed decrypt.", e);
+				throw new RuntimeException("Failed decrypt.", e);
 			}
 		}
 	}
@@ -139,7 +139,7 @@ public class EncryptAlgorithm {
 		private static final long serialVersionUID = -2843758461182470411L;
 
 		public PasswordNotFoundException() {
-			super("[SCTT Encrypt] Password not found.");
+			super("Password not found.");
 		}
 
 	}

spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/utils/PolarisPropertySourceUtils.java

@@ -14,35 +14,21 @@
  * CONDITIONS OF ANY KIND, either express or implied. See the License for the
  * specific language governing permissions and limitations under the License.
  */
-package com.tencent.cloud.polaris.config.tsf.cache;
-
-import java.util.HashSet;
-import java.util.Set;
 
+package com.tencent.cloud.polaris.config.utils;
 
 /**
- * @author juanyinyang
+ * Utils for PolarisPropertySource.
- * @Date 2023年8月8日 下午4:56:18
+ *
+ * @author Haotian Zhang
  */
-public final class PolarisPropertyCache {
+public final class PolarisPropertySourceUtils {
-
-	private static final PolarisPropertyCache instance = new PolarisPropertyCache();
-
-	private final Set<String> cache = new HashSet<>();
 
-	private PolarisPropertyCache() {
+	private PolarisPropertySourceUtils() {
-
-	}
-
-	public static PolarisPropertyCache getInstance() {
-		return instance;
-	}
 
-	public Set<String> getCache() {
-		return cache;
 	}
 
-	public void clear() {
+	public static String generateName(String namespace, String group, String fileName) {
-		cache.clear();
+		return namespace + "-" + group + "-" + fileName;
 	}
 }

spring-cloud-starter-tencent-polaris-config/src/test/java/com/tencent/cloud/polaris/config/adapter/PolarisConfigFileLocatorTest.java

@@ -92,6 +92,7 @@ public class PolarisConfigFileLocatorTest {
 
 		when(polarisConfigProperties.isEnabled()).thenReturn(true);
 		when(polarisConfigProperties.getGroups()).thenReturn(null);
+		when(polarisConfigProperties.isInternalEnabled()).thenReturn(true);
 		when(environment.getActiveProfiles()).thenReturn(new String[] {});
 
 		PropertySource<?> propertySource = locator.locate(environment);
@@ -140,6 +141,7 @@ public class PolarisConfigFileLocatorTest {
 
 		when(polarisConfigProperties.isEnabled()).thenReturn(true);
 		when(polarisConfigProperties.getGroups()).thenReturn(null);
+		when(polarisConfigProperties.isInternalEnabled()).thenReturn(true);
 		when(environment.getActiveProfiles()).thenReturn(new String[] {"dev"});
 
 		PropertySource<?> propertySource = locator.locate(environment);
@@ -178,6 +180,7 @@ public class PolarisConfigFileLocatorTest {
 
 		when(polarisConfigProperties.isEnabled()).thenReturn(true);
 		when(polarisConfigProperties.getGroups()).thenReturn(customFiles);
+		when(polarisConfigProperties.isInternalEnabled()).thenReturn(true);
 		when(environment.getActiveProfiles()).thenReturn(new String[] {});
 
 		// file1.properties

spring-cloud-starter-tencent-polaris-contract/src/main/java/com/tencent/cloud/polaris/contract/tsf/TsfContractProperties.java

@@ -56,7 +56,7 @@ public class TsfContractProperties implements ExtendedContractProperties {
 
 	@Override
 	public boolean isEnabled() {
-		return enabled;
+		return false;
 	}
 
 	@Override

spring-cloud-tencent-examples/tsf-example/provider-demo/pom.xml

@@ -31,6 +31,14 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-actuator</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-bootstrap</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>

spring-cloud-tencent-examples/tsf-example/provider-demo/src/main/resources/bootstrap.yml

@@ -22,3 +22,9 @@ logging:
     name: /tsf-demo-logs/${spring.application.name}/root.log
   level:
     root: INFO
+management:
+  endpoints:
+    web:
+      exposure:
+        include:
+          - polaris-config

spring-cloud-tencent-polaris-context/src/main/java/com/tencent/cloud/polaris/context/logging/PolarisLoggingApplicationListener.java

@@ -23,6 +23,7 @@ import com.tencent.polaris.logging.PolarisLogging;
 import org.springframework.boot.context.event.ApplicationEnvironmentPreparedEvent;
 import org.springframework.boot.context.event.ApplicationFailedEvent;
 import org.springframework.boot.context.logging.LoggingApplicationListener;
+import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
 import org.springframework.context.ApplicationEvent;
 import org.springframework.context.event.GenericApplicationListener;
 import org.springframework.core.ResolvableType;
@@ -45,7 +46,8 @@ public class PolarisLoggingApplicationListener implements GenericApplicationList
 			return false;
 		}
 		return ApplicationEnvironmentPreparedEvent.class.isAssignableFrom(type)
-				|| ApplicationFailedEvent.class.isAssignableFrom(type);
+				|| ApplicationFailedEvent.class.isAssignableFrom(type)
+				|| EnvironmentChangeEvent.class.isAssignableFrom(type);
 	}
 
 	@Override