From fa4734cf32d0a3a8c92b6f19d0f67f4c29fd6683 Mon Sep 17 00:00:00 2001 From: veteranchen Date: Thu, 27 Jul 2023 07:56:31 +0800 Subject: [PATCH] =?UTF-8?q?polaris=20load=20balancer:=20=E6=8F=90=E5=8F=96?= =?UTF-8?q?=E8=B4=9F=E8=BD=BD=E5=9D=87=E8=A1=A1=E5=99=A8=E5=85=AC=E5=85=B1?= =?UTF-8?q?=E6=8A=BD=E8=B1=A1=E5=9F=BA=E7=B1=BB=EF=BC=8C=E5=AE=9E=E7=8E=B0?= =?UTF-8?q?=E5=8A=A0=E6=9D=83=E8=BD=AE=E8=AE=AD=E8=B4=9F=E8=BD=BD=E5=9D=87?= =?UTF-8?q?=E8=A1=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 优化 code style --issue=968 --- .../loadbalancer/PolarisAbstractLoadBalancer.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisAbstractLoadBalancer.java b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisAbstractLoadBalancer.java index c2b68fd42..f3ad9060d 100644 --- a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisAbstractLoadBalancer.java +++ b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisAbstractLoadBalancer.java @@ -17,6 +17,9 @@ package com.tencent.cloud.polaris.loadbalancer; +import java.util.List; +import java.util.stream.Collectors; + import com.tencent.cloud.common.metadata.MetadataContext; import com.tencent.cloud.common.pojo.PolarisServiceInstance; import com.tencent.polaris.api.pojo.DefaultServiceInstances; @@ -28,6 +31,8 @@ import com.tencent.polaris.router.api.rpc.ProcessLoadBalanceRequest; import com.tencent.polaris.router.api.rpc.ProcessLoadBalanceResponse; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import reactor.core.publisher.Mono; + import org.springframework.beans.factory.ObjectProvider; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.loadbalancer.DefaultResponse; @@ -37,10 +42,6 @@ import org.springframework.cloud.client.loadbalancer.Response; import org.springframework.cloud.loadbalancer.core.NoopServiceInstanceListSupplier; import org.springframework.cloud.loadbalancer.core.ReactorServiceInstanceLoadBalancer; import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier; -import reactor.core.publisher.Mono; - -import java.util.List; -import java.util.stream.Collectors; /** * Abstract Loadbalancer of Polaris. @@ -88,7 +89,8 @@ public abstract class PolarisAbstractLoadBalancer implements ReactorServiceInsta try { ProcessLoadBalanceResponse response = routerAPI.processLoadBalance(req); return new DefaultResponse(new PolarisServiceInstance(response.getTargetInstance())); - } catch (Exception e) { + } + catch (Exception e) { log.warn("PolarisRoutingLoadbalancer error", e); return new EmptyResponse(); }