- zookeeper的基本知识
- zookeeper的数据结构:zookeeper提供的命名空间非常类似于标准的文件系统,key-value的形式存储,名称key由/分割的一系列路径元素,zookeeper名称空间中的每个节点都是一个路径标志。
- windows下的zookeeper安装:
- 在官网下载安装包,解压到本地目录文件夹下面,官网路径:https://zookeeper.apache.org/releases.html#releasenotes
- 修改配置文件zoo_sample.cfg 复制一份 重命名为zoo,cfg
- 在安装目录下面新建一个空的data文件夹和Log文件夹
- 修改zoo.cfg配置文件,将dataDir=/tmp/zookeeper修改成zookeeper安装目录所在的data文件夹,再添加一条数据日志的配置。(需要根据自己的安装路径来修改)
- 然后双击zkServer.cmd启动程序。
- 控制台显示bind to port 0.0.0.0/0.0.0.0:2181,表示服务端启动成功
- 双击zkCli.cmd启动客户端:
- 出现welcom to zookeeper! 表示我们成功启动客户端。
- zookeeper java客户端搭建
- 工具:IDEA 创建一个maven工程。命名为zookeeper-demo,并且引入如下依赖,可以自行在maven中央仓库选择合适的版本,maven依赖:
-
<dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.11</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.8</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>4.0.0</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>4.0.0</version> </dependency>
public static void main(String[] args){ try{ final CountDownLatch countDownLatch=new CountDownLatch(1); Zookeeper zooKeeper= new Zookeeper("192.168.3.33:2181,"+ "192.168.3.35:2181,192.168.3.37:2181",4000,new Watcher(){ @Override public void process(WatchedEvent event){ if(Event.KeeperState.SyncConnected==event.getState()){ //如果收到了服务端的响应事件,连接成功 countDownLatch.countDown(); } } }); countDownLatch.await(); System.out.println(zookeeper.getState()); } }
zookeeper数据模型znode结构详解
-
在zookeeper中,可以说zookeeper中所有存储的数据是由znode组成的,节点也称为znode,并且以key/value形式存储数据。
-
整体结构类似于linux文件系统的模式以树形结构存储,其中以根路径/开头。
-
进入zookeeper安装的bin目录,通过sh zkCli.sh 打开命令行终端,执行ls /命令显示
-
ls /
-
ls /zookeeper
-
ls /zookeeper/quota
-
znode的状态属性
-
czxid 创建节点时的事务ID
-
ctime 创建节点时的时间
-
mzxid 最后修改节点时的事务ID
-
mtime 最后修改节点时的时间
-
pzxid 表示该节点的子节点列表最后一次修改的事务ID,
-
5、watch 机制,监听节点变化
事件监听机制类似于观察者模式,watch 流程是客户端向服务端某个节点路径上注册一个 watcher,同时客户端也会存储特定的 watcher,当节点数据或子节点发生变化时,服务端通知客户端,客户端进行回调处理。特别注意:监听事件被单次触发后,事件就失效了。
提示:参考常用命令章节 get 命令监听 watch 使用,后面章节将详细介绍 watch 实现原理。
zookeeper的ACL 权限在生产环境是特别中药的
ACL权限可以针对节点设置相关读写等权限 保障数据安全性
permission可以指定不同的权限范围以及角色
ACL命令行
getAcl命令 获取某个节点的acl权限信息
setAcl 命令:设置某个节点的acl权限信息
addauth命令:输入认证授权信息 注册时输入明文密码 加密形式保存
ACL构成:
zookeeper的 acl通过 schema:id:permission 来构成权限列表
schema 代表采用的某种权限机制 包括world auth digest ip super集中
id 代表允许访问的用户
permissions 全线组合字符串
c 创建权限
d 删除权限
r 读权限
w 写权限
a 管理权限
world 实例
查看默认节点权限 再更新节点permissions权限部分crwa 结果删除节点失败 其中wirld