Zookeeper单机部署详解

一、Zookeeper单机安装

单机模式是最简单的Zookeeper部署方法，适合于小规模的应用开发和测试环境。以下步骤以在Linux系统上安装单节点Zookeeper为例：

# 下载Zookeeper安装包
wget https://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

# 解压缩安装包
tar -xzvf apache-zookeeper-3.7.0-bin.tar.gz

# 进入Zookeeper目录
cd apache-zookeeper-3.7.0-bin

# 复制配置文件
cp conf/zoo_sample.cfg conf/zoo.cfg

# 编辑配置文件
vim conf/zoo.cfg

修改配置文件中的dataDir和server信息，如下所示：

dataDir=/var/lib/zookeeper
server.1=localhost:2888:3888

其中，dataDir是Zookeeper存储数据的目录，server.1是ZooKeeper服务的地址和端口。此处只配置了一个节点，端口设置为默认值。

保存并退出配置文件，启动Zookeeper:

# 启动Zookeeper
bin/zkServer.sh start

# 确认Zookeeper已经启动
bin/zkCli.sh

执行以上命令后，会进入Zookeeper命令行客户端，成功连接Zookeeper。

二、Zookeeper单节点部署

Zookeeper默认是单节点部署，启动Zookeeper后，只有一个节点可以提供服务。如果节点宕机，整个Zookeeper服务将会挂掉，因此需要备份数据和配置文件。

备份Zookeeper数据和配置文件：

# 备份Zookeeper数据和配置文件
cp -r /var/lib/zookeeper ~/zookeeper_backup
cp -r conf ~/zookeeper_backup

以上命令将备份Zookeeper的数据和配置文件到~/zookeeper_backup目录下。

三、Zookeeper集群部署

Zookeeper的集群部署需要多个节点来提供服务。在部署Zookeeper集群时，通常建议使用奇数台机器，因为奇数台机器部署Zookeeper集群可以获得更好的性能。

四、Zookeeper为什么建议奇数部署

如果使用偶数台机器部署Zookeeper集群，当其中一台机器宕机后，剩余的机器数量为偶数，无法进行决策，从而导致系统无法正常工作。相比之下，如果使用奇数台机器部署Zookeeper集群，宕机后剩余的机器数量为奇数，可以进行决策。

五、Zookeeper部署模式

Zookeeper支持单机部署和集群部署两种模式。单机模式适用于小规模的应用，而集群模式适用于大规模应用。

六、Zookeeper分布式集群部署

分布式集群部署是Zookeeper的核心功能，可以为多个应用程序提供高可用性服务。Zookeeper的分布式集群部署需要多个节点提供服务，同时也需要将数据备份到多个节点，保证高可用性。

七、Zookeeper单机模式

Zookeeper单机模式是最简单的Zookeeper部署方法，适合于开发和测试环境。在单机模式下，Zookeeper只有一个节点可以提供服务，无法提供高可用性服务。

八、Zookeeper单机启动

Zookeeper单机启动很简单，只需执行以下命令：

# 启动Zookeeper
bin/zkServer.sh start

# 确认Zookeeper已经启动
bin/zkCli.sh

以上命令将启动Zookeeper并连接到Zookeeper命令行客户端。

九、Zookeeper单机部署监听不到状态

在使用Zookeeper单机部署时，由于只有一个节点提供服务，可能会存在监听不到状态的情况。此时，需要增加新的节点来提供服务。

以下为Java代码示例：

public static void main(String[] args) throws Exception {
    String connectionString = "localhost:2181";
    
    // 创建Zookeeper客户端
    ZooKeeper zkClient = new ZooKeeper(connectionString, 5000, new Watcher() {
        public void process(WatchedEvent event) {
            System.out.println("Event state: " + event.getState());
        }
    });
    
    // 等待Zookeeper连接成功
    while (zkClient.getState() != ZooKeeper.States.CONNECTED) {
        Thread.sleep(1000);
    }
    
    // 监听状态变化
    zkClient.register(new Watcher() {
        public void process(WatchedEvent event) {
            if (event.getState() == Watcher.Event.KeeperState.SyncConnected) {
                System.out.println("Connected to zookeeper.");
            } else {
                System.out.println("Disconnected from zookeeper.");
            }
        }
    });
    
    // 等待状态变化
    Thread.sleep(3600000);

    // 关闭Zookeeper客户端
    zkClient.close();
}