zookeeper的watch机制原理解析

一、Watch机制介绍

我们可以把 Watch 理解成是注册在特定 Znode 上的触发器。当这个 Znode 发⽣改变，也就是调⽤了 create ， delete ， setData ⽅法的时候，将会触发 Znode 上注册的对应事件，请求 Watch 的客户端会接收到异步通知。

具体交互过程如下：

• 客户端调⽤ getData ⽅法的时候， watch 参数设置为 true 。服务端接到请求，返回节点数据，并 且在对应的哈希表⾥插⼊被 Watch的 Znode 路径。
• 当被 Watch 的 Znode 已删除，服务端会查找哈希表，找到该 Znode 对应的所有

Watcher，异步通知客户端，并且删除哈希表中对应的 Key-Value。

这里的服务端指的是zk的服务端。

客户端使⽤了NIO通信模式监听服务端的调⽤。

二、zkCli客户端使⽤watch

zkCli客户端常用命令详解：

https://www.jb51.net/article/252869.htm

• create /test:创建test节点
• set /test aaa:给test节点赋值aaa数据
• get -w /test:⼀次性监听节点，注意这里是监听的数据变化，假如test子节点的数据发生变化也是收不到监听消息的（假如在监听节点下创建和删除子节点这些都是监听不到的，但是删除监听的节点是可以监听到的）
• ls -w /test :监听⽬录,创建和删除⼦节点会收到通知。⼦节点中新增节点不会收到通知
• ls -R -w /test :对于⼦节点中⼦节点的变化，但内容的变化不会收到通知

2.1、get -w命令详解

创建一个节点后，然后通过 get -w /test监听节点，然后使用另外一个客户端对该节点进行了赋值，这时候可以看到收到的监听消息。

监听到后并不是监听到修改后新的值，而是类似于一个消息，意思是告诉他节点发生变化了。这时候可以通过get /test命令来获取节点被修改后的值。

再次使用另一个客户端set了一下值，并没有监听到消息，因为 get -w /test是⼀次性监听节点。

假如想一直监听的话，可以在收到监听消息后，立马再执行 get -w /test命令。

删除节点是可以监听到的，监听到的消息事件类型和数据修改是不一样的。

2.2、ls -w命令详解

ls -w监听当前节点的创建和删除

又使用命令开启了监听，然后在刚刚创建的sub1节点下又创建了一个子节点，这时候收不到监听的。

2.3、ls -R -w命令详解

三、curator客户端使⽤watch

springboot整合curator客户端：https://www.jb51.net/article/252816.htm

我直接是基于上一篇文章当中的项目进行watch练习！

@Test
/**
  * 监听test节点
  *
  * @throws Exception
  */
 @Test
 public void addNodeListener() throws Exception {

     NodeCache nodeCache = new NodeCache(curatorFramework, "/test");
     nodeCache.getListenable().addListener(new NodeCacheListener() {
         @Override
         public void nodeChanged() throws Exception {
             log.info("{} path nodeChanged: ", "/test");
             printNodeData();
         }
     });
     nodeCache.start();
     // 阻塞线程
     System.in.read();
 }

 /**
  * 获取test节点数据并打印
  *
  * @throws Exception
  */
 public void printNodeData() throws Exception {
     byte[] bytes = curatorFramework.getData().forPath("/test");
     log.info("data: {}", new String(bytes));
 }

到此这篇关于zookeeper的watch机制原理解析的文章就介绍到这了,更多相关zookeeper watch机制内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！