From 1b8973d874986a1ee7d70f1c7841f3556f069f59 Mon Sep 17 00:00:00 2001 From: fangjian0423 Date: Thu, 5 Sep 2019 15:20:48 +0800 Subject: [PATCH] fix service instance select of dubbo spring cloud --- .../repository/DubboServiceMetadataRepository.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/metadata/repository/DubboServiceMetadataRepository.java b/spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/metadata/repository/DubboServiceMetadataRepository.java index 048635d9..032b1fae 100644 --- a/spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/metadata/repository/DubboServiceMetadataRepository.java +++ b/spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/metadata/repository/DubboServiceMetadataRepository.java @@ -36,7 +36,6 @@ import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Set; -import java.util.Optional; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -50,7 +49,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; -import org.springframework.cloud.client.loadbalancer.LoadBalancerClient; import org.springframework.cloud.commons.util.InetUtils; import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationEventPublisher; @@ -167,9 +165,6 @@ public class DubboServiceMetadataRepository @Autowired private DiscoveryClient discoveryClient; - @Autowired - private LoadBalancerClient loadBalancerClient; - @Autowired private JSONUtils jsonUtils; @@ -623,7 +618,7 @@ public class DubboServiceMetadataRepository } protected void initSubscribedDubboMetadataService(String serviceName) { - Optional.ofNullable(loadBalancerClient.choose(serviceName)) + discoveryClient.getInstances(serviceName).stream().findAny() .map(this::getDubboMetadataServiceURLs) .ifPresent(dubboMetadataServiceURLs -> { dubboMetadataServiceURLs.forEach(dubboMetadataServiceURL -> {