ZooKeeper1 利用虛擬機搭建本身的ZooKeeper集羣

時間 2019-11-18

標籤 zookeeper1 zookeeper 利用虛擬機搭建本身集羣欄目 Zookeeper 简体版

原文原文鏈接

前言:html

前段時間本身參考網上的文章，梳理了一下基於分佈式環境部署的業務系統在解決數據一致性問題上的方案，其中有一個方案是使用ZooKeeper，加之在大數據處理中，ZooKeeper確實起到協調服務的做用，因此利用週末休息時間，本身在虛擬機上簡單搭建了一個ZooKeeper集羣，學習瞭解一下。java

===============================================================長長的分割線====================================================================node

正文:apache

　　在本文中主要涉及三塊內容: 第一，就是搭建虛擬機環境；第二，安裝ZooKeeper、啓動ZooKeeper以及使用內置命令操做ZooKeeper；第三，使用Java API完成操做，以便了解如何在實際的項目中使用。bash

　　閒話少說，言歸正傳，本次的目的是利用VMware搭建一個屬於本身的ZooKeeper集羣。本次咱們選擇的是VMware10，具體的安裝步驟你們能夠到網上搜索，資源不少。服務器

　　第一步，肯定目標:網絡

ZooKeeperOne 192.168.224.170 CentOS分佈式

ZooKeeperTwo 192.168.224.171 CentOSoop

ZooKeeperThree 192.168.224.172 CentOS學習

咱們安裝的ZooKeeper是3.4.6版本，能夠從這裏下載zookeeper-3.4.6; JDK安裝的版本是1.7版本

第二步，安裝CentOS環境、JDK1.七、配置網絡:

此處你們能夠參考網上的文章，或者參考我以前寫的一篇文章 Hadoop4 利用VMware搭建本身的hadoop集羣，該文章中的第一步到第八步涉及了安裝基本環境的步驟哦和方法。咱們只須要注意一下兩點:

(1). 因爲咱們是在VMware中搭建三個服務器，因此咱們能夠先搭建一臺，待配置都okay後，再利用VMware的克隆功能，直接克隆出另外兩臺，克隆出的兩臺只須要注意修改 /etc/sysconfig/network-scripts/ifcfg-eth0 中HWADDR屬性、IPADDR 以及 /etc/sysconfig/network 的主機名稱HOSTNAME

(2). JDK的安裝注意使用JDK1.7，有些ZooKeeper版本在JDK1.6下是不支持的，因此簡單一點，咱們就直接使用JDK1.7。

第三步，安裝配置ZooKeeper:

(1). 從這裏下載zookeeper-3.4.6，將文件解壓縮，不用安裝。以個人爲例，個人ZooKeeper路徑是: /myself_settings/zookeeper3.4.6/zookeeper-3.4.6，詳細以下圖:

(2). 須要執行 vi ~/.bash_profile，編輯一下ZooKeeper的環境變量，編輯完畢後執行 source ~/.bash_profile 使配置生效，詳細以下圖:

(3). 在(1)的zookeeper目錄中，有一個conf文件夾，該文件夾中有一個 zoo_sample.cfg 的文件，咱們使用命令 mv zoo_sample.cfg zoo.cfg 複製出一個zoo.cfg文件，這個文件就是ZooKeeper啓動是時候默認要加載的配置文件，咱們能夠打開zoo.cfg查看都有哪些配置，並簡單瞭解一下配置的含義，而後咱們須要將配置改爲以下圖中的配置:

(4). 如(3)中的圖中的配置，除了我在圖中用紅色框圈中的屬性須要你添加或者修改，其他屬性可使用默認的。對於dataDir和dataLogDir這連個配置，顧名思義，分別是ZooKeeper的數據和日誌目錄，這個路徑能夠任意配置，我本身的目錄就分別爲/opt/zookeeper4.3.6/data 和 /opt/zookeeper4.3.6/log; 對於配置中的最後三行，每一行的格式都形如: server.id=host:port1:port2，其中host就是你的主機名稱，port1表明着從(follower)機器鏈接到主(leader)機器的端口，port2表明着是用來進行leader選舉的端口，注意這兩個端口與 clientPort=2181 這個端口的含義區別。還有server.id中的id標識的是不一樣的服務器，在dataDir這個配置的路徑下，創建一個名爲myid的文件，在文件中只包含一行內容，即所指定的自身的id值，好比服務器"1"應該在myid文件中寫入"1"。

(5). 其他兩臺服務器，注意修改(4)中的提到的這些須要變更的配置。

(6). 通過上邊的配置，咱們就能夠準備啓動ZooKeeper了，我麼經過執行 zkServer.sh start 就能夠將ZooKeeper啓動了，其他服務器也直接使用相同命令啓動便可。咱們也可使用 zkServer.sh start 指定路徑的zoo.cfg文件這個命令來啓動ZooKeeper。啓動成功截圖詳細以下:

第四步，使用客戶端命令訪問客戶端:

(1). 咱們能夠在服務器上執行 zkCli.sh -server 192.168.224.170:2181 進入客戶端，咱們能夠看到WelCome to ZooKeeper!等文字，詳細以下圖:

(2). 在客戶端中咱們瞭解如下幾個命令，你們能夠自行在客戶端執行體驗一下，對於get /zk這個命令執行返回的結果中，每一個屬性的含義值你們能夠參考這片文章初步瞭解一下。

a. ls / 該命令用來查看當前ZooKeeper中所包含的內容

b. create /zk myData 該命令是建立了一個新的Znode節點zk，其內容是 myData

c. get /zk 該命令是獲取已建立節點的信息

d. set /zk hahaha 該命令是對zk這個節點的內容進行設置

e. delete /zk 該命令是刪除某個節點

第五步，使用Java API訪問ZooKeeper:

其實Java API提供的功能基本也是基於上邊的客戶端命令來實現的，萬變不離其宗，我將我整理的網上的例子貼到下面，你們能夠在本地Java工程中執行一下，便可瞭解調用方法。這裏有一點須要注意，咱們須要在本地Java工程中引入 ZooKeeper安裝包根目錄下的zookeeper-3.4.6.jar 和 lib目錄中的jar包。

 1 import java.util.List;
 2 
 3 import org.apache.zookeeper.CreateMode;
 4 import org.apache.zookeeper.WatchedEvent;
 5 import org.apache.zookeeper.Watcher;
 6 import org.apache.zookeeper.ZooDefs.Ids;
 7 import org.apache.zookeeper.ZooKeeper;
 8 import org.apache.zookeeper.data.Stat;
 9 
10 
11 /**
12  * @Title ZookeeperDemo0001.java
13  * @Package 
14  * @author zhangyi03
15  * @description 基於zookeeper3.4.6，完成第一個zookeeper程序
16  * @date 2015-9-19 下午11:14:20
17  * @version v1.0
18  */
19 public class ZookeeperDemo0001 {
20     // 會話超時時間，設置爲系統默認時間一致
21     private static final int SESSION_TIMEOUT = 30000;
22     
23     // 建立ZooKeeper實例
24     ZooKeeper zk;
25     
26     // 建立Watcher實例
27     Watcher wh = new Watcher() {
28         public void process(WatchedEvent event) {
29             System.out.println(event.toString());
30         }
31     };
32     
33     // 初始化ZooKeeper實例
34     private void createZKInstance() throws Exception {
35         zk = new ZooKeeper("192.168.224.170:2181", SESSION_TIMEOUT, wh);
36     }
37     
38     private void ZKOperations() throws Exception {
39         System.out.println("\n1. 建立 ZooKeeper 節點 (znode: zoo2, 數據: myData2, " +
40                 "權限: OPEN_ACL_UNSAFE, 節點類型: Persistent)");
41         zk.create("/zoo2", "myData2".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
42         
43         System.out.println("\n2. 查看是否建立成功:");
44         System.out.println(new String(zk.getData("/zoo2", false, null)));
45         
46         System.out.println("\n3. 修改節點數據");
47         Stat setDataStat = zk.setData("/zoo2", "zhangyi03201509192339".getBytes(), -1);
48         
49         
50         System.out.println("\n4. 查看是否修改爲功:");
51         System.out.println(new String(zk.getData("/zoo2", false, null)));
52         
53         System.out.println("\n5. 添加子節點");
54         for (int index = 0; index < 3; index++) {
55             zk.create("/zoo2/" + "child_" + (index+1), ("child_" + (index+1)).getBytes(), 
56                     Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
57         }
58         
59         System.out.println("\n6. 查看全部子節點:");
60         List<String> childList = zk.getChildren("/zoo2", false);
61         for (String child : childList) {
62             System.out.println("\t\t\t 子節點:" + child);
63         }
64         
65         System.out.println("\n7. 刪除全部子節點");
66         for (String child : childList) {
67             zk.delete("/zoo2" + "/" + child, -1);
68         }
69         
70         System.out.println("\n8. 刪除節點");
71         zk.delete("/zoo2", -1);
72         
73         System.out.println("\n9. 查看節點是否被刪除:");
74         System.out.println("節點狀態: [" + zk.exists("/zoo2", false) + "]");
75     }
76     
77     private void ZKClose() throws Exception {
78         zk.close();
79     }
80     
81     /**
82      * @author zhangyi03
83      * @date 2015-9-19 下午11:14:01
84      * @description 
85      * @param args
86      */
87     public static void main(String[] args) throws Exception {
88         ZookeeperDemo0001 demo = new ZookeeperDemo0001();
89         demo.createZKInstance();
90         demo.ZKOperations();
91         demo.ZKClose();
92     }
93 }