Java使用ZookeeperAPI

2017-07-24
此篇接着上一篇Zookeeper的安装及使用，重点介绍如何使用Java调用Zookeeper的API。
1、下载依赖包，加入到项目

2、常用的增删改查API示例如下：

package com.lanting.zookeeper;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;
import java.util.List;

/**
 * Zookeeper的简单使用
 */
public class Demo01 {
    // 主机:端口的模式（主机:端口,主机:端口....可以添加多个服务，失败后往后尝试）
    private static final String connectString = "192.168.2.111:2181";
    // 设置超时时间
    private static final int sessionTimeout = 3000;
    private ZooKeeper zooKeeperClient = null;

    /**
     * 测试之前的初始化
     * @throws IOException
     */
    @Before
    public void init() throws IOException {
        zooKeeperClient = new ZooKeeper(connectString, sessionTimeout, (event -> {
            System.out.println(event.getType() + "---" + event.getPath() + "---" + event.getState() + "---" + event.getWrapper());
        }));
    }

    /**
     * 测试创建一个数据
     */
    @Test
    public void createTest() throws KeeperException, InterruptedException {
        // 创建。参数1：节点，参数2：内容，参数3：权限，参数4：模式（这里是持久模式）
        // 返回参数：创建好的节点
        String result = zooKeeperClient.create("/idea", "this is test data".getBytes(StandardCharsets.UTF_8), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        System.out.println(result);
    }

    /**
     * 测试查询所有的子节点
     */
    @Test
    public void getChildren() throws KeeperException, InterruptedException {
        // 查询路径 / 下的所有子节点。true表示启用监听（这个监听只能监听一次）
        List<String> children = zooKeeperClient.getChildren("/",true);
        // 遍历所有的子节点
        children.stream().forEach(s-> System.out.println(s));
    }

    /**
     * 判断指定节点是否存在
     */
    @Test
    public void testExist() throws KeeperException, InterruptedException {
        // 如果返回值不为null表示存在
        Stat exists = zooKeeperClient.exists("/idea", true);
        System.out.println(exists == null ? "not exist" : "exist");
    }

    /**
     * 测试获取数据
     */
    @Test
    public void testGetData() throws KeeperException, InterruptedException, UnsupportedEncodingException {
        // 查询数据
        byte[] data = zooKeeperClient.getData("/idea", true, null);
        // 打印获取到的数据
        System.out.println(new String(data,"utf-8"));
    }

    /**
     * 测试删除数据
     */
    @Test
    public void testDeleteData() throws KeeperException, InterruptedException {
        // 删除指定的节点，-1表示删除的版本号为所有
        zooKeeperClient.delete("/idea",-1);
    }

    /**
     * 测试更新数据
     */
    @Test
    public void updateDataTest() throws KeeperException, InterruptedException {
        // 更新指定节点的数据，-1表示更新的版本号为所有版本都修改
        zooKeeperClient.setData("/idea","this is updateData".getBytes(StandardCharsets.UTF_8),-1);
    }

}