用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测试）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。