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事件