聊聊dubbo-go的kubernetesRegistry
时间:2022-07-22
本文章向大家介绍聊聊dubbo-go的kubernetesRegistry,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下dubbo-go的kubernetesRegistry
kubernetesRegistry
dubbo-go-v1.4.2/registry/kubernetes/registry.go
var (
processID = ""
localIP = ""
)
const (
Name = "kubernetes"
ConnDelay = 3
MaxFailTimes = 15
)
func init() {
processID = fmt.Sprintf("%d", os.Getpid())
localIP, _ = gxnet.GetLocalIP()
extension.SetRegistry(Name, newKubernetesRegistry)
}
type kubernetesRegistry struct {
registry.BaseRegistry
cltLock sync.RWMutex
client *kubernetes.Client
listenerLock sync.Mutex
listener *kubernetes.EventListener
dataListener *dataListener
configListener *configurationListener
}
- kubernetesRegistry定义了cltLock、client、listenerLock、listener、dataListener、configListener属性
newKubernetesRegistry
dubbo-go-v1.4.2/registry/kubernetes/registry.go
func newKubernetesRegistry(url *common.URL) (registry.Registry, error) {
// actually, kubernetes use in-cluster config,
r := &kubernetesRegistry{}
r.InitBaseRegistry(url, r)
if err := kubernetes.ValidateClient(r); err != nil {
return nil, perrors.WithStack(err)
}
r.WaitGroup().Add(1)
go r.HandleClientRestart()
r.InitListeners()
logger.Debugf("the kubernetes registry started")
return r, nil
}
- newKubernetesRegistry方法实例化kubernetesRegistry,然后执行InitBaseRegistry、InitListeners
InitListeners
dubbo-go-v1.4.2/registry/kubernetes/registry.go
func (r *kubernetesRegistry) InitListeners() {
r.listener = kubernetes.NewEventListener(r.client)
r.configListener = NewConfigurationListener(r)
r.dataListener = NewRegistryDataListener(r.configListener)
}
- InitListeners方法执行kubernetes.NewEventListener、NewConfigurationListener、NewRegistryDataListener
DoRegister
dubbo-go-v1.4.2/registry/kubernetes/registry.go
func (r *kubernetesRegistry) DoRegister(root string, node string) error {
return r.client.Create(path.Join(root, node), "")
}
- DoRegister执行r.client.Create(path.Join(root, node), "")
DoSubscribe
dubbo-go-v1.4.2/registry/kubernetes/registry.go
func (r *kubernetesRegistry) DoSubscribe(svc *common.URL) (registry.Listener, error) {
var (
configListener *configurationListener
)
r.listenerLock.Lock()
configListener = r.configListener
r.listenerLock.Unlock()
if r.listener == nil {
r.cltLock.Lock()
client := r.client
r.cltLock.Unlock()
if client == nil {
return nil, perrors.New("kubernetes client broken")
}
r.listenerLock.Lock()
if r.listener == nil {
// double check
r.listener = kubernetes.NewEventListener(r.client)
}
r.listenerLock.Unlock()
}
//register the svc to dataListener
r.dataListener.AddInterestedURL(svc)
for _, v := range strings.Split(svc.GetParam(constant.CATEGORY_KEY, constant.DEFAULT_CATEGORY), ",") {
go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+v, svc.Service()), r.dataListener)
}
return configListener, nil
}
- DoSubscribe方法在r.listener为nil时则通过kubernetes.NewEventListener(r.client)创建listener;之后执行r.dataListener.AddInterestedURL(svc);最后遍历category,执行r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+v, svc.Service()), r.dataListener)
小结
kubernetesRegistry定义了cltLock、client、listenerLock、listener、dataListener、configListener属性;InitListeners方法执行kubernetes.NewEventListener、NewConfigurationListener、NewRegistryDataListener
doc
- registry
- 得到真实外网IP、IP所在国家、省份、地区
- 机器学习在智能制造中的应用!
- sql2008 附加数据库时 错误5123
- Logistic Regression Models分析交互式问答译
- 照虎画猫写自己的Spring——依赖注入
- Logistic Regression Models分析交互式问答译
- Asp.Net开发等级星使用(Jquery Rating)
- Enterprise Library Policy Injection Application Block 之四:如何控制CallHandler的执行顺序
- 人工智能时代的艺术
- asp.net生成静态页
- Enterprise Library深入解析与灵活应用(1):通过Unity Extension实现和Policy Injection Application Block的集成
- 照虎画猫写自己的Spring
- 照虎画猫写自己的Spring
- mybatis 框架实战,实现数据库的增删改查
- 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 数组属性和方法
- tf.get_collection()
- tf.reduce_mean()
- tf.placeholder函数说明
- tf.sigmoid()用法
- Latex 表格过大(或过小)的调整方法
- Latex设置字体大小及表格中的文字大小等
- jQuery 选择器
- jQuery 介绍 以及基本使用
- 答应我,用了这个jupyter插件,别再重复造轮子了
- 商业数据分析从入门到入职(9)Python网络数据获取
- 谈一谈还原解包后小程序页面wxss样式的若干方法
- 什么?不使用selenium爬京东评论?你是不是在骗我
- 骚操作,Python操作PPT,你会吗?
- 用了这个jupyter插件,我已经半个月没打开过excel了
- Mística:一款支持任意协议的应用程序通信工具