写点什么

zookeeper 的 watch 机制

发布于: 2021 年 03 月 25 日
zookeeper的watch机制

Zookeeper 是一个分布式协调服务的开源框架。 主要用来解决分布式集群中应用系统的一致性问题,例如怎样避免同时操作同一数据造成脏读的问题。


ZooKeeper 本质上是一个分布式的小文件存储系统。 提供基于类似于文件系统的目录树方式的数据存储,并且可以对树中的节点进行有效管理。从而用来维护和监控你存储的数据的状态变化。通过监控这些数据状态的变化,从而可以达到基于数据的集群管理。 诸如: 统一命名服务(dubbo)、分布式配置管理(solr 的配置集中管理)、分布式消息队列(sub/pub)、分布式锁、分布式协调等功能。


zookeeper 的特性


  • 1) 全局数据一致:每个 server 保存一份相同的数据副本, client 无论连接到哪个 server,展示的数据都是一致的,这是最重要的特征;

  • 2) 可靠性:如果消息被其中一台服务器接受,那么将被所有的服务器接受。

  • 3) 顺序性:包括全局有序和偏序两种:全局有序是指如果在一台服务器上消息 a 在消息 b 前发布,则在所有 Server 上消息 a 都将在消息 b 前被发布;偏序是指如果一个消息 b 在消息 a 后被同一个发送者发布, a 必将排在 b 前面。

  • 4) 数据更新原子性:一次数据更新要么成功(半数以上节点成功),要么失败,不存在中间状态;

  • 5) 实时性: Zookeeper 保证客户端将在一个时间间隔范围内获得服务器的更新信息,或者服务器失效的信息。


watch 机制


ZooKeeper 提供了分布式数据发布/订阅(pub/sub)功能,一个典型的发布/订阅模型系统定义了一种一对多的订阅关系,能让多个订阅者同时监听某一个主题对象,当这个主题对象自身状态变化时,会通知所有订阅者,使他们能够做出相应的处理。ZooKeeper 中,引入了 Watcher 机制来实现这种分布式的通知功能 。ZooKeeper 允许客户端向服务端注册一个 Watcher 监听,当服务端的一些事件触发了这个 Watcher,那么就会向指定客户端发送一个事件通知来实现分布式的通知功能。触发事件种类很多,如:节点创建,节点删除,节点改变,子节点改变等。


总的来说可以概括 Watcher 为以下三个过程:客户端向服务端注册 Watcher、服务端事件发生触发 Watcher、客户端回调 Watcher 得到触发事件情况


1 watch 机制特点


  • 一次性触发

  • 事件封装

  • event 异步发送

  • 先注册再触发


2 通知状态和事件类型


同一个事件类型在不同的通知状态中代表的含义有所不同,下表列举了常见的通知状态和事件类型。



其中连接状态事件(type=None, path=null)不需要客户端注册,客户端只要有需要直接处理就行了


3 shell 客户端设置 watch 机制


设置节点数据变动监听:


get /aaa000000001 watch
复制代码



通过另一个客户端更改节点数据:


set /aaa0000000001 hello22
复制代码



此时设置监听的节点收到通知:



发布于: 2021 年 03 月 25 日阅读数: 12
用户头像

还未添加个人签名 2021.03.07 加入

还未添加个人简介

评论

发布
暂无评论
zookeeper的watch机制