feat: Connect spring cloud properties refresh

apollo-client/pom.xml

@@ -93,5 +93,12 @@
 			<scope>test</scope>
 		</dependency>
 		<!-- end of test -->
+		<!-- spring cloud -->
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-context</artifactId>
+			<scope>provided</scope>
+		</dependency>
+		<!-- end of spring cloud -->
 	</dependencies>
 </project>

apollo-client/src/main/java/com/ctrip/framework/apollo/spring/boot/ApolloAutoConfiguration.java

@@ -19,7 +19,10 @@
 import com.ctrip.framework.apollo.spring.config.ConfigPropertySourcesProcessor;
 import com.ctrip.framework.apollo.spring.config.PropertySourcesConstants;
 import com.ctrip.framework.apollo.spring.config.PropertySourcesProcessor;
+import com.ctrip.framework.apollo.spring.config.SpringCloudConfigPropertySourceProcessor;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -30,7 +33,14 @@
 public class ApolloAutoConfiguration {
 
   @Bean
+  @ConditionalOnMissingClass("org.springframework.cloud.context.scope.refresh.RefreshScope")
   public ConfigPropertySourcesProcessor configPropertySourcesProcessor() {
     return new ConfigPropertySourcesProcessor();
   }
+
+  @Bean
+  @ConditionalOnClass(name = {"org.springframework.cloud.context.scope.refresh.RefreshScope"})
+  public SpringCloudConfigPropertySourceProcessor springCloudConfigPropertySourceProcessor() {
+    return new SpringCloudConfigPropertySourceProcessor();
+  }
 }

apollo-client/src/main/java/com/ctrip/framework/apollo/spring/config/PropertySourcesProcessor.java

@@ -16,6 +16,7 @@
  */
 package com.ctrip.framework.apollo.spring.config;
 
+import com.ctrip.framework.apollo.ConfigChangeListener;
 import com.ctrip.framework.apollo.build.ApolloInjector;
 import com.ctrip.framework.apollo.spring.property.AutoUpdateConfigChangeListener;
 import com.ctrip.framework.apollo.spring.util.SpringInjector;
@@ -139,15 +140,17 @@ private void initializeAutoUpdatePropertiesFeature(ConfigurableListableBeanFacto
       return;
     }
 
-    AutoUpdateConfigChangeListener autoUpdateConfigChangeListener = new AutoUpdateConfigChangeListener(
-        environment, beanFactory);
-
     List<ConfigPropertySource> configPropertySources = configPropertySourceFactory.getAllConfigPropertySources();
     for (ConfigPropertySource configPropertySource : configPropertySources) {
-      configPropertySource.addChangeListener(autoUpdateConfigChangeListener);
+      configPropertySource.addChangeListener(configChangeListener(this.environment, beanFactory));
     }
   }
 
+  protected ConfigChangeListener configChangeListener(
+          Environment environment, ConfigurableListableBeanFactory beanFactory) {
+    return new AutoUpdateConfigChangeListener(environment, beanFactory);
+  }
+
   @Override
   public void setEnvironment(Environment environment) {
     //it is safe enough to cast as all known environment is derived from ConfigurableEnvironment

apollo-client/src/main/java/com/ctrip/framework/apollo/spring/config/SpringCloudConfigPropertySourceProcessor.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.ctrip.framework.apollo.spring.config;
+
+import com.ctrip.framework.apollo.ConfigChangeListener;
+import com.ctrip.framework.apollo.spring.property.SpringCloudAutoUpdateConfigChangeListener;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.core.env.Environment;
+
+public class SpringCloudConfigPropertySourceProcessor extends ConfigPropertySourcesProcessor
+        implements ApplicationContextAware {
+
+    private ApplicationContext applicationContext;
+
+    @Override
+    protected ConfigChangeListener configChangeListener(
+            Environment environment, ConfigurableListableBeanFactory beanFactory) {
+        return new SpringCloudAutoUpdateConfigChangeListener(
+                environment, beanFactory, applicationContext);
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+}

apollo-client/src/main/java/com/ctrip/framework/apollo/spring/property/SpringCloudAutoUpdateConfigChangeListener.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 2022 Apollo Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.ctrip.framework.apollo.spring.property;
+
+import com.ctrip.framework.apollo.model.ConfigChangeEvent;
+import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
+import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
+import org.springframework.cloud.context.scope.refresh.RefreshScope;
+import org.springframework.context.ApplicationContext;
+import org.springframework.core.env.Environment;
+
+public class SpringCloudAutoUpdateConfigChangeListener extends AutoUpdateConfigChangeListener {
+  final ApplicationContext applicationContext;
+
+  public SpringCloudAutoUpdateConfigChangeListener(
+      Environment environment,
+      ConfigurableListableBeanFactory beanFactory,
+      ApplicationContext applicationContext) {
+    super(environment, beanFactory);
+    this.applicationContext = applicationContext;
+  }
+
+  @Override
+  public void onChange(ConfigChangeEvent changeEvent) {
+    super.onChange(changeEvent);
+    adapterSpringCloud(changeEvent);
+  }
+
+  private void adapterSpringCloud(ConfigChangeEvent changeEvent) {
+    RefreshScope refreshScope = applicationContext.getBean(RefreshScope.class);
+    if (refreshScope != null) {
+      refreshScope.refreshAll();
+    }
+    applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys()));
+  }
+}