ZooKeeper安裝及配置（Windows系統下）

ZooKeeper的定義用一句話就能說清：分布式服務框架 Zookeeper -- 管理分布式環境中的數據。下面從安裝開始，對這個框架進行分析。

1.安裝

1. 官網下載壓縮包並解壓到D:\Program Files (x86)\zookeeper-3.4.12

2. 在D:\Program Files (x86)\zookeeper-3.4.12目錄下新建data和log文件夾

3. 復制conf目錄下zoo_sample.cfg文件到同目錄下，重命名為zoo.cfg（Zookeeper 在啟動時會找這個文件作為默認配置文件），修改其中的 dataDir 和 dataLogDir 上面新建目錄的路徑

4. 啟動測試一下

服務端啟動

 啟動之后，端口查看可以看到ZooKeeper通過2181端口啟動了一個java服務

啟動客戶端連接一下，成功

2. ZooKeeper配置文件

目前配置文件zoo.cfg中的內容如下

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:\\Program Files (x86)\\zookeeper-3.4.12\\data  
dataLogDir=D:\\Program Files (x86)\\zookeeper-3.4.12\\log 
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1

單機模式下，主要配置項作用：

• tickTime：這個時間是作為 Zookeeper 服務器之間或客戶端與服務器之間維持心跳的時間間隔，也就是每個 tickTime 時間就會發送一個心跳。
• dataDir：顧名思義就是 Zookeeper 保存數據的目錄，默認情況下，Zookeeper 將寫數據的日志文件也保存在這個目錄里。
• dataLogDir：顧名思義就是 Zookeeper 保存日志文件的目錄。
• clientPort：這個端口就是客戶端連接 Zookeeper 服務器的端口，Zookeeper 會監聽這個端口，接受客戶端的訪問請求。

3. 集群模式

ZooKeeper的安裝模式分為三種，分別為：單機模式（stand-alone）、集群模式和集群偽分布模式。上面演示的即單機模式；通過多台機器共同提供服務即為集群模式；一台電腦的話其實還可以進行偽集群模式，即在一台物理機上運行多個 Zookeeper 實例。

集群模式是通過增加配置文件zoo.cfg中的配置項來設置，主要配置項如下：

initLimit=10 
syncLimit=5 
server.1=192.168.211.1:2888:3888 
server.2=192.168.211.2:2888:3888

• initLimit：這個配置項是用來配置 Zookeeper 接受客戶端（這里所說的客戶端不是用戶連接 Zookeeper 服務器的客戶端，而是 Zookeeper 服務器集群中連接到 Leader 的 Follower 服務器）初始化連接時最長能忍受多少個心跳時間間隔數。當已經超過 10 個心跳的時間（也就是 tickTime）長度后 Zookeeper 服務器還沒有收到客戶端的返回信息，那么表明這個客戶端連接失敗。總的時間長度就是 10*2000=20 秒
• syncLimit：這個配置項標識 Leader 與 Follower 之間發送消息，請求和應答時間長度，最長不能超過多少個 tickTime 的時間長度，總的時間長度就是 5*2000=10 秒
• server.A=B：C：D：其中 A 是一個數字，表示這個是第幾號服務器；B 是這個服務器的 ip 地址；C 表示的是這個服務器與集群中的 Leader 服務器交換信息的端口；D 表示的是萬一集群中的 Leader 服務器掛了，需要一個端口來重新進行選舉，選出一個新的 Leader，而這個端口就是用來執行選舉時服務器相互通信的端口。如果是偽集群的配置方式，由於 B 都是一樣，所以不同的 Zookeeper 實例通信端口號不能一樣，所以要給它們分配不同的端口號。

除了修改 zoo.cfg 配置文件，集群模式下還要配置一個文件 myid，這個文件在 dataDir 目錄下，這個文件里面就有一個數據就是 A 的值，Zookeeper 啟動時會讀取這個文件，拿到里面的數據與 zoo.cfg 里面的配置信息比較從而判斷到底是哪個 server。

單機偽集群模式配置步驟如下：

3.1 配置文件修改

conf目錄下復制三次zoo.cfg到同目錄下，分別命名zoo1.cfg，zoo2.cfg，zoo3.cfg，對三個文件進行如下修改

zoo1.cfg

zoo2.cfg

zoo3.cfg

相對應的，需要在各自dataDir下創建myid文件（無后綴名），內容分別為1，2，3，表示其為第幾號服務器。

3.2 修改服務端啟動配置

bin目錄下復制三次zkServer.cmd到同目錄下，分別命名zkServer1.cmd，zkServer2.cmd，zkServer3.cmd，對三個文件進行如下修改

zkServer1.cmd

 

zkServer2.cmd

zkServer3.cmd

 

3.3 啟動服務

cmd下啟動三個zkServer，在這里我是打開三個cmd窗口啟動的，順序1-2-3，三個zkServer沒全啟動的時候會報如下錯誤，這是zookeeper的Leader選舉算法的異常信息，當節點沒有啟動完畢的時候，Leader無法正常進行工作，這種錯誤信息是可以忽略的，等其他節點啟動之后就正常了。

 

三個端口全部啟動

 4. java連接測試

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;

public class WatcherTest implements Watcher{
    public void process(WatchedEvent arg0){
        System.out.println("========================");
        System.out.println("path:"+arg0.getPath());
        System.out.println("type:"+arg0.getType());
        System.out.println("state:"+arg0.getState());
    }
}

創建ZooKeeper實例時，如果有多個連接，則使用逗號隔開。

import java.io.IOException;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

import com.zang.WatcherTest;

public class App 
{
    
    public static void main( String[] args ) throws IOException, KeeperException, InterruptedException {
        //創建一個Zookeeper實例，第一個參數為目標服務器地址和端口，第二個參數為Session超時時間，第三個為節點變化時的回調方法
       ZooKeeper zk = new ZooKeeper("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183", 30000, new WatcherTest());
       
       String node = "/node2";
       Stat stat = zk.exists(node, false);
       if(null == stat){
           //創建一個節點，數據為test,不進行ACL權限控制，節點為永久性的 
           String createResult = zk.create(node, "test".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
           System.out.println(createResult);
       }
       
       //取得/node2/test節點下的數據,返回byte[] 
       byte[] b = zk.getData(node, false, stat);
       System.out.println(new String(b));
       zk.close();
    }
}

 

 

 

參考：https://blog.csdn.net/qiunian144084/article/details/79192819

https://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/