zookeeper的java客户端常用api

一。maven导入zookeeper

　　1. 在这个网址搜索zookeeper导入：https://search.maven.org/ ，pom文件可如下

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>hadoop_01</groupId>
    <artifactId>hadoop_01</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
            <type>pom</type>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>

</project>

　　2. 如果zookeeper不可用在刚才的网址直接下载类包导入。

二。增删改查

　　1. 初始化

public class ZkClient {
    private static Logger logger = Logger.getLogger(ZkClient.class);
    ZooKeeper zooKeeper = null;

    //挨个尝试连接，哪个能连接上就连接哪个
    private static final String connectString = "host1:2181,host2:2181,host3:2181";
    // 在 C:WindowsSystem32driversetc 的 hosts 文件加入 host1,host2,host3 的ip
    private static final int sessionTimeOut = 2000;

    @Before
    public void init() throws IOException {
        BasicConfigurator.configure();
        logger.info("123456");

        //参数1：连接地址，2：连接超时时间(毫秒)，3：回调事件，4：是否只读
        zooKeeper = new ZooKeeper(connectString, sessionTimeOut, (event -> {
            // 事件的回调
            logger.info(event.getType() + "----事件回调----" + event.getPath());
        }),false);
    }

    /**
     *  增删改查
     * @throws KeeperException
     * @throws InterruptedException
     */

}

　　2. 增加节点

    @Test
    // 创建数据到zk节点中
    public void createNode() throws KeeperException, InterruptedException {
        //返回值：节点路径 参数1：节点路径 2：节点数据(可以是任何类型) 3：节点权限(OPEN_ACL_UNSAFE 开放) 4：节点类型(PERSISTENT 持久的)
        String createNode = zooKeeper.create("/idea", "aaaaaaaa".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        logger.info("返回值为：" + createNode);
    }

可以看到增加的节点

[zk: localhost:2181(CONNECTED) 0] ls /
[zookeeper]
[zk: localhost:2181(CONNECTED) 1] ls /
[zookeeper, idea]
[zk: localhost:2181(CONNECTED) 2]

　　3 判断节点是否存在

    @Test
    // 判断节点是否存在
    public void nodeExists() throws KeeperException, InterruptedException {
        // Stat 为数据描述信息
        Stat stat = zooKeeper.exists("/idea",false);
        logger.info(stat==null?"节点不存在":"节点存在");
    }

　　4. 获取子节点

    @Test
    // 获取子节点
    public void getNode() throws KeeperException, InterruptedException {
        // 参数2：监听节点变化,不写回调函数则会调用初始化时的回调函数
        List<String> node = zooKeeper.getChildren("/",true);
        for (String n:node){
            logger.info("节点为：" + n);
        }
        Thread.sleep(Long.MAX_VALUE);
    }

　　5. 获取节点数据

    @Test
    // 获取节点数据
    public void getData() throws KeeperException, InterruptedException {
        byte[] data = zooKeeper.getData("/idea",false,null);
        logger.info("数据为：" + new String(data, StandardCharsets.UTF_8));
    }

　　6. 删除节点

    @Test
    // 删除节点
    public void deleteNode() throws KeeperException, InterruptedException {
        // 参数2：删除数据的版本，-1为全部版本都删除
        zooKeeper.delete("/idea",-1);
    }

　　7. 修改节点数据

    @Test
    // 修改节点数据
    public void setData(){
        zooKeeper.setData("/idea", "qweasd".getBytes(), -1);
    }

三。更多api可在idea编辑器查看。