Watcher 介绍&通知状态事件类型|学习笔记

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 快速学习 Watcher 介绍&通知状态事件类型

开发者学堂课程【大数据 ZooKeeper 快速入门  Watcher 介绍&通知状态事件类型】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/549/detail/7568


Watcher 介绍&通知状态事件类型

 

目录:

一、zookeeper watcher 介绍

二、Watch 机制特点

三、通知状态和事件类型

 

课程概要:下面来学习 zookeeper 中的 watcher 监听机制

 

一、Zookeeper Watcher

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

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

ZooKeeper 允许客户端向服务端注册一个 Watcher 监听,监听感兴趣的事件,监听一个节点的创建删除和改变,监听它的子节点是否发生改变,当服务端的一些事件触发了这个 Watcher,那么就会向指定客户端发送一个事件通知来实现分布式的通知功能。

触发事件种类很多,如:节点创建,节点删除,节点改变,子节点改变等。监听事件发生后,意味着事件发生,设置的监听就会被触发。

总的来说可以概括 Watcher 为以下三个过程;

(1)客户端向服务端注册 Watcher

(2)服务端事件发生触发 Watcher

(3)客户端回调 Watcher 得到触发事件情况

 

二、Watch 机制特点

1.一次性触发

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

2. 事件封装

ZooKeeper 使用 WatchedEvent 对象来封装服务端事件并传递。WatchedEvent 包含了每一个事件的三个基本属性:

通知状态(keeperState)

事件类型(EventType)

节点路径(path)

客户端根据属性获取感兴趣的数据

3.event 异步发送

watcher 的通知事件从服务端发送到客户端是异步的。服务端监听触发后异步发送。

4.先注册再触发

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

 

三、通知状态和事件类型

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

KepperState

EventType

触发条件

说明

 

None(-1)

客户端与服务端成功建立

 

SyncConnected

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进行权限2.SASL权限检查失败

通常也会收到AuthFailedException异常

EventType 是数据节点 znode 发生变化时对应的通知类型。EventType 变化时 KeeperState 永远处于 SyncConnected 通知状态下;当 keeperState 发生变化时,EventType 永远为 None。

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

 

 

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
相关文章
|
12月前
Listener概述、监听对象的创建和销毁、监听域对象属性变化、监听会话相关的感知型监听器及监听器实现
Listener概述、监听对象的创建和销毁、监听域对象属性变化、监听会话相关的感知型监听器及监听器实现
70 0
|
JavaScript
DOM注册事件以及删除事件
注册事件以及删除事件 注册事件(绑定事件) 注册事件也就是给元素添加事件,成为注册事件或者绑定事件。
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(一)
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(一)
116 0
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(二)
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(二)
96 0
【EventBus】事件通信框架 ( 发送事件 | 根据事件类型获取订阅者 | 调用订阅方法 )
【EventBus】事件通信框架 ( 发送事件 | 根据事件类型获取订阅者 | 调用订阅方法 )
112 0
【EventBus】事件通信框架 ( 订阅方法注册 | 注册 事件类型 - 订阅类 + 订阅方法 到指定集合 | 取消注册 数据准备 )
【EventBus】事件通信框架 ( 订阅方法注册 | 注册 事件类型 - 订阅类 + 订阅方法 到指定集合 | 取消注册 数据准备 )
106 0
|
缓存
【EventBus】事件通信框架 ( 订阅类-订阅方法缓存集合 | 事件类型-订阅者集合 | 订阅对象-事件类型集合 )
【EventBus】事件通信框架 ( 订阅类-订阅方法缓存集合 | 事件类型-订阅者集合 | 订阅对象-事件类型集合 )
199 0