zookeeper介绍
略(打开这篇文章的朋友肯定或多或少了解过zookeeper介绍,我也不在此上面占用大量篇幅。
zookeeper安装
Centos7上安装并配置好JDK及环境变量
1.在zookeeper官网下载二进制压缩包
2.解压缩zookeeper文件
3.在~/conf/中修改zoo.sample.cfg为zoo.cfg
4.启动并检验
cd ~/bin/
./zkServer.sh start
./zkServer.sh status
这里没有配图,我相信作为一个学到zk的朋友肯定没有压力
zookeeper应用场景
zookeeper是一个经典的分布式数据一致性解决方案,致力于为分布式应用提供一个高性能、高可用,具有严格顺序访问控制能力的分布式协调存储服务。
zookeeper的数据模型
zookeeper的数据节点分布可以视为树状结构,树中的各节点被称为znode,一个znode可以有很多子节点,又能像目录一样作为路径标识的一部分。
znode可以分成三个部分
1.节点的数据
2.子节点
3.节点的状态stat:描述当前节点创建、修改记录。
节点状态stat
属性 | 说明 |
---|---|
cZxid | 数据节点创建时的事务ID |
ctime | 数据节点创建时的时间 |
mZxid | 数据节点最后一次修改时的事务ID |
mtime | 数据节点最后一次修改时的时间 |
pZxid | 数据节点子节点最后一次被修改时的事务ID |
cversion | 子节点的版本号(1开始,修改一次加一,可表示修改次数) |
dataVersion | 节点数据的版本号(1开始,修改一次加一,可表示修改次数) |
aclVersion | 节点的ACL的版本号(1开始,修改一次加一,可表示修改次数) |
ephemeralOwner | 如果该节点是临时节点,则表示创建该节点的SessionID;如果是持久节点,该属性值为0 |
dataLength | 数据内容的长度(字节为单位) |
numChildren | 数据节点当前的子节点个数 |
配张图
节点类型
1.临时节点:该节点的生命周期依赖于创建他们的会话。一旦会话结束,临时节点将自动被删除,当啊可以手动删除,虽然临时的znode绑定到一个会话,但是在会话结束之前,他对所有的客户端都是可见的,同时zookeeper不允许临时节点拥有子节点。
2.持久节点:该节点的生命周期不依赖于会话,并且只有在客户端显示执行删除之后,他们才能被删除。
zookeeper的相关操作
为了对比学习,同时压缩篇幅,zk的shell操作,以及JavaApi操作一起写
Java创建maven项目,并引入依赖
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.6.2</version>
</dependency>
链接到zookeeper服务器
shell
# 在同启动的bin目录下,有一个zkCli.sh
./ zkCli.sh -server localhost:2181
# 打印一段日志后,会出现如下结果
Java
Zookeeper zooKeeper = new ZooKeeper(server, 5000, watchedEvent -> {
// 创建成功时的标识
if (watchedEvent.getState() == Watcher.Event.KeeperState.SyncConnected) {
System.out.println("链接创建成功");
} });
// server 类似于shell启动的server参数 为host:ip
// 5000是以毫秒为单位的时间参数,表示多长时间类没有响应,会话算是超市
// watch监听器,这里是JDK8的匿名函数的写法,在zookeeper的会话内任何一次变化,都要回调
后续的操作都是基于zookeeper对象的
创建节点
shell
create [-s] [-e] path data
# -s 设置为有序节点
# -e 设置临时节点
# path 要创建的路径
# data 该路径节点对应的数据内容
Java
// 同步创建方式
zookeeper.create(path, data, acl, model);
// 异步创建方式
zookeeper.create(path, data, acl, model, callback, ctx);
// path 创建的路径
// data 该路径下对应的内容
// acl 权限访问列表
// model 节点的模式 是否持久,是否临时
// callback 异步创建的回调
// ctx 回调方法的上下文参数
时间原因,该部分持续更新....