Replace applicationContext.getApplicationName() with applicationContext.getEnvironment().getProperty("spring.application.name")

This commit is contained in:
hongqiaowei
2022-03-11 09:48:51 +08:00
parent 5bc5112794
commit 3eb848621d
2 changed files with 5 additions and 2 deletions

View File

@@ -143,6 +143,7 @@ public class RegistryCenterService implements ApplicationListener<ContextRefresh
prev.getFizzServiceRegistration().deregister();
}
rc.initFizzServiceRegistration(applicationContext);
rc.getFizzServiceRegistration().register();
}
} catch (Throwable t) {
log.error("update registry center error, {}", message, t);

View File

@@ -22,6 +22,7 @@ import com.alibaba.cloud.nacos.registry.NacosRegistration;
import com.alibaba.cloud.nacos.registry.NacosServiceRegistry;
import com.alibaba.nacos.api.naming.NamingService;
import org.springframework.context.ApplicationContext;
import org.springframework.core.env.Environment;
import we.util.Consts;
import we.util.JacksonUtils;
import we.util.PropertiesUtils;
@@ -58,11 +59,12 @@ public abstract class FizzNacosHelper {
if (fizzNacosProperties.getId() == null) {
fizzNacosProperties.setId(fizzNacosProperties.getServerAddr());
}
Environment env = applicationContext.getEnvironment();
if (fizzNacosProperties.getService() == null) {
fizzNacosProperties.setService(applicationContext.getApplicationName());
fizzNacosProperties.setService(env.getProperty("spring.application.name"));
}
if (fizzNacosProperties.getPort() == -1) {
fizzNacosProperties.setPort(Integer.parseInt(applicationContext.getEnvironment().getProperty("server.port")));
fizzNacosProperties.setPort(Integer.parseInt(env.getProperty("server.port")));
}
fizzNacosProperties.setNamingLoadCacheAtStart("false");