“Zookeeper：watcher 事件机制原理”的版本间差异

2021年5月14日 (五) 19:45的版本

关于

监视是一种简单的机制，使客户端收到关于ZooKeeper集合中的更改的通知。客户端可以在读取特定znode时设置Watches。Watches会向注册的客户端发送任何znode（客户端注册表）更改的通知。

Znode更改是与znode相关的数据的修改或znode的子项中的更改。
watches只触发一次就失效。
如果客户端想要再次通知，则必须通过另一个读取操作来完成。
当连接会话过期时，客户端将与服务器断开连接，相关的watches也将被删除。

原理

zookeeper 的 watcher 机制，可以分为四个过程：

客户端注册 watcher；
服务端处理 watcher；
服务端触发 watcher 事件；
客户端回调 watcher。

其中“客户端注册 watcher”有三种方式，调用客户端 API 可以分别通过 getData、exists、getChildren 实现。

以 exists 方法举例说明其原理：

public class WatcherDemo implements Watcher {
    static ZooKeeper zooKeeper;
    static {
        try {
            zooKeeper = new ZooKeeper("192.168.3.39:2181", 4000,new WatcherDemo());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void process(WatchedEvent event) {
        System.out.println("eventType:"+event.getType());
        if(event.getType()==Event.EventType.NodeDataChanged){
            try {
                zooKeeper.exists(event.getPath(),true);
            } catch (KeeperException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
        String path="/watcher";
        if(zooKeeper.exists(path,false)==null) {
            zooKeeper.create("/watcher", "0".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        }
        Thread.sleep(1000);
        System.out.println("-----------");
        // true表示使用zookeeper实例中配置的watcher
        Stat stat=zooKeeper.exists(path,true);
        System.in.read();
    }
}