ZooKeeper----ZooKeeper 集群使用

1、ZooKeeper 集群 cli 使用

首先，我们可以是用命令 bin/zkCli.sh 进入 ZooKeeper 的命令行客户端，这种是直接连接本机的 ZooKeeper 服务器，还有一种方式，可以连接其他的 ZooKeeper 服务器，只需要我们在命令后面接一个参数-server 就可以了。例如：zkCli.sh -server hadoop01:2181

进入命令行之后，键入 help 可以查看简易的命令帮助文档，如下图

znode 数据信息字段解释：

ZooKeeper----ZooKeeper 集群使用

ZooKeeper 四字命令：

使用格式：

[[email protected] ~]# echo conf|nc hadoop02 2181

注意：需要安装 nc，不然不能使用

ZooKeeper----ZooKeeper 集群使用

2、ZooKeeper 集群 Java API 使用

ZooKeeper----ZooKeeper 集群使用

具体见代码

package com.zk;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import org.apache.ZooKeeper.CreateMode;
import org.apache.ZooKeeper.ZooDefs.Ids;
import org.apache.ZooKeeper.ZooKeeper;
import org.apache.ZooKeeper.data.ACL;
import org.apache.ZooKeeper.data.Stat;

public class ZooKeeperDemo {

    // 客户端去请求链接的时候的服务器链接地址信息
    private static String connectString = "hadoop02:2181,hadoop03:2181,hadoop04:2181";
    // 客户端去请求链接的超时时长
    private static int sessionTimeout = 4000;
    // 节点名称，统一命名
    private static String znode = "/zk/huangbo1";

    public static void main(String[] args) throws Exception {
        // 拿 ZooKeeper 链接
        ZooKeeper zk = new ZooKeeper(connectString, sessionTimeout, null);
        // 创建 znode
        String createdNode = zk.create(znode, "huangbo".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        System.out.println(createdNode + "节点创建成功");
        // 查看节点
        byte[] data = zk.getData(znode, null, null);
        System.out.println(new String(data));
        // 修改节点数据
        Stat setData = zk.setData(znode, "huangbo-xifu".getBytes(), -1);
        System.out.println(new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date(setData.getMtime())));
        byte[] data1 = zk.getData(znode, null, null);
        System.out.println(new String(data1));
        // 获取 znode 的权限信息
        List<ACL> aclList = zk.getACL(znode, null);
        for (ACL acl : aclList) {
            System.out.println(acl.getPerms());
        }
        // 判断节点是否存在
        Stat exists = zk.exists(znode, null);
        System.out.println(null != exists ? true : false);
        // 获取子节点
        List<String> children = zk.getChildren("/", null);
        for (String child : children) {
            System.out.println(child);
        }
        // 删除节点
        zk.delete(znode, -1);
        Stat exists1 = zk.exists(znode, null);
        System.out.println(null == exists1 ? "删除成功" : "删除失败");
        zk.close();
    }
}