From 64abfd27e5d02b7a6b218b5a540e68becc6037b9 Mon Sep 17 00:00:00 2001 From: fishtailfu Date: Fri, 11 Jul 2025 16:04:34 +0800 Subject: [PATCH] feat: support shortest response time lb and least connection loadbalancer --- ...olarisShortestResponseTimeLoadBalancerConfigModifier.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestResponseTimeLoadBalancerConfigModifier.java b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestResponseTimeLoadBalancerConfigModifier.java index 523ab9085..c2666b2bc 100644 --- a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestResponseTimeLoadBalancerConfigModifier.java +++ b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/loadbalancer/PolarisShortestResponseTimeLoadBalancerConfigModifier.java @@ -20,8 +20,10 @@ package com.tencent.cloud.polaris.loadbalancer; import com.tencent.cloud.common.constant.OrderConstant; import com.tencent.cloud.polaris.context.PolarisConfigModifier; import com.tencent.polaris.api.config.consumer.LoadBalanceConfig; +import com.tencent.polaris.api.config.consumer.ServiceRouterConfig; import com.tencent.polaris.factory.config.ConfigurationImpl; import com.tencent.polaris.plugins.loadbalancer.shortestresponsetime.ShortestResponseTimeLoadBalanceConfig; +import com.tencent.polaris.plugins.router.healthy.RecoverRouterConfig; public class PolarisShortestResponseTimeLoadBalancerConfigModifier implements PolarisConfigModifier { @@ -35,7 +37,8 @@ public class PolarisShortestResponseTimeLoadBalancerConfigModifier implements Po @Override public void modify(ConfigurationImpl configuration) { - ShortestResponseTimeLoadBalanceConfig config = new ShortestResponseTimeLoadBalanceConfig(); + ShortestResponseTimeLoadBalanceConfig config = configuration.getConsumer().getLoadbalancer() + .getPluginConfig(LoadBalanceConfig.LOAD_BALANCE_SHORTEST_RESPONSE_TIME, ShortestResponseTimeLoadBalanceConfig.class); config.setSlidePeriod(shortestResponseTime.getSlidePeriod()); configuration.getConsumer().getLoadbalancer() .setPluginConfig(LoadBalanceConfig.LOAD_BALANCE_SHORTEST_RESPONSE_TIME,