用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 {}//创建@Testpublic 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();}//修改@Testpublic void testUpdata() throws KeeperException, InterruptedException {// 参数1：节点路径  参数2：修改的数据  参数3：版本zk.setData("/demo123", "do't hello zookeeper".getBytes(),-1);zk.close();}//查询@Testpublic 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();}//查询子节点@Testpublic void testChilddrend() throws KeeperException, InterruptedException {//参数1：节点路径  参数2：是否需要监听List<String> children = zk.getChildren("/hbase", false);System.out.println(children);zk.close();}//删除@Testpublic void testRm() throws KeeperException, InterruptedException {//参数1：节点路径  参数2：所要删除的数据的版本，-1（表示所有版本）zk.delete("/demo123",-1);zk.close();}
}

zookeeper客户端练习（idea-Junit测试）相关推荐

zookeeper客户端使用与集群特性
zookeeper客户端使用与集群特性 zookeeper Java客户端项目构建创建客户端实例测试结果创建zookeeper实例参数说明演示java客户端增删查改zookeeper节点 A ...
Zookeeper客户端Curator使用详解
http://www.jianshu.com/p/70151fc0ef5d Zookeeper客户端Curator使用详解简介 Curator是Netflix公司开源的一套zookeeper客户端框 ...
Zookeeper客户端Curator详解
一.Curator 客户端使用 Curator是 Netflix公司开源的一套ZooKeeper客户端框架,和 ZkClient一样它解决了非常底层的细节开发工作,包括连接.重连.反复注册Watche ...
Zookeeper 客户端之 Curator
之前写的一个在 Linux 上安装部署 Zookeeper 的笔记,其他操作系统请自行谷歌教程吧. 本文案例工程已经同步到了 github,传送门. PS : 目前还没有看过Curator的具体源码, ...
ZooKeeper客户端Curator的基本使用
前提:ZooKeeper版本:3.4.14 Curator版本:2.13.0 1.什么是Curator Curator是Netflix公司开源的一套zookeeper客户端框架,解决了很多Z ...
2.ZooKeeper客户端Curator「第三章 ZooKeeper Java客户端」「架构之路ZooKeeper理论和实战」
前言上一篇文章介绍了zookeeper原生API的使用,使用过原生API不得不说,有很多的问题,比如:不能递归创建和删除节点.Watcher只能使用一次.还有很多可以解决分布式应用问题的api(比 ...
Zookeeper客户端ZkClient、Curator的使用，史上最详细的教程来啦~
1 前言本文主要介绍了操作Zookeeper的几种客户端的基础使用,希望对老铁们会有所帮助. 可以去操作zookeeper创建.删除.查询.修改znode节点 2 Zookeeper服务器客户端分类 ...
ZooKeeper客户端源码（零）——客户端API使用
首发CSDN:徐同学呀,原创不易,转载请注明源链接.我是徐同学,用心输出高质量文章,希望对你有所帮助. 本篇源码基于ZooKeeper3.7.0版本. 一.建立连接和会话客户端可以通过创建一个 Zo ...
zookeeper客户端管理工具
zookeeper 的监控工具公司很多产品会使用zookeeper,比如Meta消息中间件,在测试的过程中,我们经常需要查询zookeeper里面的信息来精确定位问题.目前项目中有 ...

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

用Junit测试每个方法

1) 创建连接

2) 创建节点

3）修改

4）查询

5）查询子节点

6）删除

下面是整个代码

zookeeper客户端练习（idea-Junit测试）相关推荐

最新文章

热门文章