From 91a96c421e2d8af31244f0e6114653d6b7dc5010 Mon Sep 17 00:00:00 2001 From: fishtailfu Date: Thu, 3 Jul 2025 15:07:35 +0800 Subject: [PATCH] feat: support least connection loadbalancer --- ...alancer.java => PolarisLeastConnectionLoadBalancer.java} | 6 +++--- .../PolarisLoadBalancerClientConfiguration.java | 2 +- spring-cloud-tencent-dependencies/pom.xml | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) rename spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/{PolarisShortestLeastConnectionLoadBalancer.java => PolarisLeastConnectionLoadBalancer.java} (71%) diff --git a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestLeastConnectionLoadBalancer.java b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLeastConnectionLoadBalancer.java similarity index 71% rename from spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestLeastConnectionLoadBalancer.java rename to spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLeastConnectionLoadBalancer.java index c7a02e759..2dac09564 100644 --- a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestLeastConnectionLoadBalancer.java +++ b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLeastConnectionLoadBalancer.java @@ -9,12 +9,12 @@ import org.springframework.beans.factory.ObjectProvider; import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier; /** - * PolarisShortestResponseTimeLoadBalancer. + * Polaris Least Connection LoadBalancer. * * @author Yuwei Fu */ -public class PolarisShortestLeastConnectionLoadBalancer extends AbstractPolarisLoadBalancer { - public PolarisShortestLeastConnectionLoadBalancer(String serviceId, ObjectProvider supplierObjectProvider, RouterAPI routerAPI) { +public class PolarisLeastConnectionLoadBalancer extends AbstractPolarisLoadBalancer { + public PolarisLeastConnectionLoadBalancer(String serviceId, ObjectProvider supplierObjectProvider, RouterAPI routerAPI) { super(serviceId, supplierObjectProvider, routerAPI); } diff --git a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLoadBalancerClientConfiguration.java b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLoadBalancerClientConfiguration.java index e77b1c950..1c16c25f1 100644 --- a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLoadBalancerClientConfiguration.java +++ b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisLoadBalancerClientConfiguration.java @@ -109,7 +109,7 @@ public class PolarisLoadBalancerClientConfiguration { public ReactorLoadBalancer polarisLeastConnectionLoadBalancer(Environment environment, LoadBalancerClientFactory loadBalancerClientFactory, PolarisSDKContextManager polarisSDKContextManager) { String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME); - return new PolarisShortestLeastConnectionLoadBalancer(name, + return new PolarisLeastConnectionLoadBalancer(name, loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), polarisSDKContextManager.getRouterAPI()); } @Bean diff --git a/spring-cloud-tencent-dependencies/pom.xml b/spring-cloud-tencent-dependencies/pom.xml index db0fc899a..bff254c95 100644 --- a/spring-cloud-tencent-dependencies/pom.xml +++ b/spring-cloud-tencent-dependencies/pom.xml @@ -74,7 +74,7 @@ 2.0.3.0-2024.0.1-SNAPSHOT - 2.0.2.0 + 2.0.3.0-SNAPSHOT 2.2.0