import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
public class ZooKeeperExample implements Watcher {
private static final String ZOOKEEPER_HOST = "localhost:2181";
private static final int SESSION_TIMEOUT = 5000;
private ZooKeeper zooKeeper;
public static void main(String[] args) {
ZooKeeperExample example = new ZooKeeperExample();
example.connect();
example.waitForNodeChange();
example.close();
}
public void connect() {
try {
zooKeeper = new ZooKeeper(ZOOKEEPER_HOST, SESSION_TIMEOUT, this);
} catch (Exception e) {
e.printStackTrace();
}
}
public void waitForNodeChange() {
try {
zooKeeper.getData("/myNode", true, null);
Thread.sleep(Long.MAX_VALUE);
} catch (Exception e) {
e.printStackTrace();
}
}
public void close() {
try {
zooKeeper.close();
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void process(WatchedEvent watchedEvent) {
System.out.println("Node has changed: " + watchedEvent.getPath());
}
}
