From 8bb51de9c06383cefea137d186c9f7d7f20329ac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=8E=E6=9C=A8=E5=81=A5?= <1033237526@qq.com> Date: Mon, 19 Jul 2021 19:11:51 +0800 Subject: [PATCH] optimize ShortestResponseLoadBalance active param --- .../rpc/cluster/loadbalance/ShortestResponseLoadBalance.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java index 610b1b4e336..5836884b5cc 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java @@ -61,7 +61,7 @@ protected Invoker doSelect(List> invokers, URL url, Invocation RpcStatus rpcStatus = RpcStatus.getStatus(invoker.getUrl(), invocation.getMethodName()); // Calculate the estimated response time from the product of active connections and succeeded average elapsed time. long succeededAverageElapsed = rpcStatus.getSucceededAverageElapsed(); - int active = rpcStatus.getActive(); + int active = rpcStatus.getActive() + 1; long estimateResponse = succeededAverageElapsed * active; int afterWarmup = getWeight(invoker, invocation); weights[i] = afterWarmup;