Watcher监听机制

在创建zookeeper会话时会传入一个Watcher，里面有两个特别关键的类：KeeperState（连接状态）和EventType（事件类型）。
如何拿到事件状态或类型？

//获取事件的状态
Event.KeeperState state = watchedEvent.getState(); //获取事件的状态
//获取事件的类型
Event.EventType type = watchedEvent.getType(); //获取事件的类型

KeeperState

KeeperState表示的是客户端与服务端连接的状态。

EventType

EventType表示的是节点发生变化时所触发的事件类型。

拿取事件状态demo

Event.KeeperState state = watchedEvent.getState(); //获取事件的状态
Event.EventType type = watchedEvent.getType(); //获取事件的类型
if (Event.KeeperState.SyncConnected.equals(state)) {
    switch (type) {
        case None:
            log.info("zookeeper connected success");
            countDownLatch.countDown();
            break;
        case NodeCreated:
            log.info("[{}] create node: {}", name, watchedEvent.getPath());
            break;
        case NodeDeleted:
            log.info("[{}] delete node: {}", name, watchedEvent.getPath());
            break;
        case NodeDataChanged:
            log.info("[{}] node data change: {}", name, watchedEvent.getPath());
            break;
        case NodeChildrenChanged:
            log.info("[{}] node children change: {}", name, watchedEvent.getPath());
            break;
    }
}

watcher有两种添加方式

• 使用默认watcher boolean watch

List<String> getChildren(String path, boolean watch)
byte[] getData(String path, boolean watch, Stat stat)
Stat exists(String path, boolean watch)

• 自定义watcher Watcher watcher

同一方法注册多个事件

zookeeper.exists("/p", true); // 注册默认的wachter
zookeeper.exists("/p", new MyWatcher("Customer Watcher")); // 再注册一个watcher
zookeeper.create("/p", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zookeeper.delete("/p", -1);

当一个节点注册了多个watcher，那么多个watcher的方法都会被回调。

不同方法注册同一事件多次

zookeeper.create("/p", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zookeeper.getData("/p", true, null); // 注册默认的wachter
zookeeper.exists("/p", true); // 注册两次默认的wachter
zookeeper.setData("/p", "ppp".getBytes(), -1);
zookeeper.delete("/p", -1);

通过观察运行结果，总结如下：

• 注册一次watcher只会收到一次通知，想一直监听就得收到通知后再次注册。
• 同一个watcher实例被例如exists，getData等方法多次注册，zookeeper客户端也只会收到一次通知。
• 当一个节点注册多个不同的watcher实例时，会通知多次，即每个被注册的watcher都会收到通知。
• exists可以监听一个不存在的节点，但是getData和getChildren不能监控一个不存在的节点，否则会报NoNodeException。

zookeeper原生客户端的缺点

• 不能递归的创建节点和删除节点。
• 对节点的数据操作基于字节数组（二进制安全），经常需要数组和字符串之间的转换。
• 想一直监听某个节点就要一直注册，监听一些不存在的节点可能会抛出异常。