study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

code format

Browse Source
This commit is contained in:
fangjian0423 2019-09-12 15:23:30 +08:00
parent 101ac4c605
commit dab11a2c79
2 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/autoconfigure/DubboMetadataAutoConfiguration.java
View File

@ -19,7 +19,6 @@ import java.util.Collection;
import java.util.Optional; import java.util.Optional;
import java.util.function.Supplier; import java.util.function.Supplier;
import com.alibaba.cloud.dubbo.metadata.repository.MetadataServiceInstanceSelector;
import org.apache.dubbo.config.ProtocolConfig; import org.apache.dubbo.config.ProtocolConfig;
import org.apache.dubbo.config.spring.ServiceBean; import org.apache.dubbo.config.spring.ServiceBean;
import org.apache.dubbo.config.spring.context.event.ServiceBeanExportedEvent; import org.apache.dubbo.config.spring.context.event.ServiceBeanExportedEvent;
@ -32,9 +31,11 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import; import org.springframework.context.annotation.Import;
import org.springframework.context.event.ContextClosedEvent; import org.springframework.context.event.ContextClosedEvent;
import org.springframework.context.event.EventListener; import org.springframework.context.event.EventListener;
import org.springframework.util.CollectionUtils;
import com.alibaba.cloud.dubbo.metadata.DubboProtocolConfigSupplier; import com.alibaba.cloud.dubbo.metadata.DubboProtocolConfigSupplier;
import com.alibaba.cloud.dubbo.metadata.repository.DubboServiceMetadataRepository; import com.alibaba.cloud.dubbo.metadata.repository.DubboServiceMetadataRepository;
import com.alibaba.cloud.dubbo.metadata.repository.MetadataServiceInstanceSelector;
import com.alibaba.cloud.dubbo.metadata.resolver.DubboServiceBeanMetadataResolver; import com.alibaba.cloud.dubbo.metadata.resolver.DubboServiceBeanMetadataResolver;
import com.alibaba.cloud.dubbo.metadata.resolver.MetadataResolver; import com.alibaba.cloud.dubbo.metadata.resolver.MetadataResolver;
import com.alibaba.cloud.dubbo.service.DubboGenericServiceFactory; import com.alibaba.cloud.dubbo.service.DubboGenericServiceFactory;
@ -44,7 +45,6 @@ import com.alibaba.cloud.dubbo.service.IntrospectiveDubboMetadataService;
import com.alibaba.cloud.dubbo.util.JSONUtils; import com.alibaba.cloud.dubbo.util.JSONUtils;
import feign.Contract; import feign.Contract;
import org.springframework.util.CollectionUtils;
/** /**
* Spring Boot Auto-Configuration class for Dubbo Metadata * Spring Boot Auto-Configuration class for Dubbo Metadata
@ -74,10 +74,9 @@ public class DubboMetadataAutoConfiguration {
@Bean @Bean
@ConditionalOnMissingBean @ConditionalOnMissingBean
public MetadataServiceInstanceSelector metadataServiceInstanceSelector() { public MetadataServiceInstanceSelector metadataServiceInstanceSelector() {
return serviceInstances -> return serviceInstances -> CollectionUtils.isEmpty(serviceInstances)
CollectionUtils.isEmpty(serviceInstances) ? Optional.empty()
? Optional.empty() : serviceInstances.stream().findAny();
: serviceInstances.stream().findAny();
} }
@Bean @Bean

17
spring-cloud-alibaba-dubbo/src/main/java/com/alibaba/cloud/dubbo/metadata/repository/MetadataServiceInstanceSelector.java
View File

@ -16,11 +16,11 @@
package com.alibaba.cloud.dubbo.metadata.repository; package com.alibaba.cloud.dubbo.metadata.repository;
import org.springframework.cloud.client.ServiceInstance;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import org.springframework.cloud.client.ServiceInstance;
/** /**
* metadata service instance selector * metadata service instance selector
* *
@ -28,11 +28,10 @@ import java.util.Optional;
*/ */
public interface MetadataServiceInstanceSelector { public interface MetadataServiceInstanceSelector {
/**
/** * choose a service instance to get metadata
* choose a service instance to get metadata * @param serviceInstances all service instance
* @param serviceInstances all service instance * @return the service instance to get metadata
* @return the service instance to get metadata */
*/ Optional<ServiceInstance> choose(List<ServiceInstance> serviceInstances);
Optional<ServiceInstance> choose(List<ServiceInstance> serviceInstances);
} }