一、ZooKeeper单机集群概述

ZooKeeper作为分布式系统的协调服务，广泛应用于配置管理、命名服务、分布式锁等场景。单机集群模式指在一台物理机上部署多个ZooKeeper实例，通过模拟集群环境实现高可用性测试、开发环境搭建等需求。其核心优势在于资源占用低、配置灵活，尤其适合预算有限或需要快速验证的场景。

1.1 单机集群的适用场景

开发环境模拟：开发者可在本地复现生产环境行为，避免因网络延迟或节点故障导致的调试困难。
高可用性测试：通过手动触发节点故障，验证客户端重连机制和Leader选举逻辑。
资源受限环境：在云服务器或虚拟机中，以最小成本搭建多节点测试环境。

1.2 与分布式集群的区别

维度	单机集群	分布式集群
节点分布	同一物理机	多台物理机
网络延迟	本地回环（极低）	物理网络（较高）
故障隔离	依赖进程级隔离	物理机级隔离
资源消耗	共享CPU/内存	独立资源分配

二、部署前准备

2.1 系统要求

操作系统：Linux（推荐CentOS 7+/Ubuntu 20.04+）
Java环境：JDK 8或更高版本（验证命令：java -version）
端口开放：默认2181（客户端）、2888（节点通信）、3888（Leader选举）

2.2 依赖安装

# 以CentOS为例
sudo yum install -y java-1.8.0-openjdk-devel
sudo systemctl stop firewalld  # 测试环境可临时关闭防火墙

2.3 目录规划

/opt/zookeeper/
├── zoo1/       # 节点1
│   ├── data/
│   └── logs/
├── zoo2/       # 节点2
│   ├── data/
│   └── logs/
└── zoo3/       # 节点3
    ├── data/
    └── logs/

三、脚本化部署实现

3.1 基础脚本设计

#!/bin/bash
# zk_deploy.sh
ZOOKEEPER_VERSION="3.7.0"
BASE_DIR="/opt/zookeeper"
NODES=("zoo1" "zoo2" "zoo3")
PORTS=(2181 2182 2183)
PEER_PORTS=(2888 2889 2890)
LEADER_PORTS=(3888 3889 3890)
# 下载并解压
wget https://archive.apache.org/dist/zookeeper/zookeeper-${ZOOKEEPER_VERSION}/apache-zookeeper-${ZOOKEEPER_VERSION}-bin.tar.gz
tar -xzf apache-zookeeper-*.tar.gz -C ${BASE_DIR}
ln -s ${BASE_DIR}/apache-zookeeper-${ZOOKEEPER_VERSION} ${BASE_DIR}/current
# 创建节点目录
for i in "${!NODES[@]}"; do
  NODE_DIR="${BASE_DIR}/${NODES[$i]}"
  mkdir -p ${NODE_DIR}/data ${NODE_DIR}/logs
  echo ${i+1} > ${NODE_DIR}/data/myid  # 节点ID从1开始
done

3.2 动态配置生成

# 生成zoo.cfg模板
CONFIG_TEMPLATE="
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/opt/zookeeper/%s/data
dataLogDir=/opt/zookeeper/%s/logs
clientPort=%d
server.%d=127.0.0.1:%d:%d
"
# 为每个节点生成配置
for i in "${!NODES[@]}"; do
  NODE=${NODES[$i]}
  CFG_FILE="${BASE_DIR}/${NODE}/conf/zoo.cfg"
  printf "$CONFIG_TEMPLATE" "$NODE" "$NODE" "${PORTS[$i]}" "$((i+1))" "${PEER_PORTS[$i]}" "${LEADER_PORTS[$i]}" > "$CFG_FILE"
done

3.3 启动脚本封装

#!/bin/bash
# zk_start.sh
BASE_DIR="/opt/zookeeper"
NODES=("zoo1" "zoo2" "zoo3")
for NODE in "${NODES[@]}"; do
  ZK_HOME="${BASE_DIR}/current"
  DATA_DIR="${BASE_DIR}/${NODE}/data"
  LOG_DIR="${BASE_DIR}/${NODE}/logs"
  # 检查myid是否存在
  if [ ! -f "${DATA_DIR}/myid" ]; then
    echo "Error: myid file missing in ${DATA_DIR}"
    exit 1
  fi
  # 启动节点
  nohup ${ZK_HOME}/bin/zkServer.sh start-foreground \
    ${BASE_DIR}/${NODE}/conf/zoo.cfg \
    >> ${LOG_DIR}/zookeeper.out 2>&1 &
done

四、验证与运维

4.1 状态检查

# 检查各节点状态
for NODE in zoo1 zoo2 zoo3; do
  echo "Checking ${NODE}:"
  ${BASE_DIR}/current/bin/zkServer.sh status ${BASE_DIR}/${NODE}/conf/zoo.cfg
done

4.2 客户端连接测试

# 连接第一个节点
${BASE_DIR}/current/bin/zkCli.sh -server 127.0.0.1:2181
# 在CLI中执行
create /test_node "单机集群测试"
get /test_node

4.3 故障模拟

# 停止Leader节点（需先通过status命令确认）
${BASE_DIR}/current/bin/zkServer.sh stop ${BASE_DIR}/zoo2/conf/zoo.cfg
# 观察客户端重连和新Leader选举

五、优化建议

资源隔离：通过cgroups限制每个节点的CPU/内存使用

# 示例：为zoo1限制512MB内存
sudo cgcreate -g memory:/zk_zoo1
echo "536870912" > /sys/fs/cgroup/memory/zk_zoo1/memory.limit_in_bytes

日志轮转：配置log4j.properties实现日志分割

# 在conf/log4j.properties中添加
log4j.appender.ROLLINGFILE=org.apache.log4j.DailyRollingFileAppender
log4j.appender.ROLLINGFILE.File=/opt/zookeeper/zoo1/logs/zookeeper.log
log4j.appender.ROLLINGFILE.DatePattern='.'yyyy-MM-dd

监控集成：通过JMX暴露指标

# 启动时添加JMX参数
JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=9010 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false"
nohup ${ZK_HOME}/bin/zkServer.sh start-foreground ${CFG_FILE} $JMX_OPTS >> ... &

六、常见问题处理

端口冲突：
- 现象：Address already in use
- 解决：使用netstat -tulnp | grep 2181确认占用进程，修改zoo.cfg中的端口配置
数据不一致：
- 现象：QuorumPeerMain启动失败
- 解决：检查各节点dataDir下的version-2目录是否完整，必要时从健康节点复制
内存溢出：
- 现象：OutOfMemoryError
- 解决：在zkEnv.sh中增加JVMFLAGS="-Xms512m -Xmx1024m"

通过脚本化部署，ZooKeeper单机集群的搭建时间可从数小时缩短至分钟级，且配置一致性得到保障。实际生产环境中，建议在此基础上扩展为真正的分布式集群，但单机模式在特定场景下仍具有不可替代的价值。

ZooKeeper单机集群部署指南：脚本化高效配置实践