public class FgeduZkClient {
private ZooKeeper zk;

public void connect(String hosts) throws Exception {
zk = new ZooKeeper(hosts, 3000, event -> {
System.out.println(“Event: ” + event);
});
}

public void create(String path, String data) throws Exception {
zk.create(path, data.getBytes(),
ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

public String getData(String path) throws Exception {
byte[] data = zk.getData(path, false, new Stat());
return new String(data);
}

public void close() throws Exception {
zk.close();
}
}

// 使用示例
FgeduZkClient client = new FgeduZkClient();
client.connect(“fgedu01:2181,fgedu02:2181,fgedu03:2181”);
client.create(“/fgedu/app”, “app_config”);
String data = client.getData(“/fgedu/app”);
System.out.println(“Data: ” + data);
client.close();