聊聊dubbo-go的failsafeCluster
时间:2022-07-22
本文章向大家介绍聊聊dubbo-go的failsafeCluster,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下dubbo-go的failsafeCluster
failsafeCluster
dubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster.go
type failsafeCluster struct{}
const failsafe = "failsafe"
func init() {
extension.SetCluster(failsafe, NewFailsafeCluster)
}
// NewFailsafeCluster ...
func NewFailsafeCluster() cluster.Cluster {
return &failsafeCluster{}
}
func (cluster *failsafeCluster) Join(directory cluster.Directory) protocol.Invoker {
return newFailsafeClusterInvoker(directory)
}
- failsafeCluster的join方法执行newFailsafeClusterInvoker
newFailsafeClusterInvoker
dubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster_invoker.go
type failsafeClusterInvoker struct {
baseClusterInvoker
}
func newFailsafeClusterInvoker(directory cluster.Directory) protocol.Invoker {
return &failsafeClusterInvoker{
baseClusterInvoker: newBaseClusterInvoker(directory),
}
}
- newFailsafeClusterInvoker方法创建failsafeClusterInvoker
Invoke
dubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster_invoker.go
func (invoker *failsafeClusterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
invokers := invoker.directory.List(invocation)
err := invoker.checkInvokers(invokers, invocation)
if err != nil {
return &protocol.RPCResult{}
}
url := invokers[0].GetUrl()
methodName := invocation.MethodName()
//Get the service loadbalance config
lb := url.GetParam(constant.LOADBALANCE_KEY, constant.DEFAULT_LOADBALANCE)
//Get the service method loadbalance config if have
if v := url.GetMethodParam(methodName, constant.LOADBALANCE_KEY, ""); v != "" {
lb = v
}
loadbalance := extension.GetLoadbalance(lb)
invoked := make([]protocol.Invoker, 0)
var result protocol.Result
ivk := invoker.doSelect(loadbalance, invocation, invokers, invoked)
//DO INVOKE
result = ivk.Invoke(ctx, invocation)
if result.Error() != nil {
// ignore
logger.Errorf("Failsafe ignore exception: %v.n", result.Error().Error())
return &protocol.RPCResult{}
}
return result
}
- Invoke方法先通过invoker.directory.List(invocation)获取invokers,之后通过invoker.doSelect(loadbalance, invocation, invokers, invoked)选择ivk,最后执行ivk.Invoke(ctx, invocation),如果有error,则打印error,返回空结果
GetLoadbalance
dubbo-go-v1.4.2/common/extension/loadbalance.go
// GetLoadbalance ...
func GetLoadbalance(name string) cluster.LoadBalance {
if loadbalances[name] == nil {
panic("loadbalance for " + name + " is not existing, make sure you have import the package.")
}
return loadbalances[name]()
}
- GetLoadbalance方法根据执行的name获取cluster.LoadBalance,默认为randomLoadBalance
小结
failsafeCluster的join方法执行newFailsafeClusterInvoker;Invoke方法先通过invoker.directory.List(invocation)获取invokers,之后通过invoker.doSelect(loadbalance, invocation, invokers, invoked)选择ivk,最后执行ivk.Invoke(ctx, invocation),如果有error,则打印error,返回空结果
与failfastCluster的区别就是针对error进行log,然后返回的始终的是没有err的
- 无人值守,检测程序正常运行,遇故障则重启服务
- JS魔法堂:jsDeferred源码剖析
- JavaSE(八)之集合概述
- 浅谈PHP开发与Java开发的优劣势,还不知道学习方向的可以来看看
- KVM+Qemu+Libvirt实战
- 内核级虚拟化技术
- tomcat配置ROOT目录和多站点
- IntelliJ IDEA使用(一)基本设置与类、方法模板设置
- JS魔法堂:从void 0 === undefined说起
- Maven(三)在Eclipse中使用Maven与Maven坐标
- Nginx多站点设置及负载均衡
- Maven(二)Maven项目的创建(命令、myeclipse)及生命周期
- JS魔法堂:初探传说中的setImmediate函数
- 配置nginx.conf实现负载均衡
- 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 数组属性和方法
- 学好Spark必须要掌握的Scala技术点
- EF Linq中的左连接Left Join查询
- dotnet 删除自身程序的方法
- Roslyn 读取 PackageReference 的版本号和内容
- Web开发中的时区问题
- 编写代码生成器的一些问题与思考
- 和小曼一起走到MySQL行的尽头
- 明亮解我“工厂模式无用”之惑
- 「源码分析」— 为什么枚举是单例模式的最佳方法
- 如何记忆 Spring Bean 的生命周期
- 系统学习Stream
- Java回调的四种写法(反射、直接调用、接口调用、Lamda表达式)
- 避开NullPointerException的10条建议
- REST服务,使用Dubbo还是SpringMVC?
- Linux系统下Anaconda的安装和使用教程