package cn.fansunion.zookeeper;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
public class ZooKeeperTest {
private static final int TIME_OUT = 3000;
private static final String HOST = "localhost:2181";
public static void main(String[] args) throws Exception{
ZooKeeper zookeeper = new ZooKeeper(HOST, TIME_OUT, null);
System.out.println("=========创建节点===========");
if(zookeeper.exists("/test", false) == null)
{
zookeeper.create("/test", "znode1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
System.out.println("=============查看节点是否安装成功===============");
System.out.println(new String(zookeeper.getData("/test", false, null)));
System.out.println("=========修改节点的数据==========");
String data = "zNode2";
zookeeper.setData("/test", data.getBytes(), -1);
System.out.println("========查看修改的节点是否成功=========");
System.out.println(new String(zookeeper.getData("/test", false, null)));
System.out.println("=======删除节点==========");
zookeeper.delete("/test", -1);
System.out.println("==========查看节点是否被删除============");
System.out.println("节点状态:" + zookeeper.exists("/test", false));
zookeeper.close();
}
}
运行结果
log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
=========创建节点===========
=============查看节点是否安装成功===============
znode1
=========修改节点的数据==========
========查看修改的节点是否成功=========
zNode2
=======删除节点==========
==========查看节点是否被删除============
节点状态:null