Skip to main content

zookeeper 插件

我们使用zk作为zookeeper连接的SDK, 并且将其封装在xzk包中。我们也为其适配了自动注册的rzk包的实现。

如何使用​

自动注册​

在使用的过程中，我们只需要将rzk导入到主程序中，比如

import (
    _ "path/to/r/rzk"
)

func main() {
    .....
}

主程序运行过程中会根据配置中的数据，创建对应的实例，并且放到内存中。我们在使用的过程中，可以调用

cli := rzk.GetZKClient("ngo.client.zookeeper.{name}")

直接拿到客户端，就可以使用了。

配置参数​

参数类型含义默认值
Namestring用户需要保证名字唯一, 也是ngo.client.zookeeper.{name}中的{name}
Addr[]string节点地址
SessionTimeoutnumber连接断开服务器的超时时间

配置举例​

[[ngo.client.zookeeper]]
name = "demo01"
addr = ["127.0.0.1:2181"]
sessionTimeout = 5000000000 #5s

目前我们支持了同一个应用的多客户端, 因此你可以在toml配置文件中配置多个。