Zookeeper入门（三）

Zookeeper Java 客户端

项目构建

ookeeper 官方的客户端没有和服务端代码分离，他们为同一个jar 文件，以是我们直接引入
zookeeper的maven即可， 这里版本请保持与服务端版本划一，不然会有很多兼容性的问题

1. 1 <dependency>
2. 2 <groupId>org.apache.zookeeper</groupId>
3. 3 <artifactId>zookeeper</artifactId>
4. 4 <version>3.5.8</version>
5. 5 </dependency>

复制代码

创建客户端实例：

为了便于测试，直接在初始化方法中创建zookeeper实例

1. 1 @Slf4j
2. 2 public class ZookeeperClientTest {
3. 3
4. 4 private static final String ZK_ADDRESS="192.168.109.200:2181";
5. 5
6. 6 private static final int SESSION_TIMEOUT = 5000;
7. 7
8. 8 private static ZooKeeper zooKeeper;
9. 9
10. 10 private static final String ZK_NODE="/zk‐node";
11. 11
12. 12
13. 13 @Before
14. 14 public void init() throws IOException, InterruptedException {
15. 15 final CountDownLatch countDownLatch=new CountDownLatch(1);
16. 16 zooKeeper=new ZooKeeper(ZK_ADDRESS, SESSION_TIMEOUT, event ‐> {
17. 17 if (event.getState()== Watcher.Event.KeeperState.SyncConnected &&
18. 18 event.getType()== Watcher.Event.EventType.None){
19. 19 countDownLatch.countDown();
20. 20 log.info("连接成功！");
21. 21 }
22. 22 });
23. 23 log.info("连接中....");
24. 24 countDownLatch.await();
25. 25 }
26. 26 }

复制代码

创建Zookeeper实例的方法：

1. 1 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher)
2. 2 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, ZKClientC
3. onfig)
4. 3 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean c
5. anBeReadOnly, HostProvider)
6. 4 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean c
7. anBeReadOnly, HostProvider, ZKClientConfig)
8. 5 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean c
9. anBeReadOnly)
10. 6 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean c
11. anBeReadOnly, ZKClientConfig)
12. 7 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, long, byt
13. e[])
14. 8 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, long, byt
15. e[], boolean, HostProvider)
16. 9 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, long, byt
17. e[], boolean, HostProvider, ZKClientConfig)
18. 10 ZooKeeper(String connectString, int sessionTimeout, Watcher watcher, long, by
19. te[], boolean)

复制代码

connectString:

ZooKeeper服务器列表，由英文逗号分开的host:port字符串构成，
每一个都代表一台ZooKeeper机器，如，
host1:port1,host2:port2,host3:port3。另外，也可以在connectString中设
置客户端毗连上ZooKeeper
后的根目录，方法是在host:port字符串之后添加上这个根目录，例
如,host1:port1,host2:port2,host3:port3/zk-base,这样就指定了该客户端连
接上ZooKeeper服务器之后,所有对ZooKeeper
的操作，都会基于这个根目录。比方，客户端对/sub-node 的操作，最终创建
/zk-node/sub-node, 这个目录也叫Chroot，即客户端隔离命名空间。

sessionTimeout 

会话的超时时间，是一个以“毫秒”为单位的整型值。在ZooKeeper中有
会话的概念，在一个会话周期内，ZooKeeper客户端和服务器之间会通过心跳
检
测机制来维持会话的有效性，一旦在sessionTimeout时间内没有举行有效
的心跳检测，会话就会失效。

watcher

ZooKeeper允许
客户端在构造方法中传入一个接口 watcher (org.apache. zookeeper.
Watcher)的实现类对象来作为默认的 Watcher变乱关照处理器。当然，该参
数可以设置为null 以表明不必要设置默认的 Watcher处理器。

canBeReadOnly

这是一个boolean范例的参数，用于标识当前会话是否支持“read-only(只
读)”模式。默认情况下，在ZooKeeper集群中，一个机器如果和集群中过半
及
以上机器失去了网络毗连，那么这个机器将不再处理客户端请求（包罗读写请
求)。但是在某些使用场景下，当ZooKeeper服务器发生此类故障的时候，我
们
还是渴望ZooKeeper服务器可以或许提供读服务（当然写服务肯定无法提供）——
这就是 ZooKeeper的“read-only”模式。
sessionId和 ses
sionPasswd

分别代表会话ID和会话秘钥。这两个参数可以或许唯一确定一个会话，同时客户
端使用这两个参数可以实现客户端会话复用，从而到达规复会话的结果。具体
使用方法是，第一次毗连上ZooKeeper服务器时，通过调用ZooKeeper对象
实
例的以下两个接口，即可得到当前会话的ID和秘钥:
long getSessionId();
byte[]getSessionPasswd( );
荻取到这两个参数值之后，就可以在下次创建ZooKeeper对象实例的时候传
入构造方法了

1. 同步创建节点：
2. 1 @Test
3. 2 public void createTest() throws KeeperException, InterruptedException {
4. 3 String path = zooKeeper.create(ZK_NODE, "data".getBytes(), ZooDefs.Ids.OPEN_A
5. CL_UNSAFE, CreateMode.PERSISTENT);
6. 4 log.info("created path: {}",path);
7. 5 }
8. 异步创建节点：
9. 1 @Test
10. 2 public void createAsycTest() throws InterruptedException {
11. 3 zooKeeper.create(ZK_NODE, "data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,
12. 4 CreateMode.PERSISTENT,
13. 5 (rc, path, ctx, name) ‐> log.info("rc {},path {},ctx {},name
14. {}",rc,path,ctx,name),"context");
15. 6 TimeUnit.SECONDS.sleep(Integer.MAX_VALUE);
16. 7 }
17. 修改节点数据
18. 1 @Test
19. 2 public void setTest() throws KeeperException, InterruptedException {
20. 3
21. 4 Stat stat = new Stat();
22. 5 byte[] data = zooKeeper.getData(ZK_NODE, false, stat);
23. 6 log.info("修改前: {}",new String(data));
24. 7 zooKeeper.setData(ZK_NODE, "changed!".getBytes(), stat.getVersion());
25. 8 byte[] dataAfter = zooKeeper.getData(ZK_NODE, false, stat);
26. 9 log.info("修改后: {}",new String(dataAfter));
27. 10 }

复制代码

什么是 Curator

Curator 是一套由netflix 公司开源的，Java 语言编程的 ZooKeeper 客户端框架，Curator项目
是现在ZooKeeper 客户端中使用最多，对ZooKeeper 版本支持最好的第三方客户端，并推荐使
用，Curator 把我们平时常用的很多 ZooKeeper 服务开发功能做了封装，比方 Leader 推举、
分布式计数器、分布式锁。这就减少了技术职员在使用 ZooKeeper 时的大部门底层细节开发工
作。在会话重新毗连、Watch 反复注册、多种非常处理等使用场景中，用原生的 ZooKeeper
处理比较复杂。而在使用 Curator 时，由于其对这些功能都做了高度的封装，使用起来更加简
单，不但减少了开发时间，而且加强了程序的可靠性。

Curator Caches:

Curator 引入了 Cache 来实现对 Zookeeper 服务端变乱监听，Cache 变乱监听可以理解为一
个当地缓存视图与长途 Zookeeper 视图的对比过程。Cache 提供了反复注册的功能。Cache 分
为两类注册范例：节点监听和子节点监听。


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。