目录

ZooKeeper的shell操作

客户端连接

shell基本操作

操作命令

操作实例

节点属性

​​​​​​​ZooKeeper Watcher(监听机制)

​​​​​​​Watch机制特点

​​​​​​​通知状态和事件类型

​​​​​​​Shell 客户端设置watcher


ZooKeepershell操作

客户端连接

运行 zkCli.sh –server ip   进入命令行工具。

bin/zkCli.sh  -server node1:2181

shell基本操作

操作命令

命令

说明

参数

create [-s] [-e] path data acl

创建Znode

-s 指定是顺序节点<br>-e 指定是临时节点

ls path [watch]

列出Path下所有子Znode

get path [watch]

获取Path对应的Znode的数据和属性

ls2 path [watch]

查看Path下所有子Znode以及子Znode的属性

set path data [version]

更新节点

version 数据版本

delete path [version]

删除节点, 如果要删除的节点有子Znode则无法删除

version 数据版本

rmr path

删除节点, 如果有子Znode则递归删除

setquota -n|-b val path

修改Znode配额

-n 设置子节点最大个数<br>-b 设置节点数据最大长度

history

列出历史记录

​​​​​​​操作实例

1:创建普通节点

create /app1 hello

2: 创建顺序节点

create -s /app2 world

3:创建临时节点

create -e /tempnode world

4:创建顺序的临时节点

create -s -e /tempnode2 aaa

5:获取节点数据

get  /app1

6:修改节点数据

set /app1  hadoop

7:删除节点

delete  /app1 删除的节点不能有子节点

rmr    /app1 递归删除

​​​​​​​节点属性

每个znode都包含了一系列的属性,通过命令get,可以获得节点的属性。

dataVersion:数据版本号,每次对节点进行set操作,dataVersion的值都会增加1(即使设置的是相同的数据),可有效避免了数据更新时出现的先后顺序问题。

cversion :子节点的版本号。当znode的子节点有变化时,cversion 的值就会增加1。

cZxid :Znode创建的事务id。

mZxid :Znode被修改的事务id,即每次对znode的修改都会更新mZxid。

对于zk来说,每次的变化都会产生一个唯一的事务id,zxid(ZooKeeper Transaction Id)。通过zxid,可以确定更新操作的先后顺序。例如,如果zxid1小于zxid2,说明zxid1操作先于zxid2发生,zxid对于整个zk都是唯一的,即使操作的是不同的znode。

ctime:节点创建时的时间戳.

mtime:节点最新一次更新发生时的时间戳.

ephemeralOwner:如果该节点为临时节点, ephemeralOwner值表示与该节点绑定的session id. 如果不是, ephemeralOwner值为0.

在client和server通信之前,首先需要建立连接,该连接称为session。连接建立后,如果发生连接超时、授权失败,或者显式关闭连接,连接便处于CLOSED状态, 此时session结束。

​​​​​​​ZooKeeper Watcher(监听机制)

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

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

触发事件种类很多,如:节点创建,节点删除,节点改变,子节点改变等。

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

​​​​​​​Watch机制特点

一次性触发

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

事件封装

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

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

通知状态(keeperState),事件类型(EventType)和节点路径(path)

event异步发送

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

先注册再触发

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

​​​​​​​通知状态和事件类型

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

事件封装: Watcher 得到的事件是被封装过的, 包括三个内容 keeperState, eventType, path

KeeperState

EventType

触发条件

说明

None

连接成功

SyncConnected

NodeCreated

Znode被创建

此时处于连接状态

SyncConnected

NodeDeleted

Znode被删除

此时处于连接状态

SyncConnected

NodeDataChanged

Znode数据被改变

此时处于连接状态

SyncConnected

NodeChildChanged

Znode的子Znode数据被改变

此时处于连接状态

Disconnected

None

客户端和服务端断开连接

此时客户端和服务器处于断开连接状态

Expired

None

会话超时

会收到一个SessionExpiredExceptio

AuthFailed

None

权限验证失败

会收到一个AuthFailedException

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

​​​​​​​Shell 客户端设置watcher

设置节点数据变动监听:

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

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

2021年大数据ZooKeeper(四):ZooKeeper的shell操作相关推荐

  1. 大数据学习笔记:HBase Shell操作

    文章目录 一.启动HBase Shell 二.HBase Shell操作 (一)help - 帮助命令 1.查看某个命令的帮助信息 2.查看某个命令组的帮助信息 (二)general - 通用类命令 ...

  2. 客快物流大数据项目(四十七):Spark操作Kudu Native RDD

    目录 Spark操作Kudu Native RDD Spark操作Kudu Native RDD Spark与Kudu的集成同时提供了kudu RDD 代码示例 val columnsList = L ...

  3. 大数据课堂笔记 HDFS的shell操作

    一.HDFS常用命令操作实战 启动Hadoop集群 执行命令   start-yarn.sh  1.创建目录 (1).单层目录 执行命令  hdfs dfs -mkdir /ied 利用WebUI查看 ...

  4. 2021年大数据Kafka(四):❤️kafka的shell命令使用❤️

    全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 Kafka的shell命令使用 一.创建topic 二.生产 ...

  5. 2021年大数据HBase(十四):HBase的原理及其相关的工作机制

    全网最详细的大数据HBase文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 HBase的原理及其相关的工作机制 一.HBase的flus ...

  6. 2021年大数据Hadoop(十四):HDFS的高可用机制

    全网最详细的Hadoop文章系列,强烈建议收藏加关注! 后面更新文章都会列出历史文章目录,帮助大家回顾知识重点. 目录 本系列历史文章 前言 HDFS的高可用机制 HDFS高可用介绍 组件介绍 Nam ...

  7. 2021年大数据ELK(四):Lucene的美文搜索案例

    全网最详细的大数据ELK文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 美文搜索案例 一.需求 二.准备工作 1.创建IDEA项目 2. ...

  8. 2021年大数据HBase(四):HBase的相关操作-客户端命令式!【建议收藏】

    全网最详细的大数据HBase文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 前言 HBase的相关操作-客户端命令式 1.进入HBase ...

  9. 2021年大数据Hive(四):Hive查询语法

    全网最详细的Hive文章系列,强烈建议收藏加关注! 后面更新文章都会列出历史文章目录,帮助大家回顾知识重点. 目录 系列历史文章 前言 hive查询语法 一.SELECT语句 1.语句结构 2.全表查 ...

  10. 2021年大数据ELK(二):Elasticsearch简单介绍

    全网最详细的大数据ELK文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录 系列历史文章 一.Elasticsearch简介 1.介绍 2.创始人 二.E ...

最新文章

  1. 超越Facebook、谷歌、微软,百度发布全球首个百亿参数对话预训练生成模型PLATO-XL...
  2. 1.python全栈之路:python基础
  3. 黑马vue---8-10、v-cloak、v-text、v-html、v-bind、v-on的基本使用
  4. Interview:算法岗位面试—2019秋招校园招聘—算法工程师【机器学习、深度学习(偏图像)】秋招感悟:初期阶段的傲娇→中期阶段的紧张→后期阶段的蜕变
  5. Ubuntu18.04 MariaDB
  6. python tkinter怎么读_Tkinter GUI与阅读系列
  7. 如何实现下拉框的绑定
  8. HTH的完整形式是什么?
  9. Golang入门(1):安装与配置环境变量的意义
  10. 机器学习经典算法笔记——PCA和梯度上升算法
  11. Spring框架第一天
  12. esri-leaflet入门教程(1)-leaflet介绍
  13. 【JAVA】家庭记账系统
  14. 计算机时代前的发明,假如1万人回到150万年前,只带简单工具,多久才能制造出计算机?...
  15. 试用蓝牙模块的一点经验整理(Part 3, 关于iBeacon功能 )
  16. 粒子效果动画使用总结
  17. java综合知识点总结-必背
  18. SrpingCloud微服务 服务调用逻辑图
  19. 漫威java_10年漫威,到底有多少角色。
  20. pdf怎么转换成jpg图片效果好

热门文章

  1. 抽样方法,采样方法 shuffle
  2. 宿主机虚拟机文件复制 apt-get 换成yum
  3. dataframe构建
  4. bootstrap上传文件美化
  5. SpringBoot整合MyBatis详细教程~
  6. 特斯拉超级计算机Dojo
  7. MLIR算子量化Quantization
  8. GIT上传服务器同步到web目录
  9. Error:(1, 0) Your project path contains non-ASCII characters.
  10. Handler的postDelayed()关闭的方法