目录 start

  1. 安装并启动
    1. 使用
    2. Java API

目录 end|2019-10-19 17:04|


安装并启动

  • 进官网下载ZooKeeper,地址为https://www.apache.org/dyn/closer.cgi/zookeeper/

  • 将下载好的压缩包,解压缩,并进入ZooKeeper的文件夹

  • 查看目录conf下是否含有zoo.cfg配置文件(因我下载的版本是3.4.12,发现conf下有文件zoo_sample.cfg,将文件zoo_sample.cfg在原有目录下复制并改名为zoo.cfg,因ZooKeeper的启动脚本默认是使用配置conf/zoo.cfg,若没有该配置,则会报错)

  • 启动服务器命令为bin/zkServer.sh start

  • 启动CLI的命令为bin/zkCli.sh

  • 停止ZooKeeper服务的命令为bin/zkServer.sh stop

使用

  • 创建Znodes:create [参数] /path 数据,例如:create /FirstZnode "first ZooKeeper-app",起命令参数如下

    • -s: 创建连续的Znode
    • -e: 创建一个零时的Znode
  • 获取Znodes: get /path,/path要与创建时的一直

  • 监视znode的数据变化:get /path [watch] 1, 例如:get /FirstZnode 1,当/FirstZnode的数据发生变化时,将输出变化

  • 设置znode的数据:set /path data,例如:set /FirstNode "Hello"

  • 创建子Znode的方法与创建Znode的方法一样,但需要在路径中包含父路径:create /parent/path data,例如:create /FirstNode/TestNode "test"

  • 显示子Znode:ls /parent,例如列出上一步创建的Znodels /FirstNode

  • 检查状态:stat /path,例如:stat /FirstNode

  • 删除Znode:rmr /path,仅适用于无子Znode

Java API

Java API

  • 获取ZooKeeper连接

    1
    2
    3
    4
    5
    6
    7
    ZooKeeper zooKeeper = new ZooKeeper(host, 5000, new Watcher() {
    public void process(WatchedEvent watchedEvent) {
    if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
    latch.countDown();
    }
    }
    });
    • 参数说明 : ZooKeeper(String connectionString, int sessionTimeout, Watcher watcher)

    connectionString : ZooKeeper集合主机。
    sessionTimeout : 以毫秒为单位会话超时。
    watcher : 一个执行对象“观察者”的接口。ZooKeeper 集合返回通过监控器对象的连接状态。

  • 创建Znode : create(String path, byte[] data, List<ACL> acl, CreateMode createMode)

    1
    2
    3
    4
    5
    6
    7
    8
        public void createZnode() throws IOException, InterruptedException, KeeperException {
    ZooKeeper zoo = connect("localhost");
    byte[] data = "Java API Test".getBytes();
    // 调用create方法创建Znode
    zoo.create(ZNODE_PATH, data, ZooDefs.Ids.OPEN_ACL_UNSAFE,
    CreateMode.PERSISTENT);
    close(zoo);
    }
    • 参数说明:

    path : Znode的路径。例如 /myapp1, /myapp2, /myapp1/mydata1, myapp2/mydata1/myanothersubdata
    data : 在一个指定的znode路径存储数据
    acl : 要创建节点的访问控制列表。 ZooKeeperAPI提供了一个静态接口ZooDefs.Ids得到一些基本的ACL列表。例如,ZooDefs.Ids.OPEN_ACL_UNSAFE返回ACL开放的 znodes 列表。
    createMode : 节点的类型,可以是短暂的,连续的,或两者。这是一个枚举类型。

  • 检查Znode是否存在:exists(String path, boolean watcher)

    • 参数说明

    path : Znode 路径
    watcher : 布尔值,指定是否监视指定的znode与否

  • 获取数据:getData(String path, Watcher watcher, Stat stat)

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    public void getData() throws IOException, InterruptedException, KeeperException {
    ZooKeeper zoo = connect("localhost");
    byte[] data = zoo.getData(ZNODE_PATH, new Watcher() {
    @Override
    public void process(WatchedEvent watchedEvent) {
    if (watchedEvent.getType() == Event.EventType.None) {
    switch (watchedEvent.getState()) {
    case Expired:
    latch.countDown();
    break;
    }
    } else {
    String path = "/MyFirstZnode";
    try {
    byte[] bn = zoo.getData(path,
    false, null);
    String data = new String(bn,
    "UTF-8");
    System.out.println(data);
    latch.countDown();

    } catch(Exception ex) {
    System.out.println(ex.getMessage());
    }
    }
    }
    }, null);
    System.out.println(new String(data, "UTF-8"));
    close(zoo);
    }
    • 参数说明

    path : Znode 路径.
    watcher : Watcher类型的回调函数。ZooKeeper集合将通知通过观察者回调时指定的节点改变的数据。这是一次性的通知。
    stat : 返回 znode 元数据。

  • 修改数据: setData(String path, byte[] data, int version)

    1
    2
    3
    4
    5
    6
    public void setData() throws IOException, InterruptedException, KeeperException {
    ZooKeeper zoo = connect("localhost");
    byte[] data = "修改数据".getBytes();
    zoo.setData(ZNODE_PATH, data, zoo.exists(ZNODE_PATH, true).getVersion());
    close(zoo);
    }
    • 参数说明

    path : Znode 路径
    data : 数据存储在一个指定的znode路径。
    version : 当前znode的版本。ZooKeeper更新数据在znode的版本号改变了以后。

  • 获取子节点: getChildren(String path, Watcher watcher)

    1
    2
    3
    4
    5
    6
    public void getChild() throws IOException, InterruptedException, KeeperException {
    ZooKeeper zoo = connect("localhost");
    List<String> children = zoo.getChildren("/FirstNode", false);
    children.forEach(System.out::println);
    close(zoo);
    }
    • 参数说明

    path : Znode 路径.
    watcher : 调用“Watcher”类型函数. ZooKeeper集合将通知在指定的 znode 被删除或znode以下子节点创建/删除。 这是一次性的通知。

  • 删除Znode节点

    1
    2
    3
    4
    5
    public void del() throws IOException, InterruptedException, KeeperException {
    ZooKeeper zoo = connect("localhost");
    zoo.delete(ZNODE_PATH, zoo.exists(ZNODE_PATH, true).getVersion());
    close(zoo);
    }
    • 参数说明

    path : Znode 路径
    version : 当前 znode 的版本