zookeeper客户端练习（idea-Junit测试）

用Junit测试每个方法

1) 创建连接

 ZooKeeper zk = new ZooKeeper("chun1:2181,chun2:2181," +
                    "chun3:2181,chun4:2181,chun5:2181",3000,null);

2) 创建节点

@Test
public void testCreate() throws KeeperException, InterruptedException {
//参数1.节点路径名字 参数2：数据  参数3：访问权限 参数4：节点类型
	String create = zk.create("/demo123", "hello zookeeper".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
	System.out.println(create);
    zk.close();
}

3）修改

 //修改
@Test
public void testUpdata() throws KeeperException, InterruptedException {
  // 参数1：节点路径  参数2：修改的数据  参数3：版本
	zk.setData("/demo123", "do't hello zookeeper".getBytes(),-1);
	zk.close();
 }

4）查询

@Test
public void testGetdata() throws KeeperException, InterruptedException {
 //参数1：路径  参数2：是否要监听：  参数3：所要获取的数据的版本（null表示最新版本）
	byte[] data = zk.getData("/demo123", false, null); 
	String s = new String(data);
	System.out.println(s);
	zk.close();
}

5）查询子节点

@Test
public void testChilddrend() throws KeeperException, InterruptedException {
//参数1：节点路径  参数2：是否需要监听
	List<String> children = zk.getChildren("/hbase", false);
	System.out.println(children);
	zk.close();
}

6）删除

@Test
public void testRm() throws KeeperException, InterruptedException {
 //参数1：节点路径  参数2：所要删除的数据的版本，-1（表示所有版本）
   zk.delete("/demo123",-1);
   zk.close();
}

下面是整个代码

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

import java.io.IOException;
import java.util.List;

public class ZookeeperDemo {
        ZooKeeper zk = new ZooKeeper("chun1:2181,chun2:2181," +
                    "chun3:2181,chun4:2181,chun5:2181",3000,null);

    public ZookeeperDemo() throws IOException {
    }

    //创建
        @Test
        public void testCreate() throws KeeperException, InterruptedException {
            //参数1.节点路径名字 参数2：数据  参数3：访问权限 参数4：节点类型
            String create = zk.create("/demo123", "hello zookeeper".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            System.out.println(create);
            zk.close();
        }
        //修改
        @Test
        public void testUpdata() throws KeeperException, InterruptedException {
            // 参数1：节点路径  参数2：修改的数据  参数3：版本
            zk.setData("/demo123", "do't hello zookeeper".getBytes(),-1);
            zk.close();
        }
        //查询
        @Test
        public void testGetdata() throws KeeperException, InterruptedException {
            //参数1：路径  参数2：是否要监听：  参数3：所要获取的数据的版本（null表示最新版本）
            byte[] data = zk.getData("/demo123", false, null);
            String s = new String(data);
            System.out.println(s);
            zk.close();
        }
        //查询子节点
        @Test
        public void testChilddrend() throws KeeperException, InterruptedException {
            //参数1：节点路径  参数2：是否需要监听
            List<String> children = zk.getChildren("/hbase", false);
            System.out.println(children);
            zk.close();
        }
        //删除
        @Test
        public void testRm() throws KeeperException, InterruptedException {
            //参数1：节点路径  参数2：所要删除的数据的版本，-1（表示所有版本）
            zk.delete("/demo123",-1);
            zk.close();
        }
}