【郑州校区】大数据基础加强阶段2之ZooKeeper Watcher

ZooKeeper 提供了分布式数据发布/订阅功能，一个典型的发布/订阅模型系

统定义了一种一对多的订阅关系，能让多个订阅者同时监听某一个主题对象，当这个主题对象自身状态变化时，会通知所有订阅者，使他们能够做出相应的处理。

ZooKeeper 中， 引入了 Watcher 机制来实现这种分布式的通知功能。

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

触发事件种类很多，如：节点创建，节点删除，节点改变，子节点改变等。总的来说可以概括 Watcher 为以下三个过程：客户端向服务端注册 Watcher、

服务端事件发生触发 Watcher、客户端回调 Watcher 得到触发事件情况

4.1 ． Watch 机制特点

一次性触发   

事件发生触发监听，一个 watcher event 就会被发送到设置监听的客户端， 这种效果是一次性的，后续再次发生同样的事件，不会再次触发。

事件封装

ZooKeeper 使用 WatchedEvent 对象来封装服务端事件并传递。

WatchedEvent 包含了每一个事件的三个基本属性：

通知状态（keeperState），事件类型（EventType）和节点路径（path） event 异步发送   

watcher 的通知事件从服务端发送到客户端是异步的。先注册再触发

Zookeeper 中的 watch 机制，必须客户端先去服务端注册监听，这样事件发送才会触发监听，通知给客户端。

         

4.2 ． 通知状态和事件类型

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

KeeperState	EventType	触发条件	说明
	None （-1）	客户端与服务端成功建立连接
SyncConnected （0）	NodeCreated （1）	Watcher 监听的对应数据节点被创建
	NodeDeleted （2）	Watcher 监听的对应数据节点被删除	此时客户端和服务器处于连接状态
	NodeDataChanged （3）	Watcher 监听的对应数据节点的数据内容 发生变更
	NodeChildChanged （4）	Wather 监听的对应数据节点的子节点列 表发生变更
Disconnected （0）	None （-1）	客户端与 ZooKeeper 服务器 断开连接	此时客户端和服务器处于断开连接状态
Expired （-112）	Node （-1）	会话超时	此时客户端会话失效，通常同时也会受到 SessionExpiredException 异常
AuthFailed （4）	None （-1）	通常有两种情况， 1：使用错误的 schema 进行权限检	通常同时也会收到 AuthFailedException 异常

查 2：SASL 权限检查失败

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

         

4.3 ． Shell 客户端设置 watcher

设置节点数据变动监听：

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

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

传智播客·黑马程序员郑州校区地址

河南省郑州市 高新区长椿路11号大学科技园（西区）东门8号楼三层

联系电话 0371-56061160/61/62

来校路线  地铁一号线梧桐街站A口出

【郑州校区】大数据基础加强阶段2之ZooKeeper Watcher

ZooKeeper 提供了分布式数据发布/订阅功能，一个典型的发布/订阅模型系

统定义了一种一对多的订阅关系，能让多个订阅者同时监听某一个主题对象，当这个主题对象自身状态变化时，会通知所有订阅者，使他们能够做出相应的处理。

ZooKeeper 中， 引入了 Watcher 机制来实现这种分布式的通知功能。

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

触发事件种类很多，如：节点创建，节点删除，节点改变，子节点改变等。总的来说可以概括 Watcher 为以下三个过程：客户端向服务端注册 Watcher、

服务端事件发生触发 Watcher、客户端回调 Watcher 得到触发事件情况

4.1 ． Watch 机制特点

一次性触发   

事件发生触发监听，一个 watcher event 就会被发送到设置监听的客户端， 这种效果是一次性的，后续再次发生同样的事件，不会再次触发。

事件封装

ZooKeeper 使用 WatchedEvent 对象来封装服务端事件并传递。

WatchedEvent 包含了每一个事件的三个基本属性：

通知状态（keeperState），事件类型（EventType）和节点路径（path） event 异步发送   

watcher 的通知事件从服务端发送到客户端是异步的。先注册再触发

Zookeeper 中的 watch 机制，必须客户端先去服务端注册监听，这样事件发送才会触发监听，通知给客户端。

         

4.2 ． 通知状态和事件类型

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

KeeperState	EventType	触发条件	说明
	None （-1）	客户端与服务端成功建立连接
SyncConnected （0）	NodeCreated （1）	Watcher 监听的对应数据节点被创建
	NodeDeleted （2）	Watcher 监听的对应数据节点被删除	此时客户端和服务器处于连接状态
	NodeDataChanged （3）	Watcher 监听的对应数据节点的数据内容 发生变更
	NodeChildChanged （4）	Wather 监听的对应数据节点的子节点列 表发生变更
Disconnected （0）	None （-1）	客户端与 ZooKeeper 服务器 断开连接	此时客户端和服务器处于断开连接状态
Expired （-112）	Node （-1）	会话超时	此时客户端会话失效，通常同时也会受到 SessionExpiredException 异常
AuthFailed （4）	None （-1）	通常有两种情况， 1：使用错误的 schema 进行权限检	通常同时也会收到 AuthFailedException 异常

查 2：SASL 权限检查失败

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

         

4.3 ． Shell 客户端设置 watcher

设置节点数据变动监听：

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

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

传智播客·黑马程序员郑州校区地址

河南省郑州市 高新区长椿路11号大学科技园（西区）东门8号楼三层

联系电话 0371-56061160/61/62

来校路线  地铁一号线梧桐街站A口出