当前位置: 首页 > news >正文

Zookeeper Watcher机制--数据变更通知

Zookeeper允许客户端向服务端的某个Znode注册一个Watcher监听,当服务端的一些指定事件触发了这个Watcher,服务端会向指定客户端发送一个事件通知来实现分布式的通知功能,然后客户端根据Watcher通知状态和事件类型做出业务上的改变。

工作机制:

        1、客户端注册watcher

        2、服务端处理watcher

        3、客户端回调watcher

Watcher特性总结

        1.一次性

无论是服务端还是客户端,一旦一个Watcher被触发,Zookeeper都会将其从相应的存储中移除,这样的设计有效的减轻了服务端的压力,不然对于更新非常频繁的节点,服务端会不断的向客户端发送事件通知,无论对于网络还是服务端的压力都非常大。

        2.客户端串行执行

客户端Watcher回调的过程时一个串行的同步的过程

        3.轻量

3.1Watcher通知非常简单,只会告诉客户端发生了事件,而不会说明事件的具体内容。

3.2客户端向服务端注册Watcher的时候,并不会把客户端真实的watcher对象实体传递到服务端,仅仅实在客户端请求中使用boolean类型属性进行了标记

        4.watcher event

watcher event异步发送watcher的通知事件从server发送到client是异步的,这就存在一个问题,不同的客户端和服务器之间通过socket进行通信,由于网络延迟或者其它因素导致客户端在不同的时刻监听到事件,由于zookeeper本身提供了ordering guarantee,即客户监听事件后,才会感知它监视的znode发生了变化,所以我们只用zookeeper不能期望能够监控到节点每次的变化。zookeeper只能保证最终的一致性,而无法保证强一致性。

        5.注册watcher 

getData,exists,个体Children

        6.触发watcher

create、delete、setData

        7.当一个客户端连接到另一个新的服务器上时,watch将会被以任意会话事件触发。当与一个服务器失去连接的时候,是无法收到watch的。而当client重新连接时,如果需要的话,所有先前注册过的watch,都会被重新注册。通常这是完全透明的。只有在一个特殊情况下,watch可能会丢失;对于一个未创建的znode的exist watch,如果在客户端断开来凝结期间被创建了,并且随后在客户端连接上之前又删除了,这种情况下,这个watch事件可能会被丢失

相关文章:

  • ResNet简单解释
  • 深度学习中的epoch, batch 和 iteration
  • 【Python机器学习】零基础掌握MissingIndicator缺失值填充
  • 小黑子—spring:第一章 Bean基础
  • SQL Delete 语句(删除表中的记录)
  • linux 音视频架构 linux音视频开发
  • CRM客户管理系统源码 带移动端APP+H5+小程序
  • Java-API简析_java.net.URL类(基于 Latest JDK)(浅析源码)
  • 牛客网刷题-(7)
  • C++——基于多态的职工管理系统
  • 业务架构、应用架构、技术架构、数据架构
  • Unity性能优化一本通
  • 聊一下Glove
  • Makefile泛谈
  • 归结原理、归结演绎推理
  • 【159天】尚学堂高琪Java300集视频精华笔记(128)
  • 345-反转字符串中的元音字母
  • crontab执行失败的多种原因
  • leetcode386. Lexicographical Numbers
  • Magento 1.x 中文订单打印乱码
  • ReactNativeweexDeviceOne对比
  • SpiderData 2019年2月13日 DApp数据排行榜
  • 闭包--闭包之tab栏切换(四)
  • 模型微调
  • 目录与文件属性:编写ls
  • 前嗅ForeSpider中数据浏览界面介绍
  • 人脸识别最新开发经验demo
  • 算法之不定期更新(一)(2018-04-12)
  • PostgreSQL 快速给指定表每个字段创建索引 - 1
  • 湖北分布式智能数据采集方法有哪些?
  • 资深实践篇 | 基于Kubernetes 1.61的Kubernetes Scheduler 调度详解 ...
  • #stm32驱动外设模块总结w5500模块
  • #Z2294. 打印树的直径
  • (11)MSP430F5529 定时器B
  • (2015)JS ES6 必知的十个 特性
  • (30)数组元素和与数字和的绝对差
  • (pojstep1.1.1)poj 1298(直叙式模拟)
  • (附源码)spring boot球鞋文化交流论坛 毕业设计 141436
  • (介绍与使用)物联网NodeMCUESP8266(ESP-12F)连接新版onenet mqtt协议实现上传数据(温湿度)和下发指令(控制LED灯)
  • (南京观海微电子)——I3C协议介绍
  • (五)关系数据库标准语言SQL
  • (转)linux下的时间函数使用
  • * CIL library *(* CIL module *) : error LNK2005: _DllMain@12 already defined in mfcs120u.lib(dllmodu
  • .NET CORE 2.0发布后没有 VIEWS视图页面文件
  • .net mvc 获取url中controller和action
  • .Net转前端开发-启航篇,如何定制博客园主题
  • [ 数据结构 - C++]红黑树RBTree
  • [.net]官方水晶报表的使用以演示下载
  • [\u4e00-\u9fa5] //匹配中文字符
  • []FET-430SIM508 研究日志 11.3.31
  • [android] 天气app布局练习
  • [C# 网络编程系列]专题六:UDP编程
  • [C#]手把手教你打造Socket的TCP通讯连接(一)
  • [C/C++随笔] char与unsigned char区别
  • [C++] Windows中字符串函数的种类