import org.apache.zookeeper.*; public class ZookeeperServerExample { private static final String ZOOKEEPER_ADDRESS = "localhost:2181"; private static final int SESSION_TIMEOUT = 5000; public static void main(String[] args) throws Exception { ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, null); String path = "/example"; String data = "Hello, ZooKeeper!"; CreateMode createMode = CreateMode.PERSISTENT; zooKeeper.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, createMode); byte[] nodeData = zooKeeper.getData(path, false, null); System.out.println("Node data: " + new String(nodeData)); String newData = "Hello, ZooKeeper updated!"; zooKeeper.setData(path, newData.getBytes(), -1); byte[] updatedNodeData = zooKeeper.getData(path, false, null); System.out.println("Updated node data: " + new String(updatedNodeData)); zooKeeper.delete(path, -1); zooKeeper.close(); } }