Zookeeper 安装与配置

搭建一个稳定可靠的 Zookeeper 集群

Zookeeper 作为分布式系统的命脉，其集群搭建不容忽视。本文将从头到尾，为你指明 Zookeeper 集群搭建之路，让你轻松驾驭 Zookeeper 的分布式协调能力。

准备工作

起航之前，做好准备工作至关重要。你需要安装 Java 环境（JDK 8 或更高）、下载 Zookeeper 并解压，同时还要修改 conf/zoo.cfg 配置文件。主要配置如下：

dataDir=/data/zookeeper
dataLogDir=/data/zookeeper/logs
clientPort=2181
tickTime=2000
initLimit=10
syncLimit=5

格式化数据目录

接下来，需要格式化数据目录，为 Zookeeper 创建元数据。使用 bin/zkServer.sh formatConf 命令即可。

规划集群结构

根据业务需求，规划好 Zookeeper 集群的结构，推荐使用奇数个节点（如 3、5、7）。

安装和配置各个节点

在各个集群节点上，重复 Zookeeper 的安装和配置步骤。别忘了修改每个节点 dataDir 目录下的 myid 文件，写入唯一的集群 ID。

启动集群

一切准备就绪，使用 bin/zkServer.sh start 命令启动 Zookeeper 服务。

验证集群状态

使用 bin/zkServer.sh status 命令，验证集群状态。所有节点应显示为 "Leader"、"Follower" 或 "Observer"。

集群监控

监控集群状态是保障稳定的关键，使用 Zookeeper Admin Server (zkAdmin) 或第三方工具（如 Prometheus）即可轻松实现。

故障处理

Zookeeper 集群具备自动故障转移功能，当某个节点出现故障时，其他节点将接管其职责。

扩容与缩容

随着业务需求的变化，可以根据需要向集群添加或删除节点。

滚动升级

在集群运行期间，可以通过滚动升级的方式更新 Zookeeper 版本，确保平滑过渡。

代码示例

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

public class ZookeeperClient {

    private ZooKeeper zk;

    public static void main(String[] args) throws Exception {
        // 连接 Zookeeper 集群
        zk = new ZooKeeper("localhost:2181", 3000, new Watcher() {
            @Override
            public void process(WatchedEvent event) {
                System.out.println("Watched event: " + event);
            }
        });

        // 创建节点
        zk.create("/test", "test".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

        // 获取节点数据
        Stat stat = new Stat();
        byte[] data = zk.getData("/test", false, stat);
        System.out.println(new String(data));

        // 更新节点数据
        zk.setData("/test", "updated".getBytes(), stat.getVersion());

        // 删除节点
        zk.delete("/test", stat.getVersion());

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

最佳实践

• 使用奇数个节点，避免出现脑裂。
• 选择合适的数据目录，位于高性能存储设备中。
• 定期备份 Zookeeper 数据，以防数据丢失。
• 保持 Zookeeper 版本一致，所有集群节点应运行相同版本。
• 合理配置 Zookeeper，根据实际需求调整 tickTime、initLimit 和 syncLimit。

常见问题解答

• 为什么使用 Zookeeper？
  Zookeeper 提供分布式协调服务，支持分布式系统中的节点选举、配置管理和数据同步。
• 如何判断集群是否健康？
  使用 bin/zkServer.sh status 命令，所有节点应显示为 "Leader"、"Follower" 或 "Observer"。
• 如何处理故障节点？
  Zookeeper 集群具备自动故障转移功能，当某个节点出现故障时，其他节点将接管其职责。
• 如何扩容集群？
  向集群添加节点，并修改每个节点的 myid 文件，写入唯一的集群 ID。
• 如何滚动升级 Zookeeper？
  逐步更新集群中的每个节点，确保平滑过渡。

结语

Zookeeper 集群搭建并非难事，遵循本文指南，结合代码示例和最佳实践，你将轻松构建一个稳定可靠的 Zookeeper 集群，为你的分布式系统保驾护航。