natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge c627b92dc7 into 3c4247eb58

This commit is contained in:
Ken Liu 2024-06-20 16:52:34 +08:00 committed by GitHub
parent 3c4247eb58 c627b92dc7
commit a7c4a02fdd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/registry/ZoneAwareClusterInvoker.java
View File

@ -19,6 +19,7 @@ package org.apache.dubbo.rpc.cluster.support.registry;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.common.logger.Logger;
import org.apache.dubbo.common.logger.LoggerFactory;
import org.apache.dubbo.common.utils.CollectionUtils;
import org.apache.dubbo.common.utils.StringUtils;
import org.apache.dubbo.rpc.Invocation;
import org.apache.dubbo.rpc.Invoker;
@ -32,6 +33,7 @@ import org.apache.dubbo.rpc.cluster.LoadBalance;
import org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
import static org.apache.dubbo.common.constants.CommonConstants.PREFERRED_KEY;
@ -60,6 +62,12 @@ public class ZoneAwareClusterInvoker<T> extends AbstractClusterInvoker<T> {
if (loader.hasExtension("default")) {
zoneDetector = loader.getExtension("default");
}
if (zoneDetector == null) {
Set<ZoneDetector> zoneDetectors = loader.getSupportedExtensionInstances();
if (CollectionUtils.isNotEmpty(zoneDetectors)) {
zoneDetector = zoneDetectors.iterator().next();
}
}
}
@Override