apache · fantiq · Jul 28, 2025 · Jul 29, 2025 · Jul 30, 2025 · Aug 1, 2025
diff --git a/...ommon/src/main/java/org/apache/dubbo/common/config/configcenter/DynamicConfiguration.java b/...ommon/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;
+    }
 }
diff --git a/...va/org/apache/dubbo/common/config/configcenter/wrapper/CompositeDynamicConfiguration.java b/...va/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);
+    }
 }
diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/UrlUtils.java b/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
      *

diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ServiceConfig.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ServiceConfig.java
@@ -430,6 +430,11 @@ protected void mapServiceName(
         }
         logger.info("[INSTANCE_REGISTER] [METADATA_REGISTER] Try to register interface application mapping for service "
                 + url.getServiceKey());
+        try {
+            serviceNameMapping.mapping(url);
+            return;
+        } catch (UnsupportedOperationException ignore) {
+        }
         boolean succeeded = false;
         try {
             succeeded = serviceNameMapping.map(url);

diff --git a/...nfig/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java b/...nfig/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java
@@ -383,6 +383,7 @@ public DubboBootstrap metadataReport(Consumer<MetadataReportBuilder> consumerBui
     public DubboBootstrap metadataReport(String id, Consumer<MetadataReportBuilder> consumerBuilder) {
         MetadataReportBuilder metadataReportBuilder = createMetadataReportBuilder(id);
         consumerBuilder.accept(metadataReportBuilder);
+        metadataReport(metadataReportBuilder.build());
         return this;
     }
 
@@ -673,6 +674,7 @@ public DubboBootstrap configCenter(Consumer<ConfigCenterBuilder> consumerBuilder
     public DubboBootstrap configCenter(String id, Consumer<ConfigCenterBuilder> consumerBuilder) {
         ConfigCenterBuilder configCenterBuilder = createConfigCenterBuilder(id);
         consumerBuilder.accept(configCenterBuilder);
+        configCenter(configCenterBuilder.build());
         return this;
     }
 

diff --git a/...g-api/src/main/java/org/apache/dubbo/config/bootstrap/builders/MetadataReportBuilder.java b/...g-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;
     }

diff --git a/...o-config-api/src/main/java/org/apache/dubbo/config/deploy/DefaultApplicationDeployer.java b/...o-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;
@@ -488,6 +489,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 +649,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;
     }
 
@@ -890,19 +901,17 @@ private DynamicConfiguration prepareEnvironment(ConfigCenterConfig configCenter)
             DynamicConfiguration dynamicConfiguration;
             try {
                 dynamicConfiguration = getDynamicConfiguration(configCenter.toUrl());
-            } catch (Exception e) {
-                if (!configCenter.isCheck()) {
+                if (!dynamicConfiguration.isAvailable()) {
                     logger.warn(
-                            CONFIG_FAILED_INIT_CONFIG_CENTER,
-                            "",
-                            "",
-                            "The configuration center failed to initialize",
-                            e);
-                    configCenter.setInitialized(false);
-                    return null;
-                } else {
-                    throw new IllegalStateException(e);
+                            CONFIG_FAILED_INIT_CONFIG_CENTER, "", "", "The configuration center failed to initialize");
+                    if (!configCenter.isCheck()) {
+                        configCenter.setInitialized(true);
+                        // TODO should it `updateExternalConfigMap` when the connection recovery
+                        return dynamicConfiguration;
+                    }
                 }
+            } catch (Exception e) {
+                throw new IllegalStateException(e);
             }
             ApplicationModel applicationModel = getApplicationModel();
 

diff --git a/.../src/main/java/org/apache/dubbo/configcenter/support/nacos/NacosDynamicConfiguration.java b/.../src/main/java/org/apache/dubbo/configcenter/support/nacos/NacosDynamicConfiguration.java
@@ -28,11 +28,13 @@
 import org.apache.dubbo.common.utils.ConcurrentHashMapUtils;
 import org.apache.dubbo.common.utils.MD5Utils;
 import org.apache.dubbo.common.utils.StringUtils;
+import org.apache.dubbo.common.utils.UrlUtils;
 import org.apache.dubbo.metrics.config.event.ConfigCenterEvent;
 import org.apache.dubbo.metrics.event.MetricsEventBus;
 import org.apache.dubbo.rpc.model.ApplicationModel;
 
 import java.util.Map;
+import java.util.Optional;
 import java.util.Properties;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
@@ -103,6 +105,9 @@ private NacosConfigServiceWrapper buildConfigService(URL url) {
         int retryTimes = url.getPositiveParameter(NACOS_RETRY_KEY, 10);
         int sleepMsBetweenRetries = url.getPositiveParameter(NACOS_RETRY_WAIT_KEY, 1000);
         boolean check = url.getParameter(NACOS_CHECK_KEY, true);
+        if (check && !UrlUtils.isCheck(url)) {
+            check = false;
+        }
         ConfigService tmpConfigServices = null;
         try {
             for (int i = 0; i < retryTimes + 1; i++) {
@@ -394,4 +399,12 @@ private ConfigChangeType getChangeType(String configInfo, String oldValue) {
     protected String buildListenerKey(String key, String group) {
         return key + HYPHEN_CHAR + group;
     }
+
+    @Override
+    public boolean isAvailable() {
+        Optional<String> status = Optional.ofNullable(configService)
+                .map(NacosConfigServiceWrapper::getConfigService)
+                .map(ConfigService::getServerStatus);
+        return status.isPresent() && UP.equals(status.get());
+    }
 }
diff --git a/...n/java/org/apache/dubbo/configcenter/support/zookeeper/ZookeeperDynamicConfiguration.java b/...n/java/org/apache/dubbo/configcenter/support/zookeeper/ZookeeperDynamicConfiguration.java
@@ -36,7 +36,6 @@
 
 import org.apache.zookeeper.data.Stat;
 
-import static org.apache.dubbo.common.constants.LoggerCodeConstants.CONFIG_FAILED_CONNECT_REGISTRY;
 import static org.apache.dubbo.common.constants.LoggerCodeConstants.REGISTRY_ZOOKEEPER_EXCEPTION;
 
 public class ZookeeperDynamicConfiguration extends TreePathDynamicConfiguration {
@@ -68,23 +67,6 @@ public class ZookeeperDynamicConfiguration extends TreePathDynamicConfiguration
                 new AbortPolicyWithReport(threadName, url));
 
         zkClient = zookeeperClientManager.connect(url);
-        boolean isConnected = zkClient.isConnected();
-        if (!isConnected) {
-
-            IllegalStateException illegalStateException = new IllegalStateException(
-                    "Failed to connect with zookeeper, pls check if url " + url + " is correct.");
-
-            if (logger != null) {
-                logger.error(
-                        CONFIG_FAILED_CONNECT_REGISTRY,
-                        "configuration server offline",
-                        "",
-                        "Failed to connect with zookeeper",
-                        illegalStateException);
-            }
-
-            throw illegalStateException;
-        }
     }
 
     /**
@@ -174,4 +156,9 @@ protected void doRemoveListener(String pathKey, ConfigurationListener listener)
             zkClient.removeDataListener(pathKey, zookeeperDataListener);
         }
     }
+
+    @Override
+    public boolean isAvailable() {
+        return zkClient != null && zkClient.isConnected();
+    }
 }