import org.apache.zookeeper.*;
public class ZooKeeperClient {
public static void main(String[] args) throws Exception {
zooKeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.println("Received event: " + event.getType());
}
});
String nodePath = "/myNode";
byte[] data = "Hello, ZooKeeper!".getBytes();
zooKeeper.create(nodePath, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
byte[] retrievedData = zooKeeper.getData(nodePath, false, null);
System.out.println("Retrieved data: " + new String(retrievedData));
zooKeeper.close();
}
}
text
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.7.0</version>
</dependency>
