import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import java.io.IOException;
public class ZooKeeperExample {
private static final String ZOOKEEPER_ADDRESS = "localhost:2181";
private static final int SESSION_TIMEOUT = 5000;
public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
ZooKeeper zookeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, new Watcher() {
public void process(WatchedEvent event) {
if (event.getState() == Watcher.Event.KeeperState.SyncConnected) {
}
}
});
String znodePath = "/example";
String znodeValue = "Hello, ZooKeeper!";
if (zookeeper.exists(znodePath, false) == null) {
zookeeper.create(znodePath, znodeValue.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
Stat stat = zookeeper.exists(znodePath, new Watcher() {
public void process(WatchedEvent event) {
if (event.getType() == Watcher.Event.EventType.NodeDataChanged) {
}
}
});
byte[] znodeData = zookeeper.getData(znodePath, false, stat);
System.out.println("ZNode data: " + new String(znodeData));
}
}
