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/

轉載于:https://www.cnblogs.com/zjfjava/p/9215374.html

總結

以上是生活随笔為你收集整理的ZooKeeper安装及配置（Windows系统下）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。