Feat support check for config-center and metadata-center

dubbo-common/src/main/java/org/apache/dubbo/common/config/configcenter/DynamicConfiguration.java

@@ -222,4 +222,12 @@ static String getRuleKey(URL url) {
     default boolean removeConfig(String key, String group) {
         return true;
     }
+
+    /**
+     * check the config center client connection available
+     * @return the connection status
+     */
+    default boolean isAvailable() {
+        return true;
+    }
 }

dubbo-common/src/main/java/org/apache/dubbo/common/config/configcenter/wrapper/CompositeDynamicConfiguration.java

@@ -120,4 +120,9 @@ private Object iterateConfigOperation(Function<DynamicConfiguration, Object> fun
         }
         return value;
     }
+
+    @Override
+    public boolean isAvailable() {
+        return !configurations.isEmpty() && configurations.stream().anyMatch(DynamicConfiguration::isAvailable);
+    }
 }

dubbo-common/src/main/java/org/apache/dubbo/common/utils/UrlUtils.java

@@ -35,6 +35,7 @@
 
 import static java.util.Collections.emptyMap;
 import static org.apache.dubbo.common.constants.CommonConstants.ANY_VALUE;
+import static org.apache.dubbo.common.constants.CommonConstants.CHECK_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.CLASSIFIER_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.COMMA_SPLIT_PATTERN;
 import static org.apache.dubbo.common.constants.CommonConstants.CONSUMER;
@@ -522,6 +523,10 @@ public static boolean isRegistry(URL url) {
                 || (url.getProtocol() != null && url.getProtocol().endsWith("-registry-protocol"));
     }
 
+    public static boolean isCheck(URL url) {
+        return url.getParameter(CHECK_KEY, true) && url.getPort() != 0;
+    }
+
     /**
      * The specified {@link URL} is service discovery registry type or not
      *

dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ServiceConfig.java

@@ -26,7 +26,6 @@
 import org.apache.dubbo.common.logger.ErrorTypeAwareLogger;
 import org.apache.dubbo.common.logger.LoggerFactory;
 import org.apache.dubbo.common.threadpool.manager.ExecutorRepository;
-import org.apache.dubbo.common.threadpool.manager.FrameworkExecutorRepository;
 import org.apache.dubbo.common.url.component.ServiceConfigURL;
 import org.apache.dubbo.common.utils.ClassUtils;
 import org.apache.dubbo.common.utils.CollectionUtils;
@@ -71,7 +70,6 @@
 import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
@@ -400,11 +398,7 @@ protected void exported() {
         exportedURLs.forEach(url -> {
             if (url.getParameter(SERVICE_NAME_MAPPING_KEY, false)) {
                 ServiceNameMapping serviceNameMapping = ServiceNameMapping.getDefaultExtension(getScopeModel());
-                ScheduledExecutorService scheduledExecutor = getScopeModel()
-                        .getBeanFactory()
-                        .getBean(FrameworkExecutorRepository.class)
-                        .getSharedScheduledExecutor();
-                mapServiceName(url, serviceNameMapping, scheduledExecutor);
+                mapServiceName(url, serviceNameMapping);
             }
         });
 
@@ -423,49 +417,24 @@ public boolean hasRegistrySpecified() {
                         .getRegistries());
     }
 
-    protected void mapServiceName(
-            URL url, ServiceNameMapping serviceNameMapping, ScheduledExecutorService scheduledExecutor) {
+    protected void mapServiceName(URL url, ServiceNameMapping serviceNameMapping) {
         if (!exported) {
             return;
         }
         logger.info("[INSTANCE_REGISTER] [METADATA_REGISTER] Try to register interface application mapping for service "
                 + url.getServiceKey());
-        boolean succeeded = false;
-        try {
-            succeeded = serviceNameMapping.map(url);
-            if (succeeded) {
-                logger.info(
-                        "[INSTANCE_REGISTER][METADATA_REGISTER] Successfully registered interface application mapping for service "
-                                + url.getServiceKey());
-            } else {
-                logger.error(
-                        CONFIG_SERVER_DISCONNECTED,
-                        "configuration server disconnected",
-                        "",
-                        "[INSTANCE_REGISTER] [METADATA_REGISTER] Failed register interface application mapping for service "
-                                + url.getServiceKey());
-            }
-        } catch (Exception e) {
+        if (serviceNameMapping.map(url)) {
+            logger.info(
+                    "[INSTANCE_REGISTER][METADATA_REGISTER] Successfully registered interface application mapping for service "
+                            + url.getServiceKey());
+        } else {
             logger.error(
                     CONFIG_SERVER_DISCONNECTED,
                     "configuration server disconnected",
                     "",
                     "[INSTANCE_REGISTER] [METADATA_REGISTER] Failed register interface application mapping for service "
-                            + url.getServiceKey(),
-                    e);
+                            + url.getServiceKey());
         }
-        if (!succeeded && serviceNameMapping.hasValidMetadataCenter()) {
-            scheduleToMapping(scheduledExecutor, serviceNameMapping, url);
-        }
-    }
-
-    private void scheduleToMapping(
-            ScheduledExecutorService scheduledExecutor, ServiceNameMapping serviceNameMapping, URL url) {
-        Integer mappingRetryInterval = getApplication().getMappingRetryInterval();
-        scheduledExecutor.schedule(
-                () -> mapServiceName(url, serviceNameMapping, scheduledExecutor),
-                mappingRetryInterval == null ? 5000 : mappingRetryInterval,
-                TimeUnit.MILLISECONDS);
     }
 
     private void checkAndUpdateSubConfigs() {

dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java

@@ -383,7 +383,7 @@ public DubboBootstrap metadataReport(Consumer<MetadataReportBuilder> consumerBui
     public DubboBootstrap metadataReport(String id, Consumer<MetadataReportBuilder> consumerBuilder) {
         MetadataReportBuilder metadataReportBuilder = createMetadataReportBuilder(id);
         consumerBuilder.accept(metadataReportBuilder);
-        return this;
+        return metadataReport(metadataReportBuilder.build());
     }
 
     public DubboBootstrap metadataReport(MetadataReportConfig metadataReportConfig) {
@@ -673,7 +673,7 @@ public DubboBootstrap configCenter(Consumer<ConfigCenterBuilder> consumerBuilder
     public DubboBootstrap configCenter(String id, Consumer<ConfigCenterBuilder> consumerBuilder) {
         ConfigCenterBuilder configCenterBuilder = createConfigCenterBuilder(id);
         consumerBuilder.accept(configCenterBuilder);
-        return this;
+        return configCenter(configCenterBuilder.build());
     }
 
     public DubboBootstrap configCenter(ConfigCenterConfig configCenterConfig) {

dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/builders/MetadataReportBuilder.java

@@ -77,6 +77,8 @@ public class MetadataReportBuilder extends AbstractBuilder<MetadataReportConfig,
      */
     private Boolean check;
 
+    private Boolean reportDefinition;
+
     public static MetadataReportBuilder newBuilder() {
         return new MetadataReportBuilder();
     }
@@ -141,6 +143,11 @@ public MetadataReportBuilder check(Boolean check) {
         return getThis();
     }
 
+    public MetadataReportBuilder reportDefinition(Boolean reportDefinition) {
+        this.reportDefinition = reportDefinition;
+        return getThis();
+    }
+
     @Override
     public MetadataReportConfig build() {
         MetadataReportConfig metadataReport = new MetadataReportConfig();
@@ -157,6 +164,7 @@ public MetadataReportConfig build() {
         metadataReport.setCycleReport(cycleReport);
         metadataReport.setSyncReport(syncReport);
         metadataReport.setCheck(check);
+        metadataReport.setReportDefinition(reportDefinition);
 
         return metadataReport;
     }

dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/deploy/DefaultApplicationDeployer.java

@@ -93,6 +93,7 @@
 
 import static java.lang.String.format;
 import static org.apache.dubbo.common.config.ConfigurationUtils.parseProperties;
+import static org.apache.dubbo.common.constants.CommonConstants.CHECK_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.REGISTRY_SPLIT_PATTERN;
 import static org.apache.dubbo.common.constants.CommonConstants.REMOTE_METADATA_STORAGE_TYPE;
 import static org.apache.dubbo.common.constants.LoggerCodeConstants.COMMON_METRICS_COLLECTOR_EXCEPTION;
@@ -118,6 +119,8 @@ public class DefaultApplicationDeployer extends AbstractDeployer<ApplicationMode
     private static final ErrorTypeAwareLogger logger =
             LoggerFactory.getErrorTypeAwareLogger(DefaultApplicationDeployer.class);
 
+    private static final String REFRESH_ERR = "Refresh instance and metadata error.";
+
     private final ApplicationModel applicationModel;
 
     private final ConfigManager configManager;
@@ -488,6 +491,11 @@ private ConfigCenterConfig registryAsConfigCenter(RegistryConfig registryConfig)
             cc.setTimeout(registryConfig.getTimeout().longValue());
         }
         cc.setHighestPriority(false);
+        // use registry check option
+        if (Boolean.FALSE == registryConfig.isCheck()
+                || !Boolean.parseBoolean(cc.getParameters().getOrDefault(CHECK_KEY, "true"))) {
+            cc.setCheck(false);
+        }
         return cc;
     }
 
@@ -643,6 +651,11 @@ private MetadataReportConfig registryAsMetadataCenter(
         if (metadataReportConfig.getTimeout() == null) {
             metadataReportConfig.setTimeout(registryConfig.getTimeout());
         }
+        // use registry check option
+        if (Boolean.FALSE == registryConfig.isCheck()
+                || !Boolean.parseBoolean(metadataReportConfig.getParameters().getOrDefault(CHECK_KEY, "true"))) {
+            metadataReportConfig.setCheck(false);
+        }
         return metadataReportConfig;
     }
 
@@ -886,7 +899,6 @@ private DynamicConfiguration prepareEnvironment(ConfigCenterConfig configCenter)
             if (!configCenter.checkOrUpdateInitialized(true)) {
                 return null;
             }
-
             DynamicConfiguration dynamicConfiguration;
             try {
                 dynamicConfiguration = getDynamicConfiguration(configCenter.toUrl());
@@ -904,6 +916,24 @@ private DynamicConfiguration prepareEnvironment(ConfigCenterConfig configCenter)
                     throw new IllegalStateException(e);
                 }
             }
+            if (dynamicConfiguration == null || !dynamicConfiguration.isAvailable()) {
+                if (configCenter.isCheck()) {
+                    throw new IllegalStateException("The configuration center is not available");
+                } else if (dynamicConfiguration == null) {
+                    logger.warn(
+                            CONFIG_FAILED_INIT_CONFIG_CENTER,
+                            "",
+                            "",
+                            "The configuration center failed to initialize, dynamicConfiguration is null.");
+                } else {
+                    logger.warn(
+                            CONFIG_FAILED_INIT_CONFIG_CENTER,
+                            "",
+                            "",
+                            "The configuration center initialize successfully, but connection is not available.");
+                }
+                return dynamicConfiguration;
+            }
             ApplicationModel applicationModel = getApplicationModel();
 
             if (StringUtils.isNotEmpty(configCenter.getConfigFile())) {
@@ -1034,12 +1064,7 @@ public synchronized void registerServiceInstance() {
                                     }
                                 } catch (Exception e) {
                                     if (!applicationModel.isDestroyed()) {
-                                        logger.error(
-                                                CONFIG_REFRESH_INSTANCE_ERROR,
-                                                "",
-                                                "",
-                                                "Refresh instance and metadata error.",
-                                                e);
+                                        logger.error(CONFIG_REFRESH_INSTANCE_ERROR, "", "", REFRESH_ERR, e);
                                     }
                                 }
                             },
@@ -1056,7 +1081,7 @@ public void refreshServiceInstance() {
             try {
                 ServiceInstanceMetadataUtils.refreshMetadataAndInstance(applicationModel);
             } catch (Exception e) {
-                logger.error(CONFIG_REFRESH_INSTANCE_ERROR, "", "", "Refresh instance and metadata error.", e);
+                logger.error(CONFIG_REFRESH_INSTANCE_ERROR, "", "", REFRESH_ERR, e);
             }
         }
     }
@@ -1345,7 +1370,7 @@ private void onStarted() {
                 ServiceInstanceMetadataUtils.refreshMetadataAndInstance(applicationModel);
             }
         } catch (Exception e) {
-            logger.error(CONFIG_REFRESH_INSTANCE_ERROR, "", "", "Refresh instance and metadata error.", e);
+            logger.error(CONFIG_REFRESH_INSTANCE_ERROR, "", "", REFRESH_ERR, e);
         }
     }