feature:support spring cloud configData

pull/451/head
wulingxiao 3 years ago
parent ab96eeb4a7
commit 77c3db0724

@ -6,3 +6,4 @@
- [Feature: add rate limit filter debug log](https://github.com/Tencent/spring-cloud-tencent/pull/437) - [Feature: add rate limit filter debug log](https://github.com/Tencent/spring-cloud-tencent/pull/437)
- [Add configurable heartbeat interval support](https://github.com/Tencent/spring-cloud-tencent/pull/444) - [Add configurable heartbeat interval support](https://github.com/Tencent/spring-cloud-tencent/pull/444)
- [feat:enhance Feign and RestTemplate and support Polaris monitor.](https://github.com/Tencent/spring-cloud-tencent/pull/447) - [feat:enhance Feign and RestTemplate and support Polaris monitor.](https://github.com/Tencent/spring-cloud-tencent/pull/447)
- [Feature: support spring cloud config data.](https://github.com/Tencent/spring-cloud-tencent/pull/451)

@ -121,7 +121,7 @@ public class PolarisConfigDataLoader implements ConfigDataLoader<PolarisConfigDa
} }
// load config data // load config data
if (StringUtils.hasText(resource.getFileName())) { if (StringUtils.hasText(resource.getFileName())) {
log.info("loading config data config file,group:" + resource.getGroupName() + "file:" + resource.getFileName()); log.info("loading config data config file, group:" + resource.getGroupName() + " file: " + resource.getFileName());
this.puller.initCustomPolarisConfigFile(compositePropertySource, configFileGroup(resource)); this.puller.initCustomPolarisConfigFile(compositePropertySource, configFileGroup(resource));
} }
return compositePropertySource; return compositePropertySource;

@ -188,9 +188,13 @@ public class PolarisConfigDataLocationResolver implements
String serviceName = loadPolarisConfigProperties(resolverContext, String serviceName = loadPolarisConfigProperties(resolverContext,
String.class, "spring.application.name"); String.class, "spring.application.name");
String groupName = StringUtils.isBlank(groupFileName) ? EMPTY_STRING : parseGroupName(groupFileName, serviceName); String groupName = StringUtils.isBlank(groupFileName) ? EMPTY_STRING : parseGroupName(groupFileName, serviceName);
log.info("group from configDataLocation is" + groupName); if (StringUtils.isNotBlank(groupName)) {
log.info("group from configDataLocation is " + groupName);
}
String fileName = StringUtils.isBlank(groupFileName) ? EMPTY_STRING : parseFileName(groupFileName); String fileName = StringUtils.isBlank(groupFileName) ? EMPTY_STRING : parseFileName(groupFileName);
log.info("file from configDataLocation is" + fileName); if (StringUtils.isNotBlank(fileName)) {
log.info("file from configDataLocation is " + fileName);
}
PolarisConfigDataResource polarisConfigDataResource = new PolarisConfigDataResource( PolarisConfigDataResource polarisConfigDataResource = new PolarisConfigDataResource(
polarisConfigProperties, polarisConfigProperties,
polarisContextProperties, polarisContextProperties,

@ -5,7 +5,6 @@ import org.junit.runner.RunWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.junit.MockitoJUnitRunner; import org.mockito.junit.MockitoJUnitRunner;
import org.springframework.boot.ConfigurableBootstrapContext;
import org.springframework.boot.context.config.ConfigDataLocation; import org.springframework.boot.context.config.ConfigDataLocation;
import org.springframework.boot.context.config.ConfigDataLocationResolverContext; import org.springframework.boot.context.config.ConfigDataLocationResolverContext;
import org.springframework.boot.context.properties.bind.Binder; import org.springframework.boot.context.properties.bind.Binder;
@ -33,13 +32,9 @@ public class PolarisConfigDataLocationResolverTest {
private final Binder environmentBinder = Binder.get(this.environment); private final Binder environmentBinder = Binder.get(this.environment);
@Mock
private ConfigurableBootstrapContext bootstrapContext;
@Test @Test
public void testIsResolvable() { public void testIsResolvable() {
when(context.getBinder()).thenReturn(environmentBinder); when(context.getBinder()).thenReturn(environmentBinder);
when(context.getBootstrapContext()).thenReturn(bootstrapContext);
assertThat( assertThat(
this.resolver.isResolvable(this.context, ConfigDataLocation.of("configserver:"))) this.resolver.isResolvable(this.context, ConfigDataLocation.of("configserver:")))
.isFalse(); .isFalse();
@ -55,7 +50,6 @@ public class PolarisConfigDataLocationResolverTest {
public void unEnabledPolarisConfigData() { public void unEnabledPolarisConfigData() {
environment.setProperty("spring.cloud.polaris.config.enabled", "false"); environment.setProperty("spring.cloud.polaris.config.enabled", "false");
when(context.getBinder()).thenReturn(environmentBinder); when(context.getBinder()).thenReturn(environmentBinder);
when(context.getBootstrapContext()).thenReturn(bootstrapContext);
assertThat( assertThat(
this.resolver.isResolvable(this.context, ConfigDataLocation.of("polaris:"))) this.resolver.isResolvable(this.context, ConfigDataLocation.of("polaris:")))
.isFalse(); .isFalse();

Loading…
Cancel
Save