前言
zkClient主要做了两件事情:
- 一件是在session loss和session expire时自动创建新的ZooKeeper实例进行重连。
- 另一件是将一次性watcher包装为持久watcher。后者的具体做法是简单的在watcher回调中,重新读取数据的同时再注册相同的watcher实例。
zkClient目前已经运用到了很多项目中,知名的有Dubbo、Kafka、Helix。
zkClient jar包下载,或者直接添加maven依赖: http://mvnrepository.com/artifact/com.101tec/zkclient
正文
直接上代码:
1.测试类
1 | package com.xbq.demo; |
2.自定义序列化类
1 | package com.xbq.demo; |
源码下载
点击阅读原文下载源码哦