study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

fix

Browse Source
This commit is contained in:
yuhuangbin 2020-09-09 14:55:39 +08:00
parent da9a57ddf8
commit b81f998f40
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-discovery/src/main/java/com/alibaba/cloud/nacos/NacosDiscoveryProperties.java
View File

@ -23,6 +23,7 @@ import java.util.Enumeration;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.Optional;
import java.util.Properties; import java.util.Properties;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
@ -215,7 +216,7 @@ public class NacosDiscoveryProperties {
private NacosServiceManager nacosServiceManager; private NacosServiceManager nacosServiceManager;
@Autowired @Autowired
private NacosAutoServiceRegistration nacosAutoServiceRegistration; private Optional<NacosAutoServiceRegistration> nacosAutoServiceRegistrationOptional;
@PostConstruct @PostConstruct
public void init() throws Exception { public void init() throws Exception {
@ -266,11 +267,13 @@ public class NacosDiscoveryProperties {
this.overrideFromEnv(environment); this.overrideFromEnv(environment);
nacosAutoServiceRegistrationOptional.ifPresent(nacosAutoServiceRegistration -> {
if (nacosServiceManager.isNacosDiscoveryInfoChanged(this)) { if (nacosServiceManager.isNacosDiscoveryInfoChanged(this)) {
nacosAutoServiceRegistration.stop(); nacosAutoServiceRegistration.stop();
nacosServiceManager.reBuildNacosService(getNacosProperties()); nacosServiceManager.reBuildNacosService(getNacosProperties());
nacosAutoServiceRegistration.start(); nacosAutoServiceRegistration.start();
} }
});
} }
public String getEndpoint() { public String getEndpoint() {