第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事件
下一篇:
Linux系统如何重装Windows系统