zookeeper的簡單搭建，java使用zk的例子和一些坑

ZooKeeper Java · 發表 2018-09-11 11:40:00

摘要：一整合由於本人的碼雲太多太亂了，於是決定一個一個的整合到一個springboot專案裡面。附上自己的github專案地址 https://github.com/247292980/spring-boot 附上彙總博文地址 https://www.cnblogs.com/...

一整合

由於本人的碼雲太多太亂了，於是決定一個一個的整合到一個springboot專案裡面。

附上自己的github專案地址 ofollow,noindex">https://github.com/247292980/spring-boot

附上彙總博文地址 https://www.cnblogs.com/ydymz/p/9391653.html

以整合功能

spring-boot，FusionChart，thymeleaf，vue，ShardingJdbc，mybatis-generator，微信分享授權，drools，spring-security，spring-jpa，webjars，Aspect，drools-drt，rabbitmq

這次就來整合下簡單的zookeeper搭建

二安裝

這玩意最坑的地方在於，和mq一樣，百度第一的安裝教程缺了一部分。

1 . 先安裝java並配置環境變數。直接百度，進官網下載，還是程式員最喜歡的解壓安裝，贊！

2.將安裝目錄下的conf資料夾下的zoo_sample.cfg複製一份並命名為zoo.cfg，如下圖

3.修改一下配置，主要是dataDir和dataDirLog，並且要建立相應的資料夾

配置檔案簡單解析

1、tickTime：這個時間是作為Zookeeper 伺服器之間或客戶端與伺服器之間維持心跳的時間間隔，也就是每個 tickTime 時間就會發送一個心跳。

2、dataDir：顧名思義就是Zookeeper 儲存資料的目錄，預設情況下，Zookeeper 將寫資料的日誌檔案也儲存在這個目錄裡。

3、dataLogDir：顧名思義就是Zookeeper 儲存日誌檔案的目錄

4、clientPort：這個埠就是客戶端連線Zookeeper 伺服器的埠，Zookeeper 會監聽這個埠，接受客戶端的訪問請求。

4.進入到bin目錄，並且啟動zkServer.cmd

zkServer.cmd
可以通過以下程式碼檢驗有沒有成功啟動，成功後有一個QuorumPeerMain的程序
jps -l –v

5.啟動一個 zkCli

zkCli 127.0.0.1:2181

6.具體的cli可以去w3c裡面瞭解，建議都試一次 https://www.w3cschool.cn/zookeeper/zookeeper_api.html

建議zkCli裡面，跑一下這些命令，否則普通demo的java程式碼裡面就什麼都沒有了

create /FirstZnode FirstZnode1
create /SecondZnode SecondZnode2
create /ThirdZnode ThirdZnode3

三程式碼

程式碼有點多，我只貼叢集監聽demo和普通demo，基本上實際使用的都是叢集監聽demo，而普通demo是給大家一個過渡的階段。

要是看完普通還看不懂叢集監聽，可以github把我的程式碼拷下來，裡面有個中間態，監聽demo。

普通demo，很簡單獲取根目錄下的全部children

public class ZkDemo {
public static void main(String[] args) throws IOException {
String hostPort = "localhost:2181";
List<String> zooChildren = new ArrayList<String>();
ZooKeeper zk = new ZooKeeper(hostPort, 2000, null);
if (zk != null) {
try {
String zpath = "/";
zooChildren = zk.getChildren(zpath, false);
System.out.println("Znodes of '/': ");
for (String child : zooChildren) {
System.out.println(child);
}
}catch (Exception e) {
e.printStackTrace();
}
}
}
}

叢集監聽demo.ClusterMonitor，寫成執行緒是讓他當個伺服器，小白如果看到idea提示紅色報警有點慌的話，可以看看檔名字有沒有紅色波浪線，沒有即說明程式碼正常

public class ClusterMonitor implements Runnable {
private static String membershipRoot = "/Members";
private final Watcher connectionWatcher;
private final Watcher childrenWatcher;
private ZooKeeper zk;
boolean alive = true;

public ClusterMonitor(String HostPort) throws IOException, InterruptedException, KeeperException {
connectionWatcher = new Watcher() {
@Override
public void process(WatchedEvent event) {
if (event.getType() == Watcher.Event.EventType.None && event.getState() == Watcher.Event.KeeperState.SyncConnected) {
System.out.printf("\nEvent Received: %s", event.toString());
}
}
};

childrenWatcher = new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.printf("\nEvent Received: %s", event.toString());
if (event.getType() == Event.EventType.NodeChildrenChanged) {
try {
//Get current list of child znode,
//reset the watch
List<String> children = zk.getChildren(membershipRoot, this);
wall("!!!Cluster Membership Change!!!");
wall("Members: " + children);
} catch (KeeperException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
alive = false;
throw new RuntimeException(e);
}
}
}
};

zk = new ZooKeeper(HostPort, 2000, connectionWatcher);

// Ensure the parent znode exists
if (zk.exists(membershipRoot, false) == null) {
zk.create(membershipRoot, "ClusterMonitorRoot".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}

// Set a watch on the parent znode
List<String> children = zk.getChildren(membershipRoot, childrenWatcher);
System.err.println("Members: " + children);
}

public synchronized void close() {
try {
zk.close();
} catch (InterruptedException e) {
e.printStackTrace();
}
}

public void wall(String message) {
System.out.printf("\nMESSAGE: %s", message);
}

@Override
public void run() {
try {
synchronized (this) {
while (alive) {
wait();
}
}
} catch (InterruptedException e) {
e.printStackTrace();
Thread.currentThread().interrupt();
} finally {
this.close();
}
}

public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
String hostPort = "localhost:2181";
new ClusterMonitor(hostPort).run();
}
}

叢集監聽demo.ClusterClient，這個可能需要你多開幾個java執行緒跑， idea改一下啟動引數就好了，然後在伺服器裡面對比才比較明顯

命令列啟動java執行緒的程式碼

java -cp $CLASSPATH ClusterMonitor

public class ClusterClient implements Watcher, Runnable {
private static String membershipRoot = "/Members";
ZooKeeper zk;

public ClusterClient(String hostPort, Long pid) {
String processId = pid.toString();
try {
zk = new ZooKeeper(hostPort, 2000, this);
if (zk != null) {
zk.create(membershipRoot + '/' + processId, processId.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
}
} catch (Exception e) {
e.printStackTrace();
}
}



public synchronized void close() {
try {
zk.close();
} catch (InterruptedException e) {
e.printStackTrace();
}
}

@Override
public void process(WatchedEvent event) {
System.out.printf("\nEvent Received: %s", event.toString());
}

@Override
public void run() {
try {
synchronized (this) {
while (true) {
wait();
}
}
} catch (InterruptedException e) {
e.printStackTrace();
Thread.currentThread().interrupt();
} finally {
this.close();
}
}

public static void main(String[] args) {
String hostPort = "localhost:2181";
//Get the process id
String name = ManagementFactory.getRuntimeMXBean().getName();
int index = name.indexOf('@');
Long processId = Long.parseLong(name.substring(0, index));
new ClusterClient(hostPort, processId).run();
}
}

四總結

1.因為基本是和rabbitmq一起寫的博文，我難免會把他們做一番對比，zk和mq的安裝比起來，明顯zk簡單多了。或許原因是mq是用erlang寫的？

2.zk的生態圈很好，畢竟是Apache大廠出品，以上的程式碼，都是直接看Apache zookeeper的官網java版的api寫的，比rabbitmq不是好的一點半點，例如mq包的報錯日誌問題...

建議去zk官網看一下api或者英語不好的去w3c的zk專欄 https://www.w3cschool.cn/zookeeper/

3.坑也就是要生成幾個檔案，看下日誌就知道怎麼做，頂多是其他人的博文不太完整。

4.zk的例子比mq的多，是因為zk可以直接建立znode，而mq的佇列，通道，廣播必須cli或者gui裡面建立，工具包遠沒有zk方便。而我兩篇博文的目的就是java呼叫而不是設計，所以並沒有細說

5.最後每個專案都建議，諸位自己寫一遍跑一遍，或者直接github我的程式碼跑一遍。

zookeeper的簡單搭建，java使用zk的例子和一些坑

一 整合

二 安裝

三 程式碼

四 總結

您可能也會喜歡…

一整合

二安裝

三程式碼

四總結