Fix the problem of slow service startup. (#1036)
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/registry/mapping/impl/NacosServiceMapping.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/registry/mapping/impl/NacosServiceMapping.java
index a7d25c9..9633ebb 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/registry/mapping/impl/NacosServiceMapping.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/registry/mapping/impl/NacosServiceMapping.java
@@ -40,7 +40,6 @@
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import static com.alibaba.nacos.api.PropertyKeyConst.NAMING_LOAD_CACHE_AT_START;
import static org.apache.dubbo.common.constants.RegistryConstants.CONFIGURATORS_CATEGORY;
@@ -94,15 +93,6 @@
@Override
public void listenerAll() {
-
- try {
- anyServices = getAllServiceNames().stream().filter(this::filterApplication).collect(Collectors.toSet());
- } catch (Exception e) {
- LOGGER.error("Get nacos all services fail ", e);
- }
- for (String service : anyServices) {
- notifyMappingChangedEvent(service);
- }
scheduledExecutorService.scheduleAtFixedRate(() -> {
try {
Set<String> serviceNames = getAllServiceNames();
@@ -115,7 +105,7 @@
LOGGER.error("Get nacos all services fail ", e);
}
- }, LOOKUP_INTERVAL, LOOKUP_INTERVAL, TimeUnit.SECONDS);
+ }, 0, LOOKUP_INTERVAL, TimeUnit.SECONDS);
}
private Set<String> getAllServiceNames() throws NacosException {
