configFileGroups) {
String namespace = polarisContextProperties.getNamespace();
@@ -125,12 +191,10 @@ public class PolarisConfigFileLocator implements PropertySourceLocator {
// unknown extension is resolved as properties file
if (ConfigFileFormat.isPropertyFile(fileName)
|| ConfigFileFormat.isUnknownFile(fileName)) {
- configKVFile = configFileService.getConfigPropertiesFile(namespace, group,
- fileName);
+ configKVFile = configFileService.getConfigPropertiesFile(namespace, group, fileName);
}
else if (ConfigFileFormat.isYamlFile(fileName)) {
- configKVFile = configFileService.getConfigYamlFile(namespace, group,
- fileName);
+ configKVFile = configFileService.getConfigYamlFile(namespace, group, fileName);
}
else {
LOGGER.warn(
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigAnnotationProcessor.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigAnnotationProcessor.java
new file mode 100644
index 0000000000000000000000000000000000000000..349799f6957fe49ce6d7f4087d622679102797e4
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigAnnotationProcessor.java
@@ -0,0 +1,105 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.annotation;
+
+import java.lang.reflect.Method;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+
+import com.google.common.base.Preconditions;
+import com.google.common.collect.Sets;
+import com.tencent.cloud.polaris.config.listener.ConfigChangeEvent;
+import com.tencent.cloud.polaris.config.listener.ConfigChangeListener;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.core.Ordered;
+import org.springframework.core.PriorityOrdered;
+import org.springframework.core.annotation.AnnotationUtils;
+import org.springframework.lang.NonNull;
+import org.springframework.util.ReflectionUtils;
+
+import static com.tencent.cloud.polaris.config.listener.PolarisConfigListenerContext.addChangeListener;
+
+/**
+ * {@link PolarisConfigAnnotationProcessor} implementation for spring .
+ * Refer to the Apollo project implementation：
+ *
+ * ApolloAnnotationProcessor
+ * @author Palmer Xu 2022-06-07
+ */
+public class PolarisConfigAnnotationProcessor implements BeanPostProcessor, PriorityOrdered {
+
+ @Override
+ public Object postProcessBeforeInitialization(@NonNull Object bean, @NonNull String beanName)
+ throws BeansException {
+ Class clazz = bean.getClass();
+ for (Method method : findAllMethod(clazz)) {
+ this.processPolarisConfigChangeListener(bean, method);
+ }
+ return bean;
+ }
+
+ @Override
+ public Object postProcessAfterInitialization(@NonNull Object bean, @NonNull String beanName) throws BeansException {
+ return bean;
+ }
+
+ @Override
+ public int getOrder() {
+ return Ordered.LOWEST_PRECEDENCE;
+ }
+
+ private List findAllMethod(Class clazz) {
+ final List res = new LinkedList<>();
+ ReflectionUtils.doWithMethods(clazz, res::add);
+ return res;
+ }
+
+ private void processPolarisConfigChangeListener(final Object bean, final Method method) {
+ PolarisConfigKVFileChangeListener annotation = AnnotationUtils
+ .findAnnotation(method, PolarisConfigKVFileChangeListener.class);
+ if (annotation == null) {
+ return;
+ }
+ Class[] parameterTypes = method.getParameterTypes();
+ Preconditions.checkArgument(parameterTypes.length == 1,
+ "Invalid number of parameters: %s for method: %s, should be 1", parameterTypes.length,
+ method);
+ Preconditions.checkArgument(ConfigChangeEvent.class.isAssignableFrom(parameterTypes[0]),
+ "Invalid parameter type: %s for method: %s, should be ConfigChangeEvent", parameterTypes[0],
+ method);
+
+ ReflectionUtils.makeAccessible(method);
+ String[] annotatedInterestedKeys = annotation.interestedKeys();
+ String[] annotatedInterestedKeyPrefixes = annotation.interestedKeyPrefixes();
+
+ ConfigChangeListener configChangeListener = changeEvent -> ReflectionUtils.invokeMethod(method, bean, changeEvent);
+
+ Set interestedKeys =
+ annotatedInterestedKeys.length > 0 ? Sets.newHashSet(annotatedInterestedKeys) : null;
+ Set interestedKeyPrefixes =
+ annotatedInterestedKeyPrefixes.length > 0 ? Sets.newHashSet(annotatedInterestedKeyPrefixes)
+ : null;
+
+ addChangeListener(configChangeListener, interestedKeys, interestedKeyPrefixes);
+ }
+
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigKVFileChangeListener.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigKVFileChangeListener.java
new file mode 100644
index 0000000000000000000000000000000000000000..142b41bed28dde1d3d68753f2f6c01b447228a05
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/annotation/PolarisConfigKVFileChangeListener.java
@@ -0,0 +1,58 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.annotation;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Configuring the change listener annotation.
+ * Refer to the Apollo project implementation：
+ *
+ * ApolloAnnotationProcessor
+ * @author Palmer Xu 2022-05-31
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+@Documented
+public @interface PolarisConfigKVFileChangeListener {
+
+ /**
+ * The keys interested in the listener, will only be notified if any of the interested keys is changed.
+ *
+ * If neither of {@code interestedKeys} and {@code interestedKeyPrefixes} is specified then the {@code listener} will be notified when any key is changed.
+ * @return interested keys in the listener
+ */
+ String[] interestedKeys() default {};
+
+ /**
+ * The key prefixes that the listener is interested in, will be notified if and only if the changed keys start with anyone of the prefixes.
+ * The prefixes will simply be used to determine whether the {@code listener} should be notified or not using {@code changedKey.startsWith(prefix)}.
+ * e.g. "spring." means that {@code listener} is interested in keys that starts with "spring.", such as "spring.banner", "spring.jpa", etc.
+ * and "application" means that {@code listener} is interested in keys that starts with "application", such as "applicationName", "application.port", etc.
+ *
+ * If neither of {@code interestedKeys} and {@code interestedKeyPrefixes} is specified then the {@code listener} will be notified when whatever key is changed.
+ * @return interested key-prefixed in the listener
+ */
+ String[] interestedKeyPrefixes() default {};
+
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/config/PolarisConfigProperties.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/config/PolarisConfigProperties.java
index 6ddc49f5fcd49622ad21d4facc2cf47c82a5e0bf..a2c9032fe4ccbfb9be31f6559dbfe40fbe2059d7 100644
--- a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/config/PolarisConfigProperties.java
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/config/PolarisConfigProperties.java
@@ -39,6 +39,11 @@ public class PolarisConfigProperties {
*/
private String address;
+ /**
+ * Polaris config grpc port.
+ */
+ private int port = 8093;
+
/**
* Whether to automatically update to the spring context when the configuration file.
* is updated
@@ -66,6 +71,14 @@ public class PolarisConfigProperties {
this.address = address;
}
+ public int getPort() {
+ return port;
+ }
+
+ public void setPort(int port) {
+ this.port = port;
+ }
+
public boolean isAutoRefresh() {
return autoRefresh;
}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpoint.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpoint.java
new file mode 100644
index 0000000000000000000000000000000000000000..eb9e94f5b3052a0d6fd2e35e5d74bd632bbc2854
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpoint.java
@@ -0,0 +1,58 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.endpoint;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.tencent.cloud.polaris.config.adapter.PolarisPropertySource;
+import com.tencent.cloud.polaris.config.adapter.PolarisPropertySourceManager;
+import com.tencent.cloud.polaris.config.config.PolarisConfigProperties;
+
+import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
+import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
+
+/**
+ * Endpoint of polaris config.
+ *
+ * @author shuiqingliu
+ **/
+@Endpoint(id = "polaris-config")
+public class PolarisConfigEndpoint {
+
+ private final PolarisConfigProperties polarisConfigProperties;
+ private final PolarisPropertySourceManager polarisPropertySourceManager;
+
+ public PolarisConfigEndpoint(PolarisConfigProperties polarisConfigProperties, PolarisPropertySourceManager polarisPropertySourceManager) {
+ this.polarisConfigProperties = polarisConfigProperties;
+ this.polarisPropertySourceManager = polarisPropertySourceManager;
+ }
+
+ @ReadOperation
+ public Map polarisConfig() {
+ Map configInfo = new HashMap<>();
+ configInfo.put("PolarisConfigProperties", polarisConfigProperties);
+
+ List propertySourceList = polarisPropertySourceManager.getAllPropertySources();
+ configInfo.put("PolarisPropertySource", propertySourceList);
+
+ return configInfo;
+ }
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpointAutoConfiguration.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpointAutoConfiguration.java
new file mode 100644
index 0000000000000000000000000000000000000000..cb26462ee44d4bdd250f5392df130522fa66f4b7
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/endpoint/PolarisConfigEndpointAutoConfiguration.java
@@ -0,0 +1,49 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.endpoint;
+
+import com.tencent.cloud.polaris.config.adapter.PolarisPropertySourceManager;
+import com.tencent.cloud.polaris.config.config.PolarisConfigProperties;
+
+import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnAvailableEndpoint;
+import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * The AutoConfiguration for Polaris Config's endpoint.
+ *
+ * @author shuiqingliu
+ **/
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnClass(Endpoint.class)
+@ConditionalOnProperty(value = "spring.cloud.polaris.config.enabled",
+ matchIfMissing = true)
+public class PolarisConfigEndpointAutoConfiguration {
+
+ @Bean
+ @ConditionalOnAvailableEndpoint
+ @ConditionalOnMissingBean
+ public PolarisConfigEndpoint polarisConfigEndpoint(PolarisConfigProperties polarisConfigProperties, PolarisPropertySourceManager polarisPropertySourceManager) {
+ return new PolarisConfigEndpoint(polarisConfigProperties, polarisPropertySourceManager);
+ }
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/enums/ConfigFileFormat.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/enums/ConfigFileFormat.java
index 2b7be5774ef147d9a10d46485e65e33f79211fcc..024ad67d0dba1a763e2c88932e044251b8cbd486 100644
--- a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/enums/ConfigFileFormat.java
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/enums/ConfigFileFormat.java
@@ -28,7 +28,7 @@ public enum ConfigFileFormat {
/**
* property format.
*/
- PROPERTY(".property"),
+ PROPERTY(".properties"),
/**
* yaml format.
*/
@@ -48,7 +48,7 @@ public enum ConfigFileFormat {
/**
* text format.
*/
- TEXT(".text"),
+ TEXT(".txt"),
/**
* html format.
*/
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeEvent.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeEvent.java
new file mode 100644
index 0000000000000000000000000000000000000000..119a5ce4c8fcebc6cab0b29a2e75afbc2799b1d4
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeEvent.java
@@ -0,0 +1,88 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.listener;
+
+import java.util.Map;
+import java.util.Set;
+
+import com.tencent.polaris.configuration.api.core.ConfigPropertyChangeInfo;
+
+/**
+ * A change event when config is changed .
+ *
+ * @author Palmer Xu 2022-06-07
+ */
+public final class ConfigChangeEvent {
+
+ /**
+ * all changes keys map.
+ */
+ private final Map changes;
+
+ /**
+ * all interested changed keys.
+ */
+ private final Set interestedChangedKeys;
+
+ /**
+ * Config Change Event Constructor.
+ * @param changes all changes keys map
+ * @param interestedChangedKeys all interested changed keys
+ */
+ public ConfigChangeEvent(Map changes, Set interestedChangedKeys) {
+ this.changes = changes;
+ this.interestedChangedKeys = interestedChangedKeys;
+ }
+
+ /**
+ * Get the keys changed.
+ * @return the list of the keys
+ */
+ public Set changedKeys() {
+ return changes.keySet();
+ }
+
+ /**
+ * Get a specific change instance for the key specified.
+ * @param key the changed key
+ * @return the change instance
+ */
+ public ConfigPropertyChangeInfo getChange(String key) {
+ return changes.get(key);
+ }
+
+ /**
+ * Check whether the specified key is changed .
+ * @param key the key
+ * @return true if the key is changed, false otherwise.
+ */
+ public boolean isChanged(String key) {
+ return changes.containsKey(key);
+ }
+
+ /**
+ * Maybe subclass override this method.
+ *
+ * @return interested and changed keys
+ */
+ public Set interestedChangedKeys() {
+ return interestedChangedKeys;
+ }
+
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListener.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListener.java
new file mode 100644
index 0000000000000000000000000000000000000000..14ab64a321132eb08ac7be2062e5658a9d35680e
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListener.java
@@ -0,0 +1,35 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.listener;
+
+/**
+ * Configuring the change listener interface.
+ *
+ * @author Palmer Xu 2022-05-31
+ */
+public interface ConfigChangeListener {
+
+ /**
+ * Invoked when there is any config change for the namespace.
+ *
+ * @param changeEvent the event for this change
+ */
+ void onChange(ConfigChangeEvent changeEvent);
+
+}
diff --git a/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/PolarisConfigChangeEventListener.java b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/PolarisConfigChangeEventListener.java
new file mode 100644
index 0000000000000000000000000000000000000000..0a55255d533bf34adf78223a93806b34cf4cd5fa
--- /dev/null
+++ b/spring-cloud-starter-tencent-polaris-config/src/main/java/com/tencent/cloud/polaris/config/listener/PolarisConfigChangeEventListener.java
@@ -0,0 +1,111 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * 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.listener;
+
+import java.util.Collection;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import com.google.common.collect.Maps;
+import com.tencent.polaris.configuration.api.core.ConfigPropertyChangeInfo;
+
+import org.springframework.boot.context.event.ApplicationStartedEvent;
+import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
+import org.springframework.context.ApplicationEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.core.env.ConfigurableEnvironment;
+import org.springframework.core.env.Environment;
+import org.springframework.core.env.MutablePropertySources;
+import org.springframework.lang.NonNull;
+
+import static com.tencent.cloud.polaris.config.listener.PolarisConfigListenerContext.fireConfigChange;
+import static com.tencent.cloud.polaris.config.listener.PolarisConfigListenerContext.initialize;
+import static com.tencent.cloud.polaris.config.listener.PolarisConfigListenerContext.merge;
+
+/**
+ * Polaris Config Change Event Listener .
+ *
+ * @author Elve.Xu 2022-06-08
+ */
+public final class PolarisConfigChangeEventListener implements ApplicationListener {
+
+ private static final AtomicBoolean started = new AtomicBoolean();
+
+ /**
+ * Handle an application event.
+ *
+ * @param event the event to respond to
+ */
+ @Override
+ public void onApplicationEvent(@NonNull ApplicationEvent event) {
+
+ // Initialize application all environment properties .
+ if (event instanceof ApplicationStartedEvent && started.compareAndSet(false, true)) {
+ ApplicationStartedEvent applicationStartedEvent = (ApplicationStartedEvent) event;
+ ConfigurableEnvironment environment = applicationStartedEvent.getApplicationContext().getEnvironment();
+ Map ret = loadEnvironmentProperties(environment);
+ if (!ret.isEmpty()) {
+ initialize(ret);
+ }
+ }
+
+ // Process Environment Change Event .
+ if (event instanceof EnvironmentChangeEvent) {
+ EnvironmentChangeEvent environmentChangeEvent = (EnvironmentChangeEvent) event;
+ ConfigurableApplicationContext context = (ConfigurableApplicationContext) environmentChangeEvent.getSource();
+ ConfigurableEnvironment environment = context.getEnvironment();
+ Map ret = loadEnvironmentProperties(environment);
+ Map changes = merge(ret);
+ fireConfigChange(changes.keySet(), Maps.newHashMap(changes));
+ changes.clear();
+ }
+ }
+
+ /**
+ * Try load all application environment config properties .
+ * @param environment application environment instance of {@link Environment}
+ * @return properties
+ */
+ @SuppressWarnings("unchecked")
+ private Map loadEnvironmentProperties(ConfigurableEnvironment environment) {
+ Map ret = Maps.newHashMap();
+ MutablePropertySources sources = environment.getPropertySources();
+ sources.iterator().forEachRemaining(propertySource -> {
+ Object o = propertySource.getSource();
+ if (o instanceof Map) {
+ for (Map.Entry entry : ((Map) o).entrySet()) {
+ String key = entry.getKey();
+ String value = environment.getProperty(key);
+ ret.put(key, value);
+ }
+ }
+ else if (o instanceof Collection) {
+ int count = 0;
+ Collection
+
+[](https://github.com/Tencent/spring-cloud-tencent/wiki)
+[](https://github.com/Tencent/spring-cloud-tencent/actions/workflows/junit_test.yml)
+[](https://search.maven.org/search?q=g:com.tencent.cloud%20AND%20a:spring-cloud-tencent)
+[](https://codecov.io/gh/Tencent/spring-cloud-tencent?branch=main)
+[](https://github.com/Tencent/spring-cloud-tencent/graphs/contributors)
+[](https://opensource.org/licenses/BSD-3-Clause)
[English](./README.md) | 简体中文
@@ -6,76 +13,97 @@
## 介绍
-Spring Cloud Tencent包含了分布式应用微服务开发过程中所需的组件，基于 Spring Cloud 框架的开发者可以使用这些组件快速进行分布式应用的开发。
-
-## 主要功能
-
-* **服务注册与发现**：基于 Spring Cloud Common的标准进行微服务的注册与发现。
-* **服务路由与负载均衡**：基于 Ribbon 的接口标准，提供场景更丰富的动态路由以及负载均衡的能力。
-* **故障节点熔断**：提供故障节点的熔断剔除以及主/被动探测恢复的能力，保证分布式服务的可靠性。
-* **服务限流**：支持微服务被调接入层和网关主动调用的限流功能，保证后台微服务稳定性，可通过控制台动态配置规则，及查看流量监控数据。
-* **元数据传递**: 支持网关及微服务应用之间的自定义元数据传递。
-
-## 如何构建
-
-* [2020.0.x](https://github.com/Tencent/spring-cloud-tencent/tree/2020.0.x)分支对应的是 Spring Cloud 2020.0版本，编译环境最低支持JDK 1.8。
-* [main](https://github.com/Tencent/spring-cloud-tencent/tree/main) 分支对应的是 Spring Cloud Hoxton版本，编译环境最低支持JDK 1.8。
-* [greenwich](https://github.com/Tencent/spring-cloud-tencent/tree/greenwich) 分支对应的是 Spring Cloud Greenwich版本，编译环境最低支持JDK 1.8。
-
-Spring Cloud Tencent 使用 Maven 来构建，最快的使用方式是将本项目 clone 到本地，然后执行以下命令：
-```bash
- ./mvnw install
-```
-执行完毕后，项目将被安装到本地 Maven 仓库。
-
-## 如何使用
-
-### 如何引入依赖
-
-在 dependencyManagement 中添加如下配置，然后在 dependencies 中添加自己所需使用的依赖即可使用。
+Spring Cloud Tencent 是腾讯开源的一站式微服务解决方案。
+
+Spring Cloud Tencent 实现了Spring Cloud 标准微服务 SPI，开发者可以基于 Spring Cloud Tencent 快速开发 Spring Cloud 云原生分布式应用。
+
+Spring Cloud Tencent 的核心依托腾讯开源的一站式服务发现与治理平台 [Polaris](https://github.com/polarismesh/polaris)，实现各种分布式微服务场景。
+
+- [Polaris Github home page](https://github.com/polarismesh/polaris)
+- [Polaris official website](https://polarismesh.cn/)
+
+Spring Cloud Tencent提供的能力包括但不限于：
+
+
+
+- 服务注册和发现
+- 动态配置管理
+- 服务治理
+ - 服务限流
+ - 服务熔断
+ - 服务路由
+ - ...
+- 标签透传
+
+## 体验环境
+
+- 管控台地址： http://14.116.241.63:8080/
+ - 账号：polaris
+ - 密码：polaris
+- 控制面地址： `grpc://183.47.111.80:8091`
+-
+ `spring-cloud-tencent-example` 下 example 地址都默认指向了体验服务地址（`grpc://183.47.111.80:8091`），如果您只是体验 Spring Cloud Tencent，可直接一键运行任何 example。
+## 管控台
+
+
+
+## 使用指南
+
+Spring Cloud Tencent 所有组件都已上传到 Maven 中央仓库，只需要引入依赖即可。
+
+例如：
+
+```` xml
+
+
-更多详细功能，请参考[polaris-java](https://github.com/polarismesh/polaris-java/blob/main/README-zh.md)。
-## 版本号规范
+## License
+The spring-cloud-tencent is licensed under the BSD 3-Clause License. Copyright and license information can be found in the file [LICENSE](LICENSE)
-采取与Spring Cloud大版本号相关的版本策略。
+## Stargazers over time
-项目的版本号格式为 ```大版本号.小版本号.补丁版本号-对应Spring Cloud的大版本号.对应Spring Cloud的小版本号-发布类型``` 的形式。
-大版本号、小版本号、补丁版本号的类型为数字，从 0 开始取值。
-对应Spring Cloud的大版本号为Spring Cloud提供的英文版本号，例如Hoxton、Greenwich等。对应Spring Cloud的小版本号为Spring Cloud给出的小版本号，例如 RS9 等。
-发布类型目前包括正式发布和发布候选版（RC）。在实际的版本号中，正式发布版不额外添加发布类型，发布候选版将添加后缀，并从 RC0 开始。
+如果您对 Spring Cloud Tencent 有兴趣，请关注我们的项目~
-示例：1.2.0-Hoxton.SR9-RC0
+[](https://starchart.cc/Tencent/spring-cloud-tencent)
-## License
-The spring-cloud-tencent is licensed under the BSD 3-Clause License. Copyright and license information can be found in the file [LICENSE](LICENSE)
diff --git a/README.md b/README.md
index b726f862acb05fd861c7efe3ebd03ecdfaf2833f..2c2965a5309b40064858f64ba9e68cfd108cc57a 100644
--- a/README.md
+++ b/README.md
@@ -1,89 +1,109 @@
-# Spring Cloud Tencent
+
-Spring Cloud Tencent uses Maven to construct, the fastest way is to clone project to local files, then execute the following orders:
+- Service registration and discovery
+- Dynamic configuration management
+- Service Governance
+ - Service rate limit
+ - Service circuit breaker
+ - Service routing
+ - ...
+- Label transparent transmission
-```bash
-./mvnw install
-```
+## Demo Environment
-When all the steps are finished, the project will be installed in local Maven repository.
+- Console Address : http://14.116.241.63:8080/
+ - Username: polaris
+ - Password: polaris
+- Server Address: `grpc://183.47.111.80:8091`
-## How to Use
+The example addresses under `spring-cloud-tencent-example` all point to the experience service address (`grpc://183.47.111.80:8091`) by default.
+If you only experience Spring Cloud Tencent, you can run any example directly with one click.
-### How to Introduce Dependency
+## Screenshots
-Add the following configurations in dependencyManagement, then add the dependencies you need.
-At the same time, you need to pay attention to the Spring Cloud version corresponding to Spring Cloud Tencent, and then the corresponding Spring Boot version.
-For example, Spring Cloud Tencent's 1.0.1.Hoxton.SR9 corresponds to the Spring Cloud Hoxton version and requires Spring Boot 2.3.x.
+