自动刷新
<dependencies>
<!--spring-cloud(自动刷新)-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-context</artifactId>
<version>2.0.2.RELEASE</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${
spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
package com.dyn.basepro.config.apollo;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
/**
*@description: ApolloConfig
*@author: dyn
*@create: 2020-03-30 21:00
*/
@Data
@Configuration
@RefreshScope
public class ApolloConfig {
@Value("${server.port:}")
String serverPort;
@Value("${server.servlet.context-path:}")
String contextPath;
@Value("${spring.application.name:}")
String applicationName;
@Value("${spring.profiles.active:}")
String profilesActive;
@Value("${spring.redis.host:}")
String redisHost;
@Value("${spring.redis.password:}")
String redisPassword;
@Value("${spring.redis.database:}")
String redisDatabase;
@Value("${spring.redis.port:}")
String redisPort;
@Value("${spring.redis.timeout:}")
String redisTimeout;
@Value("${spring.sleuth.sampler.probability:}")
String samplerProbability;
@Value("${spring.zipkin.base-url:}")
String zipkinBaseUrl;
@Value("${eureka.client.service-url.defaultZone:}")
String eurekaDefaultZone;
}
package com.dyn.basepro.frame.apollo;
import com.ctrip.framework.apollo.model.ConfigChangeEvent;
import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
import org.springframework.cloud.context.scope.refresh.RefreshScope;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
import java.util.Set;
/**
*@description: apollo配置中心自动刷新
*@author: dyn
*@create: 2020-03-30 21:01
*/
@Component
public class ApolloRefresh implements ApplicationContextAware {
private ApplicationContext applicationContext;
@Autowired
private RefreshScope refreshScope;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
@ApolloConfigChangeListener
public void refresh(ConfigChangeEvent event) {
Set<String> changedKeys = event.changedKeys();
if (changedKeys != null && changedKeys.size() != 0) {
this.applicationContext.publishEvent(new EnvironmentChangeEvent(changedKeys));
this.refreshScope.refreshAll();
}
}
// 刷新bean
@RefreshScope
@Bean
public DataSource dataSource(DataSourceProperties dataSourceProperties) {
return null;
}
}