前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >大数据ZooKeeper(四):ZooKeeper的shell操作

大数据ZooKeeper(四):ZooKeeper的shell操作

作者头像
Lansonli
修改2022-10-02 08:05:54
1.1K0
修改2022-10-02 08:05:54
举报
文章被收录于专栏:Lansonli技术博客Lansonli技术博客

ZooKeeper的shell操作

客户端连接

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

代码语言:javascript
复制
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-05-21 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • ZooKeeper的shell操作
    • 客户端连接
      • shell基本操作
        • 操作命令
        • ​​​​​​​操作实例
        • ​​​​​​​节点属性
      • ​​​​​​​ZooKeeper Watcher(监听机制)
        • ​​​​​​​Watch机制特点
        • ​​​​​​​通知状态和事件类型
        • ​​​​​​​Shell 客户端设置watcher
    相关产品与服务
    命令行工具
    腾讯云命令行工具 TCCLI 是管理腾讯云资源的统一工具。使用腾讯云命令行工具,您可以快速调用腾讯云 API 来管理您的腾讯云资源。此外,您还可以基于腾讯云的命令行工具来做自动化和脚本处理,以更多样的方式进行组合和重用。
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档