Watcher---Zk事件监听机制和原理

作者: 名字是乱打的 | 来源:发表于2020-04-05 15:28 被阅读0次

Watcher---Zk事件监听机制和原理
细谈Spring的事件监听机制
事件的委托
事件委托笔记
day08
2021-09-22 GUI(事件监听机制)
深入理解 Spring 的事件发布监听机制
spring源码事件监听
3.1 Android基于监听的事件处理
深入理解Spring的容器内事件发布监听机制

Zookeeper的Watcher 监听机制是 Zookeeper 中非常重要的特性,很多时候我们之所以用Zookeeper的原因其实都是因为Zookeeper这个特性.

想一想,我其实很久之前貌似做过类似于持续集成自动配置方面的尝试,那时候好像用的是MQ,我的配置改变了后向MQ发个消息,然后客户端的MQ消费者重新拉配置下来进行更新...

一. Zookeeper事件监听机制

我们基于 zookeeper 上创建的节点，可以对这些节点绑定监听事件，比如可以监听节点数据变更、节点删除、子节点状态变更等事件，通过这个事件机制，可以基于 zookeeper实现分布式锁、集群管理等功能

watcher 特性：当数据发生变化的时候， zookeeper 会产生 $\color{red}{一个}$ watcher 事件，并且会发送到客户端。但是客户端只会收到 $\color{red}{一次}$ 通知。如果后续这个节点再次发生变化，那么之前设置 watcher 的客户端不会再次收到消息。（watcher 是一次性的操作）。 $\color{red}{可以通过循环监听去达到永久监听效果.}$

二 .如何绑定事件机制呢?

以下三个方法均可在使用时候绑定事件.

getData
Exists
getChildren

那么哪些操作会触发事件呢?

如何触发事件？凡是事务类型的操作，都会触发监听事件。
其实也就是create /delete /setData

三 watcher 事件类型

None (-1), 客户端链接状态发生变化的时候，会收到 none 的事件
NodeCreated (1), 创建节点的事件。
NodeDeleted (2), 删除节点的事件
NodeDataChanged (3), 节点数据发生变更
NodeChildrenChanged (4); 子节点被创建、被删除、会发生事件触发

举个栗子

private static void addEvent(String path) throws KeeperException, InterruptedException {
        zooKeeper.exists(path, new Watcher(){
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("触发事件机制的路径为:"+watchedEvent.getPath());
                System.out.println("事件类型为:"+watchedEvent.getType());
            }
        });
    }

结果如下图,这也体现了事件的一次性性质,我们明明改变了两次却只触发了一次.

根据人家ZK文档,这里我们加入循环试试,我在添加事件机制在结束的时候,我又再次的为/test结点添加了事件

   private static void addEvent(String path) throws KeeperException, InterruptedException {
        zooKeeper.exists(path, new Watcher(){
            @Override
            public void process(WatchedEvent watchedEvent) {
                System.out.println("触发事件机制的路径为:"+watchedEvent.getPath());
                System.out.println("事件类型为:"+watchedEvent.getType());
                //再次为该结点绑定监听,使监听机制有效
                try {
                    zooKeeper.exists(watchedEvent.getPath(),true);
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
    }

但是结果如下,我们还是没有监听到事件