java连接虚拟机zookeeper

在Java中，连接到ZooKeeper分布式协调服务通常需要使用ZooKeeper客户端API。Apache ZooKeeper提供了一个名为`org.apache.zookeeper.ZooKeeper`的Java客户端类，用于与ZooKeeper服务器交互。以下是使用Java连接ZooKeeper的基本步骤：

1. **添加依赖**：首先，你需要将ZooKeeper的JAR包添加到你的项目中。如果你的项目是Maven项目，可以在pom.xml文件中添加依赖：

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.5.7</version> <!-- 更新为你所需的版本 -->
</dependency>

2. **创建连接**：创建`ZooKeeper`实例时，需要指定ZooKeeper集群的地址列表，通常是IP加端口号形式：

import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ClientConfig;

String[] servers = {"localhost:2181", "server2:2181", "server3:2181"}; // 根据实际配置替换
ClientConfig config = new ClientConfig();
config.setConnectionTimeout(10000); // 连接超时时间

ZooKeeper zookeeper = new ZooKeeper(servers, config.getConnectionTimeout(), event -> {
    if (event.type == Event.KeeperState.SyncConnected) {
        System.out.println("Connected to ZooKeeper");
    }
});

这里的回调函数会在连接成功时被触发。

3. **操作ZooKeeper**：可以使用`ZooKeeper`实例来进行读写、监听节点变化等操作。例如，获取某个路径的数据：

public void getData(String path) throws KeeperException, InterruptedException {
    byte[] data = zookeeper.getData(path, false, null);
    String content = new String(data);
    System.out.println("Data at " + path + ": " + content);
}

4. **关闭连接**：完成操作后别忘了关闭`ZooKeeper`实例以释放资源：

zookeeper.close();