Zookeeper的Java客户端在CentOS上如何配置 - 问答

在 CentOS 上配置 Zookeeper 的 Java 客户端

一环境准备

安装 Java 8 或更高版本（Zookeeper 依赖 Java 运行环境）。
方式一：使用系统包管理器安装 OpenJDK。
方式二：手动安装 JDK 并配置环境变量（JAVA_HOME 与 PATH）。
验证安装结果：java -version 能正常输出版本信息。

二获取并引入客户端依赖

使用构建工具管理依赖（推荐）：

Maven 依赖示例（版本可按需调整，例如 3.7.0）：

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

Gradle 依赖示例：

implementation 'org.apache.zookeeper:zookeeper:3.7.0'

不使用构建工具时，可下载官方发行包并加入项目的 classpath。

三客户端连接配置与示例代码

基本连接参数：
- connectionString：Zookeeper 服务地址列表，格式为 “host1:port1,host2:port2”。单机默认端口为 2181。
- sessionTimeout：会话超时时间（毫秒），建议不小于 2 × tickTime（服务端最小会话超时为 2 个 tick）。

最小可用示例代码（原生 API）：

import org.apache.zookeeper.*;

public class ZkClientDemo {
    public static void main(String[] args) throws Exception {
        // 替换为你的 Zookeeper 地址与端口
        String connectionString = "192.168.1.100:2181";
        int sessionTimeout = 3000;

        ZooKeeper zk = new ZooKeeper(connectionString, sessionTimeout, event -> {
            System.out.println("Received event: " + event);
        });

        // 简单读取根节点子节点
        System.out.println("Children of /: " + zk.getChildren("/", false));

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

提示：原生客户端会话建立是异步的，生产代码应等待连接状态变为 SyncConnected 后再进行业务操作。

四网络与防火墙设置

开放客户端连接端口（默认 2181）：
- firewalld：
```
sudo firewall-cmd --add-port=2181/tcp --permanent
sudo firewall-cmd --reload
```
- 或临时停止防火墙用于排查（不建议生产环境长期使用）：
```
sudo systemctl stop firewalld
```
如为集群环境，还需确保节点间通信端口（如 2888/3888）互通。

五常见问题与排查

无法连接：
- 核对 connectionString 与端口是否正确，服务器是否监听 0.0.0.0:2181 而非仅 127.0.0.1。
- 检查 firewalld/安全组 是否放行 2181，以及云厂商安全组规则。
会话超时或反复重连：
- 适当增大 sessionTimeout，并确认网络稳定；注意服务端最小会话超时为 2 × tickTime。
SELinux 干扰（如连接被拒绝且无明确网络问题）：
- 临时禁用：setenforce 0；永久禁用：编辑 /etc/selinux/config 将 SELINUX=disabled 并重启。

0 赞

0 踩