本文源碼：GitHub·點這里 || GitEE·點這里

一、框架簡介

1、基礎簡介

Zookeeper基于觀察者模式設計的組件，主要應用于分布式系統架構中的，統一命名服務、統一配置管理、統一集群管理、服務器節點動態上下線、軟負載均衡等場景。

• Linux下Zookeeper單節點安裝
• SpringBoot整合Zookeeper中間件

2、集群選舉

Zookeeper集群基于半數機制，集群中半數以上機器存活，集群處于可用狀態。所以建議Zookeeper集群安裝為奇數臺服務器。在集群的配置文件中并沒有指定Master和Slave。在Zookeeper工作時，是有一個節點為Leader，其他則為Follower，Leader是通過內部的選舉機制臨時產生的。

基本描述

假設有三臺服務器組成的Zookeeper集群，每個節點的myid編號依次1-3，依次啟動服務器，會發現server2被選擇為Leader節點。

server1啟動，執行一次選舉。服務器1投自己一票。此時服務器1票數一票，未達到半數以上（2票），選舉無法完成，服務器1狀態保持為LOOKING；

server2啟動，再執行一次選舉。服務器1和2分別投自己一票，并交換選票信息，因為服務器2的myid比服務器1的myid大，服務器1會更改選票為投服務器2。此時服務器1票數0票，服務器2票數2票，達到半數以上，選舉完成，服務器1狀態為follower，2狀態保持leader，此時集群可用，服務器3啟動后直接為follower。

二、集群配置

1、創建配置目錄

# mkdir -p /data/zookeeper/data # mkdir -p /data/zookeeper/logs

2、基礎配置

# vim /opt/zookeeper-3.4.14/conf/zoo.cfgtickTime=2000 initLimit=10 syncLimit=5 dataDir=/data/zookeeper/data dataLogDir=/data/zookeeper/logs clientPort=2181

3、單節點配置

# vim /data/zookeeper/data/myid

三個節點服務，分別在myid文件中寫入[1,2,3]

4、集群服務

在每個服務的zoo.cfg配置文件中寫入如下配置：

server.1=192.168.72.133:2888:3888 server.2=192.168.72.136:2888:3888 server.3=192.168.72.137:2888:3888

5、啟動集群

分別啟動三臺zookeeper服務

[zookeeper-3.4.14]# bin/zkServer.sh start Starting zookeeper ... STARTED

6、查看集群狀態

Mode: leader是Master節點

Mode: follower是Slave節點

[zookeeper-3.4.14]# bin/zkServer.sh status Mode: leader

7、集群狀態測試

隨便登錄一臺服務的客戶端，創建一個測試節點，然后在其他服務上查看。

[zookeeper-3.4.14 bin]# ./zkCli.sh [zk: 0] create /node-test01 node-test01 Created /node-test01 [zk: 1] get /node-test01

或者關閉leader節點

[zookeeper-3.4.14 bin]# ./zkServer.sh stop

則會重新選舉該節點。

8、Nginx統一管理

[rnginx-1.15.2 conf]# vim nginx.confstream {upstream zkcluster {server 192.168.72.133:2181;server 192.168.72.136:2181;server 192.168.72.136:2181;}server {listen 2181;proxy_pass zkcluster;} }

三、服務節點監聽

1、基本原理

分布式系統中，主節點可以有多臺，可以動態上下線，任意一臺客戶端都能實時感知到主節點服務器的上下線。

流程描述：

• 啟動Zookeeper集群服務；
• RegisterServer模擬服務端注冊；
• ClientServer模擬客戶端監聽；
• 啟動服務端注冊三次，注冊不同節點的zk-node服務；
• 依次關閉注冊的服務端，模擬服務下線流程；
• 查看客戶端日志，可以監控到服務節點變化；

首先創建一個節點：serverList，用來存放服務器列表。

[zk: 0] create /serverList "serverList"

2、服務端注冊

package com.zkper.cluster.monitor; import java.io.IOException; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.ZooDefs.Ids;public class RegisterServer {private ZooKeeper zk ;private static final String connectString = "127.0.0.133:2181,127.0.0.136:2181,127.0.0.137:2181";private static final int sessionTimeout = 3000;private static final String parentNode = "/serverList";private void getConnect() throws IOException{zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {}});}private void registerServer(String nodeName) throws Exception{String create = zk.create(parentNode + "/server", nodeName.getBytes(),Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println(nodeName +" 上線："+ create);}private void working() throws Exception{Thread.sleep(Long.MAX_VALUE);}public static void main(String[] args) throws Exception {RegisterServer server = new RegisterServer();server.getConnect();// 分別啟動三次服務，注冊不同節點，再一次關閉不同服務端看客戶端效果// server.registerServer("zk-node-133");// server.registerServer("zk-node-136");server.registerServer("zk-node-137");server.working();} }

3、客戶端監聽

package com.zkper.cluster.monitor; import org.apache.zookeeper.*; import java.io.IOException; import java.util.ArrayList; import java.util.List;public class ClientServer {private ZooKeeper zk ;private static final String connectString = "127.0.0.133:2181,127.0.0.136:2181,127.0.0.137:2181";private static final int sessionTimeout = 3000;private static final String parentNode = "/serverList";private void getConnect() throws IOException {zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {try {// 監聽在線的服務列表getServerList();} catch (Exception e) {e.printStackTrace();}}});}private void getServerList() throws Exception {List<String> children = zk.getChildren(parentNode, true);List<String> servers = new ArrayList<>();for (String child : children) {byte[] data = zk.getData(parentNode + "/" + child, false, null);servers.add(new String(data));}System.out.println("當前服務列表："+servers);}private void working() throws Exception{Thread.sleep(Long.MAX_VALUE);}public static void main(String[] args) throws Exception {ClientServer client = new ClientServer();client.getConnect();client.getServerList();client.working();}}

四、源代碼地址

GitHub·地址 https://github.com/cicadasmile/data-manage-parent GitEE·地址 https://gitee.com/cicadasmile/data-manage-parent

推薦閱讀：數據和架構管理

序號標題

A01	數據源管理：主從庫動態路由，AOP模式讀寫分離
A02	數據源管理：基于JDBC模式，適配和管理動態數據源
A03	數據源管理：動態權限校驗，表結構和數據遷移流程
A04	數據源管理：關系型分庫分表，列式庫分布式計算
A05	數據源管理：PostGreSQL環境整合，JSON類型應用
A06	數據源管理：基于DataX組件，同步數據和源碼分析
C01	架構基礎：單服務.集群.分布式，基本區別和聯系
C02	架構設計：分布式業務系統中，全局ID生成策略

總結

以上是生活随笔為你收集整理的架构设计 | 分布式系统调度，Zookeeper集群化管理的全部內容，希望文章能夠幫你解決所遇到的問題。

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