zookeeper监听机制(Watcher机制)

ops/2025/1/11 12:27:41/

文章目录

  • 引言
  • I zookeeper监听机制
    • Watcher机制实现分布式的通知功能
    • 触发事件种类
    • Watcher的三个过程
  • II watch机制特点
    • 一次性触发
    • 事件封装
    • event异步发送
    • 先注册再触发
    • 常见的通知状态和事件类型
  • III 应用案例(Kafka)
    • Kafka的消息模型
    • Kafka在Zookeeper中保存的元数据
    • Kafka 基于Controller跟Zookeeper进行交互
    • 分区瓶颈
    • Kafka新版去除Zookeeper

引言

ZooKeeper提供了分布式数据发布/订阅功能,一个典型的发布/订阅模型系统定义了一种一对多的订阅关系,能让多个订阅者同时监听某一个主题对象,当这个主题对象自身状态变化时,会通知所有订阅者,使他们能够做出相应的处理。

zookeeper_6">I zookeeper监听机制

Watcher机制实现分布式的通知功能

ZooKeeper中,引入了Watcher机制来实现这种分布式的通知功能。ZooKeeper允许客户端向服务端注册一个Watcher监听,当服务端的一些事件触发了这个Watcher,那么就会向指定客户端发送一个事件通知来实现分布式的通知功能。

触发事件种类

  • 节点创建
  • 节点删除
  • 节点改变
  • 子节点改变

Watcher的三个过程

  • 客户端向服务端注册Watcher
  • 服务端事件发生触发Watcher
  • 客户端回调Watcher得到触发事件情况

II watch机制特点

一次性触发

事件发生触发监听,一个watcher eve


http://www.ppmy.cn/ops/149158.html

相关文章

使用R包Corrplot绘制相关性图

前记 Corrplot是一个用于可视化相关性矩阵的R包。它提供了各种方法和选项来创建高质量的相关性图,并帮助用户更好地理解数据集中的变量之间的相关性。 相关性是指两个或多个变量之间的统计关系,它衡量了这些变量之间的线性关系的强度和方向。在数据分析和…

HTML-表单标签

一、form表单容器标签 <form> 标签在 HTML 中用于定义一个表单容器&#xff0c;用于收集用户输入的数据。它是所有表单元素&#xff08;如文本框、单选按钮、复选框、下拉菜单等&#xff09;的父元素。以下是关于 <form> 标签的详细介绍&#xff0c;包括其特点、用…

算法6--模拟

目录 基础经典例题1576. [替换所有的问号](https://leetcode.cn/problems/replace-all-s-to-avoid-consecutive-repeating-characters/description/)495.[ 提莫攻击](https://leetcode.cn/problems/teemo-attacking/submissions/460223504/)[6. Z 字形变换](https://leetcode.c…

python无需验证码免登录12306抢票 --selenium(2)

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 [TOC](python无需验证码免登录12306抢票 --selenium(2)) 前言 提示&#xff1a;这里可以添加本文要记录的大概内容&#xff1a; 就在刚刚我抢的票&#xff1a;2025年1月8日…

数据采集标注在智能导航系统中的应用案例

‌智能导航系统是一种基于GPS定位技术和人工智能算法的导航软件&#xff0c;其可根据用户的位置、路线和交通情况等信息&#xff0c;提供最佳的出行路线和导航服务‌。‌智能导航系统综合应用了信息管理、认知心理学与行为学、人工智能等多学科理论与技术&#xff0c;自主识别用…

深入Android架构(从线程到AIDL)_22 IPC的Proxy-Stub设计模式04

目录 5、 谁来写Proxy及Stub类呢? 如何考虑人的分工 IA接口知识取得的难题 在编程上&#xff0c;有什么技术可以实现这个方法&#xff1f; 范例 5、 谁来写Proxy及Stub类呢? -- 强龙提供AIDL工具&#xff0c;给地头蛇产出Proxy和Stub类 如何考虑人的分工 由框架开发者…

在Windows环境下搭建无人机模拟器

最近要开发无人机地面站&#xff0c;但是没有无人机&#xff0c;开发无人机对我来说也是大姑娘坐花轿——头一回。我们要用 MAVLink 和无人机之间通信&#xff0c;看了几天 MAVLink&#xff0c;还是不得劲儿&#xff0c;没有实物实在是不好弄&#xff0c;所以想先装一个无人机模…

Swagger学习⑯——@ApiResponses注解

介绍 ApiResponses 是 Swagger/OpenAPI 注解库中的一个注解&#xff0c;用于在 Java 应用程序中为 API 方法定义多个响应。它是 ApiResponse 注解的容器注解&#xff0c;允许你为一个 API 方法指定多个可能的响应。 基本用法 ApiResponses 通常与 ApiResponse 一起使用&…