产品介绍网站模板,微信营销推广,做网站的怎么获取客户信息,怎么自己做网站凑钱文章目录 引言I zookeeper监听机制Watcher机制实现分布式的通知功能触发事件种类Watcher的三个过程II watch机制特点一次性触发事件封装event异步发送先注册再触发常见的通知状态和事件类型III 应用案例(Kafka)Kafka的消息模型Kafka在Zookeeper中保存的元数据Kafka 基于Contr… 文章目录 引言I zookeeper监听机制Watcher机制实现分布式的通知功能触发事件种类Watcher的三个过程 II watch机制特点一次性触发事件封装event异步发送先注册再触发常见的通知状态和事件类型 III 应用案例(Kafka)Kafka的消息模型Kafka在Zookeeper中保存的元数据Kafka 基于Controller跟Zookeeper进行交互分区瓶颈Kafka新版去除Zookeeper 引言
ZooKeeper提供了分布式数据发布/订阅功能,一个典型的发布/订阅模型系统定义了一种一对多的订阅关系,能让多个订阅者同时监听某一个主题对象,当这个主题对象自身状态变化时,会通知所有订阅者,使他们能够做出相应的处理。
I zookeeper监听机制
Watcher机制实现分布式的通知功能
ZooKeeper中,引入了Watcher机制来实现这种分布式的通知功能。ZooKeeper允许客户端向服务端注册一个Watcher监听,当服务端的一些事件触发了这个Watcher,那么就会向指定客户端发送一个事件通知来实现分布式的通知功能。
触发事件种类
节点创建节点删除节点改变子节点改变Watcher的三个过程
客户端向服务端注册Watcher服务端事件发生触发Watcher客户端回调Watcher得到触发事件情况II watch机制特点
一次性触发
事件发生触发监听,一个watcher eve