聊聊dubbo-go的registryAwareCluster
时间:2022-07-22
本文章向大家介绍聊聊dubbo-go的registryAwareCluster,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下dubbo-go的registryAwareCluster
registryAwareCluster
dubbo-go-v1.4.2/cluster/cluster_impl/registry_aware_cluster.go
type registryAwareCluster struct{}
func init() {
extension.SetCluster("registryAware", NewRegistryAwareCluster)
}
// NewRegistryAwareCluster ...
func NewRegistryAwareCluster() cluster.Cluster {
return ®istryAwareCluster{}
}
func (cluster *registryAwareCluster) Join(directory cluster.Directory) protocol.Invoker {
return newRegistryAwareClusterInvoker(directory)
}
- registryAwareCluster的Join方法执行newRegistryAwareClusterInvoker(directory)
newRegistryAwareClusterInvoker
dubbo-go-v1.4.2/cluster/cluster_impl/registry_aware_cluster_invoker.go
type registryAwareClusterInvoker struct {
baseClusterInvoker
}
func newRegistryAwareClusterInvoker(directory cluster.Directory) protocol.Invoker {
return ®istryAwareClusterInvoker{
baseClusterInvoker: newBaseClusterInvoker(directory),
}
}
- newRegistryAwareClusterInvoker方法创建registryAwareClusterInvoker
Invoke
dubbo-go-v1.4.2/cluster/cluster_impl/registry_aware_cluster_invoker.go
func (invoker *registryAwareClusterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
invokers := invoker.directory.List(invocation)
//First, pick the invoker (XXXClusterInvoker) that comes from the local registry, distinguish by a 'default' key.
for _, invoker := range invokers {
if invoker.IsAvailable() && invoker.GetUrl().GetParam(constant.REGISTRY_DEFAULT_KEY, "false") == "true" {
return invoker.Invoke(ctx, invocation)
}
}
//If none of the invokers has a local signal, pick the first one available.
for _, invoker := range invokers {
if invoker.IsAvailable() {
return invoker.Invoke(ctx, invocation)
}
}
return nil
}
- Invoke方法先通过invoker.directory.List(invocation)获取invokers,然后遍历invokers判断是否有来自local registry的invoker, 如果有则执行invoker.Invoke(ctx, invocation);否则再次遍历invokers,找到第一个available的执行invoker.Invoke(ctx, invocation)
小结
registryAwareCluster的Join方法执行newRegistryAwareClusterInvoker(directory);registryAwareClusterInvoker的Invoke方法先通过invoker.directory.List(invocation)获取invokers,然后遍历invokers判断是否有来自local registry的invoker, 如果有则执行invoker.Invoke(ctx, invocation),没有local的则遍历invokers,找到第一个available的执行invoker.Invoke(ctx, invocation)
doc
- 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 数组属性和方法
- 前端登录,这一篇就够了
- 技术译文 | MySQL 8 需要多大的 innodb_buffer_pool_instances 值(下)
- 创建线程到底有多少种方式?
- CANet|拼接注意力网络
- SQL 中判断条件的先后顺序,会引起索引失效么?
- 一个超酷的开源uHand2.0机械手掌项目
- 神经网络低比特量化——TQT
- web前端面试题:您能读懂的Promise源码实现(手写代码)
- web前端面试题对答篇:HTTP fetch发送2次请求的原因?
- MySQL 8.0之hash join
- MySQL 8.0 之原子DDL
- 翻译|MySQL 基于ScaleFlux SSD性能测试
- 使用srsLTE搭建4G基站
- 构建高性能队列,你不得不知道的底层知识!
- 案例| +1s导致的故障