dubbo源码分析第二十五篇一dubbo负载均衡一ShortestResponseLoadBalance加权最短响应时间
  Ojuk44AdL5AF 2023年11月02日 58 0


文章目录

  • ​​原理​​
  • ​​源码​​

原理

同最小活跃数负载,算法框架完全相同

  • 计算最小响应时间[总成功请求时间/总成功请求个数 * 当前活跃数]
  • 当前活跃数通过filter机制实现,同LeastActiveLoadBalance
  • 当前请求时间和个数通过ActiveLimitFilter过滤机制实现

dubbo源码分析第二十五篇一dubbo负载均衡一ShortestResponseLoadBalance加权最短响应时间_响应时间

源码

  • 获取最短响应时间Invoker集合
  • 只有一个返回,存在多个根据权重获取
protected <T> Invoker<T> doSelect(List<Invoker<T>> invokers, URL url, Invocation invocation) {
...... 删除其他代码 基本同最小活跃数算法
for (int i = 0; i < length; i++) {
Invoker<T> invoker = invokers.get(i);
RpcStatus rpcStatus = RpcStatus.getStatus(invoker.getUrl(), invocation.getMethodName());
每个请求成功时响应的平均时间 [每个请求开始有个时间戳 结束时的时间减去开始时间加入rpcStatus]
long succeededAverageElapsed = rpcStatus.getSucceededAverageElapsed();
获取当前在活跃调用的请求数量
int active = rpcStatus.getActive();
平均请求时间*活跃数表示最小响应时间
long estimateResponse = succeededAverageElapsed * active;
int afterWarmup = getWeight(invoker, invocation);
weights[i] = afterWarmup;
计算处理
if (estimateResponse < shortestResponse) {
shortestResponse = estimateResponse;
shortestCount = 1;
shortestIndexes[0] = i;
totalWeight = afterWarmup;
firstWeight = afterWarmup;
sameWeight = true;
} else if (estimateResponse == shortestResponse) {
shortestIndexes[shortestCount++] = i;
totalWeight += afterWarmup;
if (sameWeight && i > 0
&& afterWarmup != firstWeight) {
sameWeight = false;
}
}
}
最短响应时间相同的Invoker只有一个
if (shortestCount == 1) {
return invokers.get(shortestIndexes[0]);
}
最短响应时间相同的Invoker有多个,且存在权重不同 加权获取
if (!sameWeight && totalWeight > 0) {
int offsetWeight = ThreadLocalRandom.current().nextInt(totalWeight);
for (int i = 0; i < shortestCount; i++) {
int shortestIndex = shortestIndexes[i];
offsetWeight -= weights[shortestIndex];
if (offsetWeight < 0) {
return invokers.get(shortestIndex);
}
}
}
最短响应时间相同的Invoker有多个,且权重相同 随机获取
return invokers.get(shortestIndexes[ThreadLocalRandom.current().nextInt(shortestCount)]);
}


【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月08日 0

暂无评论

推荐阅读
  ehrZuhofWJiC   2024年04月26日   39   0   0 日志Java
Ojuk44AdL5AF