import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.WatchedEvent;
public class ZooKeeperExample {
private static final String ZOOKEEPER_HOST = "localhost:2181";
private static final int SESSION_TIMEOUT = 3000;
public static void main(String[] args) throws Exception {
ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_HOST, SESSION_TIMEOUT, new Watcher() {
public void process(WatchedEvent event) {
System.out.println("Received event: " + event);
}
});
String path = zooKeeper.create("/example", "data".getBytes(), ZNodeACL.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
System.out.println("Created node: " + path);
byte[] data = zooKeeper.getData("/example", false, null);
System.out.println("Node data: " + new String(data));
zooKeeper.setData("/example", "new data".getBytes(), -1);
System.out.println("Updated node data");
zooKeeper.delete("/example", -1);
System.out.println("Deleted node");
zooKeeper.close();
}
}
# zoo.cfg
tickTime=2000
dataDir=/var/zookeeper/data
clientPort=2181
