com.101tec.zkclient使用

网上一些参考:

http://shift-alt-ctrl.iteye.com/blog/1955740

https://github.com/adyliu/zkclient/wiki

http://www.ithao123.cn/content-8163867.html

http://www.wxdl.cn/cloud/zookeeper-zkclient.html

http://www.cnphp6.com/archives/110234

http://www.zhiliaoyuan.com/zkclient%E7%AE%80%E5%8D%95%E6%93%8D%E4%BD%9C/

http://www.programcreek.com/java-api-examples/index.php?api=org.I0Itec.zkclient.ZkClient

http://san-yun.iteye.com/blog/1977454

创建ZkClient实例

ZkClient构造函数,几个参数

String zkServers : 连接zk的IP+端口字符串

int connectionTimeout : 连接超时时间

int sessionTimeout : 会话超时时间

zk客户端与服务端建立连接之后会生成一个全局唯一session,一个长连接,客户端会定时向服务器发送心跳重置session timeout

ZkSerializer zkSerializer : 序列化

在创建ZkClient实例后,在服务端执行 netstat -an | grep zk 端口号,可以看到连接信息。

创建ZkClient实例后可以通过调用close()方法关闭。

什么情况下会造成zk连接泄露???

判断节点是否存在

public boolean exists(final String path)

递归删除节点

public boolean deleteRecursive(String path)

创建临时节点EPHEMERAL(临时节点在客户端断开连接后会删除

public void createEphemeral(final String path)

获取某节点的子节点

public List<String> getChildren(String path)
Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐