文档章节

ZooKeeper的Watcher机制

Java搬砖工程师
 Java搬砖工程师
发布于 2018/11/19 16:46
字数 814
阅读 291
收藏 0

ZooKeeper 提供了分布式数据的发布/订阅功能。

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

  •  Watcher 机制主要包括客户端线程客户端 WatchManager ZooKeeper 服务器三部分。
  •  - ZooKeeper :部署在远程主机上的 ZooKeeper 集群,当然,也可能是单机的。 
    - Client :分布在各处的 ZooKeeper 的 jar 包程序,被引用在各个独立应用程序中。 
    - WatchManager :一个接口,用于管理各个监听器,只有一个方法 materialize(),返回一个 Watcher 的 set。

在具体流程上(简单讲),

  • 客户端在向 ZooKeeper 服务器注册 Watcher 的同时,会将 Watcher 对象存储在客户端的 WatchManager 中。
  • 当ZooKeeper 服务器触发 Watcher 事件后,会向客户端发送通知,
  • 客户端线程从 WatchManager 的实现类中取出对应的 Watcher 对象执行回调逻辑

工作机制

  • Watcher 机制,总的来说可以分为三个过程:客户端注册 Watcher服务器处理 Watcher客户端回调 Watcher
  • 其内部各组件之间的关系如图:
  • 在创建一个 ZooKeeper 客户端对象实例时,可以向构造方法中传入一个默认的 Watcher:
    • 这个 Watcher 将作为整个 ZooKeeper会话期间的默认 Watcher,会一直被保存在客户端 ZKWatchManagerdefaultWatcher 中。
    • ZooKeeper 客户端也可以通过 getDataexistsgetChildren 三个接口来向 ZooKeeper 服务器注册 Watcher
      • 无论哪种方式,注册 Watcher 的工作原理都是一致的。

ZooKeeper 的 Watcher 具有以下几个特性。

  • 一次性 
    • 无论是服务端还是客户端,一旦一个 Watcher 被触发,ZooKeeper 都会将其从相应的存储中移除。
    • 因此,在 Watcher 的使用上,需要反复注册。这样的设计有效地减轻了服务端的压力。
  • 客户端串行执行 
    • 客户端 Watcher 回调的过程是一个串行同步的过程,这为我们保证了顺序
    • 同时,需要注意的一点是,一定不能因为一个 Watcher 的处理逻辑影响了整个客户端的 Watcher 回调,
      • 所以,我觉得客户端 Watcher 的实现类另开一个线程进行处理业务逻辑,以便给其他的 Watcher 调用让出时间。
  • 轻量级
    • WatchedEvent 是最小通知单元
      • 仅仅包括:通知状态、事件类型、节点路径
    • 仅仅通知客户端发生了事件,不会带事件具体内容,具体内容需要客户端再次请求获取
    • 客户端向服务端传递的也不是watcher 对象,使用Boolean类型标记属性,服务端保存当前连接的ServerCnxn

watcher 事件类型

© 著作权归作者所有

Java搬砖工程师
粉丝 36
博文 640
码字总数 343291
作品 0
南京
程序员
私信 提问
[ZooKeeper]基于Java API 实践

前提 建立maven项目中 要导入zookeeper的依赖 我们同时可以打开linux中的zookeeper客户端来验证对比。输入 zkCli.sh 便可以进入zookeeper客户端 。 一、建立连接 直接建立连接后,不进行等待...

瑾兰
2018/06/13
0
0
基于 ZooKeeper 实现爬虫集群的监控

ZooKeeper ZooKeeper 是一个开源的分布式协调服务,ZooKeeper框架最初是在“Yahoo!"上构建的,用于以简单而稳健的方式访问他们的应用程序。 后来,Apache ZooKeeper成为Hadoop,HBase和其他分...

fengzhizi715
05/26
0
0
Zookeeper 的功能,安装使用方法,可视化工具ZooInspector

http://zookeeper.apache.org/ Apache ZooKeeper is an effort to develop and maintain an open-source server which enables highly reliable distributed coordination. 一、zookeeper提供......

逝水丶
2017/11/05
1K
0
中小研发团队架构实践之分布式协调器.Net版ZooKeeper

一、ZooKeeper是什么 Apache ZooKeeper是由Apache Hadoop的子项目发展而来,于2010年11月正式成为了Apache的顶级项目。 ZooKeeper是一个开放源代码的分布式协调服务。它具有高性能、高可用的...

Java干货分享
01/11
13
0
一文了解Zookeeper的Watcher机制

Zookeeper系列介绍(持续更新) Zookeeper基础初探 一文了解Zookeeper数据节点-znode 一文了解Watcher Zookeeper分布式锁实现 Zookeeper部署模式   Zookeeper提供了数据的发布/订阅功能,多...

Java花园
06/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

反编译9.png图片还原

本文链接:https://blog.csdn.net/a1140778530/article/details/10528507 经常反编译apk文件找资源,9.png的文件处理起来很麻烦。 最近使用Ant自动编译打包app时,从别处搜罗来的9.png文件导...

shzwork
30分钟前
6
0
Shell脚本应用 – for、while循环语句

一、for循环语句 在实际工作中,经常会遇到某项任务需要多次执行的情况,而每次执行时仅仅是处理的对象不一样,其他命令相同。例如:根据通讯录中的姓名列表创建系统账号等情况。 当面对各种...

linux-tao
30分钟前
5
0
RPA风潮下企业财务工作模式的变革

RPA(机器人流程自动化)在财务领域的应用,正给企业财务带来前所未有的改变。 前RPA时代,财务领域面临的痛点 在RPA机器人应用之前,企业财务工作进程的推进,主要通过财务人员人工操作或信...

UiBot
35分钟前
5
0
Hive之命令行修改表注释

最近遇到一个需求,在不重建表的情况下,修改表的注释,hive有没有类似关系型数据库的SQL命令来修改呢,找了下,亲测有效,如下List-1 List-1 hive>use your_schemahvie>ALTER TABLE tabl...

克虏伯
36分钟前
5
0
是什么,它的作用是什么

在HTML文档的首部往往会有这么一句话<!DOCTYPE html>,许多时候我们忽视了它的存在,它实际上是一个声明,告诉浏览器用哪种HTML版本的规范来解读HTML文档。 尽管我们不给出这句声明浏览器照样...

前端老手
41分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部