import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void keysComputedWhenChangesInExternalProperties() throws Exception {
	this.context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF)
			.properties("spring.cloud.bootstrap.name:none").run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(this.context);
	TestPropertyValues
			.of("spring.cloud.bootstrap.sources="
					+ ExternalPropertySourceLocator.class.getName())
			.applyTo(this.context.getEnvironment(), Type.MAP, "defaultProperties");
	ContextRefresher contextRefresher = new ContextRefresher(this.context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	Collection<String> keys = endpoint.refresh();
	assertTrue("Wrong keys: " + keys, keys.contains("external.message"));
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void springMainSourcesEmptyInRefreshCycle() throws Exception {
	this.context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF)
			.properties("spring.cloud.bootstrap.name:none").run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(this.context);
	// spring.main.sources should be empty when the refresh cycle starts (we don't
	// want any config files from the application context getting into the one used to
	// construct the environment for refresh)
	TestPropertyValues
			.of("spring.main.sources="
					+ ExternalPropertySourceLocator.class.getName())
			.applyTo(this.context);
	ContextRefresher contextRefresher = new ContextRefresher(this.context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	Collection<String> keys = endpoint.refresh();
	assertFalse("Wrong keys: " + keys, keys.contains("external.message"));
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
/**
 * Provides the action to execute when the configuration changes.
 */
@Bean
@ConditionalOnMissingBean
public ConfigurationUpdateStrategy configurationUpdateStrategy(ConfigReloadProperties properties, ConfigurableApplicationContext ctx, RestartEndpoint restarter, ContextRefresher refresher) {
    switch (properties.getStrategy()) {
    case RESTART_CONTEXT:
        return new ConfigurationUpdateStrategy(properties.getStrategy().name(), restarter::restart);
    case REFRESH:
        return new ConfigurationUpdateStrategy(properties.getStrategy().name(), refresher::refresh);
    case SHUTDOWN:
        return new ConfigurationUpdateStrategy(properties.getStrategy().name(), ctx::close);
    }
    throw new IllegalStateException("Unsupported configuration update strategy: " + properties.getStrategy());
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
@Ignore // TODO: replicate problem
public void serviceMatcherIdIsConstantAfterRefresh() {
	this.context = SpringApplication.run(new Class[] { RefreshConfig.class, },
			new String[] {});
	String originalServiceId = this.context.getBean(ServiceMatcher.class)
			.getServiceId();
	this.context.getBean(ContextRefresher.class).refresh();
	String newServiceId = this.context.getBean(ServiceMatcher.class).getServiceId();
	assertThat(newServiceId).isEqualTo(originalServiceId);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
@ConditionalOnBean(ContextRefresher.class)
@ConditionalOnEnabledEndpoint
@ConditionalOnMissingBean
public RefreshEndpoint refreshEndpoint(ContextRefresher contextRefresher) {
	return new RefreshEndpoint(contextRefresher);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void keysComputedWhenAdded() throws Exception {
	this.context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF)
			.properties("spring.cloud.bootstrap.name:none").run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(this.context);
	context.getEnvironment().setActiveProfiles("local");
	ContextRefresher contextRefresher = new ContextRefresher(this.context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	Collection<String> keys = endpoint.refresh();
	assertTrue("Wrong keys: " + keys, keys.contains("added"));
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void keysComputedWhenOveridden() throws Exception {
	this.context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF)
			.properties("spring.cloud.bootstrap.name:none").run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(this.context);
	context.getEnvironment().setActiveProfiles("override");
	ContextRefresher contextRefresher = new ContextRefresher(this.context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	Collection<String> keys = endpoint.refresh();
	assertTrue("Wrong keys: " + keys, keys.contains("message"));
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void eventsPublishedInOrder() throws Exception {
	this.context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF).run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(this.context);
	ContextRefresher contextRefresher = new ContextRefresher(this.context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	Empty empty = this.context.getBean(Empty.class);
	endpoint.refresh();
	int after = empty.events.size();
	assertEquals("Shutdown hooks not cleaned on refresh", 2, after);
	assertTrue(empty.events.get(0) instanceof EnvironmentChangeEvent);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Test
public void shutdownHooksCleaned() {
	ConfigurableApplicationContext context = new SpringApplicationBuilder(Empty.class)
			.web(WebApplicationType.NONE).bannerMode(Mode.OFF).run();
	RefreshScope scope = new RefreshScope();
	scope.setApplicationContext(context);
	ContextRefresher contextRefresher = new ContextRefresher(context, scope);
	RefreshEndpoint endpoint = new RefreshEndpoint(contextRefresher);
	int count = countShutdownHooks();
	endpoint.refresh();
	int after = countShutdownHooks();
	assertEquals("Shutdown hooks not cleaned on refresh", count, after);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
public ContextRefresher contextRefresher(ConfigurableApplicationContext context,
		RefreshScope scope) {
	return new ContextRefresher(context, scope);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
public RefreshListener(ContextRefresher contextRefresher) {
	this.contextRefresher = contextRefresher;
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
@ConditionalOnProperty(value = "spring.cloud.bus.refresh.enabled", matchIfMissing = true)
public RefreshListener refreshListener(ContextRefresher contextRefresher) {
	return new RefreshListener(contextRefresher);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public ContextRefresher contextRefresher(ConfigurableApplicationContext context,
		RefreshScope scope) {
	return new ContextRefresher(context, scope);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
public RefreshEventListener refreshEventListener(
		ContextRefresher contextRefresher) {
	return new RefreshEventListener(contextRefresher);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
public RefreshEndpoint(ContextRefresher contextRefresher) {
	this.contextRefresher = contextRefresher;
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
public RefreshEventListener(ContextRefresher refresh) {
	this.refresh = refresh;
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
@Bean
public ConfigClientWatch configClientWatch(ContextRefresher contextRefresher) {
	return new ConfigClientWatch(contextRefresher);
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
public ConfigClientWatch(ContextRefresher refresher) {
	this.refresher = refresher;
}
 

import org.springframework.cloud.context.refresh.ContextRefresher; //导入依赖的package包/类
/**
 * Constructor
 *
 * @param refresher  ContextRefresher
 * @param configPath String
 */
public CloudConfigRefreshService(ContextRefresher refresher, @Value("${k8s.config.path}") String configPath) {
    this.refresher = refresher;
    this.configPath = configPath;
}