Zookeeper（一）基础知识

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
# 打印一段日志后，会出现如下结果

shell启动

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 回调方法的上下文参数

时间原因，该部分持续更新....