properties
server.1=192.168.0.1:2888:3888
server.2=192.168.0.2:2888:3888
server.3=192.168.0.3:2888:3888
dataDir=/var/zookeeper/data
dataLogDir=/var/zookeeper/log
dataDirBackup=/var/zookeeper/backup
import org.apache.zookeeper.*;
public class ZooKeeperExample {
private static final String ZOOKEEPER_ADDRESS = "localhost:2181";
private static final int SESSION_TIMEOUT = 3000;
public static void main(String[] args) throws Exception {
ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, new Watcher() {
@Override
public void process(WatchedEvent event) {
}
});
if (zooKeeper.exists("/mynode", false) == null) {
zooKeeper.create("/mynode", "Hello, ZooKeeper!".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT);
}
byte[] data = zooKeeper.getData("/mynode", false, null);
String message = new String(data);
System.out.println(message);
zooKeeper.close();
}
}
