第1关：节点监听机制

ZooKeeper的监听机制

节点监听机制用以保证集群之间的一致性，以及服务器可以及时通知客户端节点状态的变化。

一个节点可以被监控，包括路径中存储的数据修改，子节点路径改变，当该节点发生修改，服务器可以通知设置监控的客户端。这个功能是ZooKeeper对于应用最重要的特性，通过节点监控机制可以实现的功能包括：1.配置集中管理，2.集群管理，3.分布式锁，等等。

监听机制的三个要点

• 一次性的触发器（One-time trigger）

  当节点数据发生变化时，服务器会向设置了监听的客户端发送一个watch事件。 例如，如果客户端执行get /znode1 watch，稍后更改或删除/znode1的数据，则客户端将获得/znode1的watch事件。 如果/znode1再次更改，则除非客户端已设置新的监听，否则不会发送watch事件。

• 发送至客户端(Sent to the client)

  watch事件异步发送到客户端。Zookeeper保证客户端发送过去的更新顺序是有序的。例如：某个节点没有设置watcher，那么客户端对这个节点设置watcher发送到集群之前，该客户端是感知不到该节点的改变的。

• 设置watch的数据内容(The data for which the watch was set)

  节点改变有很多种方式，例如：节点创建\删除，子节点改变，节点数据改变等等。Zookeeper维护了两个watch列表，一个节点数据watch列表，另一个是子节点watch列表。

Client（zkCli.sh）监听设置的3种命令

• stat stat设置节点监听直接在命令后加watch即可，例如，要监听节点/zoo1(首先创建该节点，节点数据为空)的变化，使用以下命令：

  stat /zoo1 watch
  

 

• 设置节点/zoo1监听后，修改节点状态（这里更新该节点的数据，例如更新为sssss），使用以下命令：

  set /zoo1 "sssss"
  

 

• 注意：设置节点监听后，由于监听机制的一次性触发机制，当再次修改节点/zoo1数据时，也不会触发watch事件。

• ls

ls命令监听当前节点的子节点数量是否改变，命令使用方式与stat一致。

• get

get命令监听当前节点数据的变化，也可以监听节点是否被删除，命令使用方式与stat一致。

编程要求

本关任务是使用命令行，进行以下操作：

• 开启ZooKeeper服务器。

• 使用客户端（zkCli.sh）连接客户端（IP：127.0.0.1，端口号：2181）。

• 创建/spnode持久节点（节点数据为空）。

zkServer.sh start
zkCli.sh -server 127.0.0.1:2181
create /spnode ""
 
 

• 使用get命令监听/spnode。

get /spnode watch

• 修改/spnode的节点值（当前客户端修改），观察watch事件。

• 再次使用get命令监听/spnode。

• 点击评测（评测中修改节点值，其他客户端修改），观察watch事件。

 
set /spnode "first"(观察watch事件)
get /spnode watch
点击评测后，观察watch事件