Apache ZooKeeper - 事件监听机制详解

￡神魔★判官ぃ 2022-12-21 15:55 205阅读 0赞

### 文章目录 ###

*  事件监听机制命令
 *  Zookeeper事件类型
 *  实操 -w
 *   *  get -w /path 监听节点数据的变化
     *  ls -w /path 监听子节点的变化（增，删） \[监听目录\]
     *  ls -w /path 例子二 循环递归的监听
     *  stat -w path 监听节点属性的变化

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center]

# 事件监听机制命令 #

添加 -w 参数可实时监听节点与子节点的变化，并且实时收到通知。非常适用保障分布式情况下的数据一至性。

其使用方式如下

<table> 
 <thead> 
  <tr> 
   <th>命令</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>ls -w path</td> 
   <td>监听子节点的变化（增，删） [监听目录]</td> 
  </tr> 
  <tr> 
   <td>get -w path</td> 
   <td>听节点数据的变化</td> 
  </tr> 
  <tr> 
   <td>stat -w path</td> 
   <td>监听节点属性的变化</td> 
  </tr> 
  <tr> 
   <td>printwatches on</td> 
   <td>off</td> 
  </tr> 
 </tbody> 
</table>

--------------------

针对节点的监听：一旦事件触发，对应的注册立刻被移除，所以事件监听是一次性的 . 依靠的客户端和服务端建立的长连接实现的实时推送。

--------------------

# Zookeeper事件类型 #

*  None: 连接建立事件
 *  NodeCreated： 节点创建
 *  NodeDeleted： 节点删除
 *  NodeDataChanged：节点数据变化
 *  NodeChildrenChanged：子节点列表变化
 *  DataWatchRemoved：节点监听被移除
 *  ChildWatchRemoved：子节点监听被移除

--------------------

# 实操 -w #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 1]

--------------------

## get -w /path 监听节点数据的变化 ##

【会话一】  
![在这里插入图片描述][20201117233450993.png_pic_center]

然后新开启一个会话，去修改这个节点

【会话二】  
![在这里插入图片描述][2020111723352032.png_pic_center]

重新回到【会话一】

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 2]  
观察节点属性的变化

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 3]

--------------------

## ls -w /path 监听子节点的变化（增，删） \[监听目录\] ##

【会话一】  
![在这里插入图片描述][20201117235819741.png_pic_center]  
【会话二】

![在这里插入图片描述][20201117235913834.png_pic_center]

切到【会话一】 观察输出的监听日志

![在这里插入图片描述][20201117235949172.png_pic_center]

当然了 delete 目录，也会发生变化

如果对节点数据内容，ls -w 是收不到通知的，只能通过 get -w来实现 。

这里，监听一点触发，就失效了，切记。

## ls -w /path 例子二 循环递归的监听 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 4]

如果监听了某个目录，那么该目录下的子目录的变更也会被监听到。 当然了 也是一次性的。

--------------------

## stat -w path 监听节点属性的变化 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 5]

--------------------

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 6]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/8b4d0113a40745d0a0fb82fa875c4676.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 1]: https://img-blog.csdnimg.cn/20201117232741134.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center
[20201117233450993.png_pic_center]: https://img-blog.csdnimg.cn/20201117233450993.png#pic_center
[2020111723352032.png_pic_center]: https://img-blog.csdnimg.cn/2020111723352032.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 2]: https://img-blog.csdnimg.cn/20201117233621846.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 3]: https://img-blog.csdnimg.cn/2020111723401164.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center
[20201117235819741.png_pic_center]: https://img-blog.csdnimg.cn/20201117235819741.png#pic_center
[20201117235913834.png_pic_center]: https://img-blog.csdnimg.cn/20201117235913834.png#pic_center
[20201117235949172.png_pic_center]: https://img-blog.csdnimg.cn/20201117235949172.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 4]: https://img-blog.csdnimg.cn/20201118002328683.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 5]: https://img-blog.csdnimg.cn/20201118001831907.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center 6]: https://img-blog.csdnimg.cn/20201118002637358.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ==,size_16,color_FFFFFF,t_70#pic_center