Zookeeper(4):Zookeeper的监听器原理
2023-09-14 09:14:55 时间
目录
0. 相关文章链接
1. 监听器原理概述
客户端注册监听它关心的目录节点,当目录节点发生变化(数据改变、节点删除、子目录节点增加删除)时,ZooKeeper 会通知客户端。监听机制保证 ZooKeeper 保存的任何的数据的任何改变都能快速的响应到监听了该节点的应用程序。
2. 节点的值变化监听
(1) 在 bigdata1 主机上注册监听/sanguo 节点数据变化
get -w /sanguo
(2)在 bigdata2 主机上修改/sanguo 节点的数据
set /sanguo "xisi"
(3)观察 bigdata1 主机收到数据变化的监听
[zk: localhost:2181(CONNECTED) 4]
WATCHER::
WatchedEvent state:SyncConnected type:NodeDataChanged path:/sanguo
注意:因为只安装了1台机器,所以上述是在单节点上测试
注意:在 bigdata1 再多次修改/sanguo的值, bigdata2 上不会再收到监听。因为注册一次,只能监听一次。想再次监听,需要再次注册。
3. 节点的子节点变化监听(路径变化)
(1)在 bigdata2 主机上注册监听/sanguo 节点的子节点变化
ls -w /sanguo
(2) 在 bigdata1 主机/sanguo 节点上创建子节点
create /sanguo/jin "simayi"
(3) 观察 bigdata2 主机收到子节点变化的监听
WATCHER::
WatchedEvent state:SyncConnected type:NodeChildrenChanged
path:/sanguo
注意: 节点的路径变化,也是注册一次,生效一次。想多次生效,就需要多次注册。
注:其他相关文章链接由此进(包括Zookeeper在内的各大数据组件相关博文) -> 大数据基础知识点 文章汇总
相关文章
- Zookeeper配置Kerberos认证
- zookeeper: zkServer.sh status没有到主机的路由
- Zookeeper的功能以及工作原理
- ZooKeeper 避坑实践:如何调优 jute.maxbuffer
- 迁移 Nacos 和 ZooKeeper,有了新工具
- 分布式协调框架ZooKeeper
- 大数据运维---Zookeeper学习
- zookeeper实现分布式锁的原理及具体使用案例
- zookeeper实现动态获取服务器列表代码示例(服务上下线监听/动态更新服务列表)
- zookeeper 负载均衡 核心机制-实现原理 包含ZAB协议(滴滴,阿里面试)
- Zookeeper原理架构
- Atitit Kafka 使用总结 内容 Kafka2.0 50M1 启动 要启动zookeeper 先,比ativemp麻烦很多啊1 Kafka生产者 1 Kafka消费者2 2
- ZooKeeper管理员指南——部署与管理ZooKeeper
- Zookeeper分布式锁,小小节点真奇妙
- zookeeper api