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();
}