天天看點

Zookeeper叢集搭建

1 叢集角色

Zookeeper 叢集模式一共有三種類型的角色:

  • Leader: 處理所有的事務請求(寫請求),可以處理讀請求,叢集中隻能有一個Leader。
  • Follower:隻能處理讀請求,同時作為Leader的候選節點,即如果Leader當機,Follower節點要參與到新的Leader選舉中,有可能成為新的Leader節點。
  • Observer:隻能處理讀請求。不能參與選舉。

2 環境說明

本例搭建的是僞叢集模式,即一台機器上啟動四個zookeeper執行個體組成叢集,真正的叢集模式無非就是執行個體IP位址不同,搭建方法沒有差別。

Zookeeper叢集搭建

其中1個leader,2個follower,1個observer。

3 配置JAVA環境

檢驗環境:保證是jdk7 及以上即可:

[root@zookeeper1 ~]# java -version
openjdk version "1.8.0_222"
OpenJDK Runtime Environment (build 1.8.0_222-b10)
OpenJDK 64-Bit Server VM (build 25.222-b10, mixed mode)      

4 下載下傳zookeeper安裝包

下載下傳連結:

https://zookeeper.apache.org/releases.html
tar -xzvf apache-zookeeper-3.5.8-bin.tar.gz      

5 建立相應目錄

mkdir -p /root/zookeeper-cluster/zk1
mkdir -p /root/zookeeper-cluster/zk2
mkdir -p /root/zookeeper-cluster/zk3
mkdir -p /root/zookeeper-cluster/zk4      

6 編輯配置檔案

這裡隻列出zk1的配置檔案,其餘3個配置檔案隻需要修改dataDir和clientPort即可。

tickTime=2000 
initLimit=10
syncLimit=5
dataDir=/root/zookeeper-cluster/zk1  #根據執行個體修改zk1,zk2,zk3,zk4
clientPort=2181 #根據執行個體修改2181,2182,2183,2184
server.1=127.0.0.1:2001:3001:participant
server.2=127.0.0.1:2002:3002:participant
server.3=127.0.0.1:2003:3003:participant
server.4=127.0.0.1:2004:3004:observer      

配置說明:

  • tickTime:用于配置Zookeeper中最小時間機關的長度,機關是毫秒,很多運作時的時間間隔都是使用tickTime的倍數來表示的。
  • initLimit:該參數用于配置Leader伺服器等待Follower啟動,并完成資料同步的時間。Follower伺服器在啟動過程中,會與Leader建立連接配接并完成資料的同步,進而确定自己對外提供服務的起始狀态。Leader伺服器允許Follower在initLimit時間内完成這個工作。
  • syncLimit:Leader與Follower心跳檢測的最大延時時間。
  • dataDir:顧名思義就是 Zookeeper儲存資料的目錄,預設情況下,Zookeeper 将寫資料的日志檔案也儲存在這個目錄裡。
  • clientPort:這個端口就是用戶端連接配接Zookeeper伺服器的端口,Zookeeper會監聽這個端口,接受用戶端的通路請求。
  • server.A=B:C:D:E:
    • A 是一個數字,表示這個是第幾号伺服器;
    • B 是這個伺服器的ip位址;
    • C 表示的是這個伺服器與叢集中的 Leader 伺服器交換資訊的端口;
    • D 表示的是萬一叢集中的 Leader 伺服器挂了,需要一個端口來重新進行選舉,選出一個新 的 Leader,而這個端口就是用來執行選舉時伺服器互相通信的端口。如果是僞叢集的配置方式,由于B都是一樣,是以不同的 Zookeeper 執行個體通信端口号不能一樣,是以要給 它們配置設定不同的端口号。
    • E 如果需要通過添加不參與叢集選舉Observer節點,可以在E的位置,添加observer辨別。

7 辨別Server ID

在前面指定的dataDir目錄下,根據不同的執行個體添加名為myid的檔案,内容為執行個體ID。

echo 1 > /root/zookeeper-cluster/zk1/myid
echo 2 > /root/zookeeper-cluster/zk2/myid
echo 3 > /root/zookeeper-cluster/zk3/myid
echo 4 > /root/zookeeper-cluster/zk4/myid      

8 檢視目錄結構

[root@zookeeper1 zookeeper-cluster]# tree /root/zookeeper-cluster
.
├── zk1
│   ├── myid
│   └── zoo.cfg
├── zk2
│   ├── myid
│   └── zoo.cfg
├── zk3
│   ├── myid
│   └── zoo.cfg
└── zk4
    ├── myid
    └── zoo.cfg
4 directories, 8 files      

9 啟動4個zookeeper執行個體

啟動之前可以先将zookeeper腳本的目錄添加到PATH路徑,目的是可以在任意目錄下運作zookeeper腳本。編輯/etc/profile,添加如下内容:

export ZK_HOME=/root/apache-zookeeper-3.5.8-bin/bin
export PATH=$PATH:$ZK_HOME      

編輯完成後source /etc/profile使其生效。

zkServer.sh start /root/zookeeper-cluster/zk1/zoo.cfg 
zkServer.sh start /root/zookeeper-cluster/zk2/zoo.cfg 
zkServer.sh start /root/zookeeper-cluster/zk3/zoo.cfg 
zkServer.sh start /root/zookeeper-cluster/zk4/zoo.cfg      

10 檢視叢集角色

可以看到此時zk2為leader,zk1和zk3為follower,zk4為observer。

[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk1/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk1/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: follower
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk2/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk2/zoo.cfg
Client port found: 2182. Client address: localhost.
Mode: leader
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk3/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk3/zoo.cfg
Client port found: 2183. Client address: localhost.
Mode: follower
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk4/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk4/zoo.cfg
Client port found: 2184. Client address: localhost.
Mode: observer
[root@zookeeper1 zookeeper-cluster]# ls      

11 連接配接叢集

zkCli.sh  -server 127.0.0.1:2181
#可以通過 檢視/zookeeper/config 節點資料來檢視叢集配置
[zk: 127.0.0.1:2181(CONNECTED) 1] get /zookeeper/config
server.1=127.0.0.1:2001:3001:participant
server.2=127.0.0.1:2002:3002:participant
server.3=127.0.0.1:2003:3003:participant
server.4=127.0.0.1:2004:3004:observer
version=0