java zookeeper数据读写

Apache ZooKeeper是一个分布式协调服务，它提供了一个高性能、可靠的分布式协调和管理服务。在Java中，我们可以使用ZooKeeper的Java客户端库来读写数据。以下是一个简单的示例，展示了如何使用Java连接到ZooKeeper，创建节点，读取节点数据和删除节点。

首先，确保你已经将ZooKeeper的Java客户端库添加到项目的依赖中。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.7.0</version>
</dependency>

接下来，我们将编写一个简单的Java程序来操作ZooKeeper：

import org.apache.zookeeper.*;

import java.io.IOException;
import java.util.Collections;
import java.util.List;

public class ZooKeeperExample {
    private static final String CONNECT_STRING = "localhost:2181";
    private static final int SESSION_TIMEOUT = 3000;
    private static ZooKeeper zooKeeper;

    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        // 连接到ZooKeeper
        zooKeeper = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, event -> {
            System.out.println("ZooKeeper连接状态变更: " + event.getState());
        });

        // 创建节点
        createNode();

        // 读取节点数据
        readNodeData();

        // 删除节点
        deleteNode();

        // 关闭连接
        zooKeeper.close();
    }

    private static void createNode() throws KeeperException, InterruptedException {
        // 创建一个持久节点
        String nodePath = "/exampleNode";
        zooKeeper.create(nodePath, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        System.out.println("节点创建成功: " + nodePath);
    }

    private static void readNodeData() throws KeeperException, InterruptedException {
        // 获取节点数据
        String nodePath = "/exampleNode";
        byte[] data = zooKeeper.getData(nodePath, false, null);
        System.out.println("节点数据: " + new String(data));
    }

    private static void deleteNode() throws KeeperException, InterruptedException {
        // 删除节点
        String nodePath = "/exampleNode";
        zooKeeper.delete(nodePath, -1);
        System.out.println("节点删除成功: " + nodePath);
    }
}

在这个示例中，我们首先连接到ZooKeeper，然后创建一个持久节点/exampleNode。接着，我们读取该节点的数据并打印出来。最后，我们删除该节点并关闭与ZooKeeper的连接。

注意：在实际应用中，你需要根据实际需求调整连接字符串、会话超时时间和节点路径等参数。