聊聊dubbo-go的randomLoadBalance
时间:2022-07-23
本文章向大家介绍聊聊dubbo-go的randomLoadBalance,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下dubbo-go的randomLoadBalance
randomLoadBalance
dubbo-go-v1.4.2/cluster/loadbalance/random.go
const (
name = "random"
)
func init() {
extension.SetLoadbalance(name, NewRandomLoadBalance)
}
type randomLoadBalance struct {
}
// NewRandomLoadBalance ...
func NewRandomLoadBalance() cluster.LoadBalance {
return &randomLoadBalance{}
}
- randomLoadBalance的NewRandomLoadBalance方法创建randomLoadBalance
Select
dubbo-go-v1.4.2/cluster/loadbalance/random.go
func (lb *randomLoadBalance) Select(invokers []protocol.Invoker, invocation protocol.Invocation) protocol.Invoker {
var length int
if length = len(invokers); length == 1 {
return invokers[0]
}
sameWeight := true
weights := make([]int64, length)
firstWeight := GetWeight(invokers[0], invocation)
totalWeight := firstWeight
weights[0] = firstWeight
for i := 1; i < length; i++ {
weight := GetWeight(invokers[i], invocation)
weights[i] = weight
totalWeight += weight
if sameWeight && weight != firstWeight {
sameWeight = false
}
}
if totalWeight > 0 && !sameWeight {
// If (not every invoker has the same weight & at least one invoker's weight>0), select randomly based on totalWeight.
offset := rand.Int63n(totalWeight)
for i := 0; i < length; i++ {
offset -= weights[i]
if offset < 0 {
return invokers[i]
}
}
}
// If all invokers have the same weight value or totalWeight=0, return evenly.
return invokers[rand.Intn(length)]
}
- Select方法先判断invokers数量,若只有一个则返回invokers[0];之后遍历invokers计算totalWeight及sameWeight,若totalWeight大于0且sameWeight为false则使用rand.Int63n(totalWeight)随机一个offset,之后遍历weights,用offset挨个去减weights[i],若offset小于0,则返回invokers[i];若都没有选中,则返回invokers[rand.Intn(length)]
小结
randomLoadBalance的NewRandomLoadBalance方法创建randomLoadBalance;其Select方法使用了带weight的方法,具体就是使用rand.Int63n(totalWeight)随机一个offset,之后遍历weights,用offset挨个去减weights[i],若offset小于0,则返回invokers[i]
doc
- Nodejs学习笔记(一)——初识Nodejs
- RabbitMQ入门-Topic模式
- 单分子数据储存取得一大突破,一枚“硬币”存量相当于100部iPhone 7
- Windows 7 旗舰版 VHD安装体验
- Nodejs学习笔记(二)——Eclipse中运行调试Nodejs
- Nodejs学习笔记(三)——一张图看懂Nodejs建站
- 不规则图形的碰撞检测
- 自学WP7第一个例子:时钟
- 教您最简单粗暴的MATLAB入门级爬虫2
- 前台JS(Jquery)调用后台方法 无刷新级联菜单示例
- 项目中对图片的缩放和水印效果
- 照虎画猫写自己的Spring——自定义注解
- 数据分析进阶课程笔记(六)
- 微信发布重磅更新!上线小游戏,小程序间可快速切换
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法