zookeeper 搭建偽群集


zookeeper 大概就是

目前只介紹這個東西的用途，可以得知我們的我們的服務都註冊到zookeeper 裡面的一個節點，然後我們可以透過去請求 zookeeper 先取得節點的可用伺服器清單，然後client 再去訪問可用的伺服器清單，這個就是 zookeeper 大概用途。

這邊文章後下回 spring cloud 來實作微服務(ps 不是這個文

zookeeper 應用場景

  • 分布式協調
  • 分布式所
  • 元数据/配置信息管理
  • HA高可用

分布式协调这个其实是 zookeeper 很经典的一个用法，简单来说，就好比，你 A 系统发送个请求到 mq，然后 B 系统消息消费之后处理了。那 A 系统如何知道 B 系统的处理结果？用 zookeeper 就可以实现分布式系统之间的协调工作。A 系统发送请求之后可以在 zookeeper 上对某个节点的值注册个监听器，一旦 B 系统处理完了就修改 zookeeper 那个节点的值，A 系统立马就可以收到通知，完美解决。

分布式锁举个栗子。对某一个数据连续发出两个修改操作，两台机器同时收到了请求，但是只能一台机器先执行完另外一个机器再执行。那么此时就可以使用 zookeeper 分布式锁，一个机器接收到了请求之后先获取 zookeeper 上的一把分布式锁，就是可以去创建一个 znode，接着执行操作；然后另外一个机器也尝试去创建那个 znode，结果发现自己创建不了，因为被别人创建了，那只能等着，等第一个机器执行完了自己再执行。

元数据/配置信息管理zookeeper 可以用作很多系统的配置信息的管理，比如 kafka、storm 等等很多分布式系统都会选用 zookeeper 来做一些元数据、配置信息的管理，包括 dubbo 注册中心不也支持 zookeeper 么？

HA高可用性这个应该是很常见的，比如 hadoop、hdfs、yarn 等很多大数据系统，都选择基于 zookeeper 来开发 HA 高可用机制，就是一个重要进程一般会做主备两个，主进程挂了立马通过 zookeeper 感知到切换到备用进程。

環境設定

下載 zookeeper 3.4.14
cd : /opt
wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
tar zxvf zookeeper-3.4.14.tar.gz


安裝目錄 : /opt/zookeeper
mkdir /opt/zookeeper
cd /opt/zookeeper 
tar -zxvf  /opt/zookeeper-3.4.11.tar.gz 
cp -rf /opt/zookeeper/zookeeper-3.4.11   /opt/zookeeper/zk1
cp -rf /opt/zookeeper/zookeeper-3.4.11   /opt/zookeeper/zk2
cp -rf /opt/zookeeper/zookeeper-3.4.11   /opt/zookeeper/zk3
rm -rf  /opt/zookeeper/zookeeper-3.4.11 

到這邊已經產生了三個節點

 /opt/zookeeper/zk1
 /opt/zookeeper/zk2
 /opt/zookeeper/zk3

zoo.cfg 配置

更多配置參數說明
https://kknews.cc/zh-tw/code/plmkpp8.html

節點1

#zookeeper时间单元，单位为毫秒
tickTime=2000
#集群中的follower服务器(F)与leader服务器(L)之间 初始连接 时能容忍的最多心跳数（tickTime的数量）。
initLimit=10
# 集群中的follower服务器(F)与leader服务器(L)之间 请求和应答 之间能容忍的最多心跳数（tickTime的数量）。
syncLimit=5
# data数据目录
dataDir=/opt/zookeeper/zk1/data
# 客户端连接端口
clientPort=2181
# 客户端最大连接数
#maxClientCnxns=60
# 需要保留的快照数目
#autopurge.snapRetainCount=3
# 是否开启自动清理事务日志和快照功能 0 不开启，1表示开启
#autopurge.purgeInterval=1
#集群配置 
server.1=127.0.0.1:2888:3888
server.2=127.0.0.1:2889:3889
server.3=127.0.0.1:2890:3890

節點2

#zookeeper时间单元，单位为毫秒
tickTime=2000
#集群中的follower服务器(F)与leader服务器(L)之间 初始连接 时能容忍的最多心跳数（tickTime的数量）。
initLimit=10
# 集群中的follower服务器(F)与leader服务器(L)之间 请求和应答 之间能容忍的最多心跳数（tickTime的数量）。
syncLimit=5
# data数据目录
dataDir=/opt/zookeeper/zk2/data
# 客户端连接端口
clientPort=2182
# 客户端最大连接数
#maxClientCnxns=60
# 需要保留的快照数目
#autopurge.snapRetainCount=3
# 是否开启自动清理事务日志和快照功能 0 不开启，1表示开启
#autopurge.purgeInterval=1
#集群配置 
server.1=127.0.0.1:2888:3888
server.2=127.0.0.1:2889:3889
server.3=127.0.0.1:2890:3890

節點3

#zookeeper时间单元，单位为毫秒
tickTime=2000
#集群中的follower服务器(F)与leader服务器(L)之间 初始连接 时能容忍的最多心跳数（tickTime的数量）。
initLimit=10
# 集群中的follower服务器(F)与leader服务器(L)之间 请求和应答 之间能容忍的最多心跳数（tickTime的数量）。
syncLimit=5
# data数据目录
dataDir=/opt/zookeeper/zk3/data
# 客户端连接端口
clientPort=2183
# 客户端最大连接数
#maxClientCnxns=60
# 需要保留的快照数目
#autopurge.snapRetainCount=3
# 是否开启自动清理事务日志和快照功能 0 不开启，1表示开启
#autopurge.purgeInterval=1
#集群配置 
server.1=127.0.0.1:2888:3888
server.2=127.0.0.1:2889:3889
server.3=127.0.0.1:2890:3890

CentOS Linux开启和关闭防火墙命令有两种，一种是临时的，重启即复原；另外一种是永久性的，重启不会复原。
1） 临时生效，重启后复原
开启： service iptables start
关闭： service iptables stop
2） 永久性生效，重启后不会复原
开启： chkconfig iptables on
关闭： chkconfig iptables off

myid 配置

需要在 data 裡面新增 一個 myid 文件各一個

echo '1'  >  /opt/zookeeper/zk1/data/myid
echo '2'  >  /opt/zookeeper/zk2/data/myid
echo '3'  >  /opt/zookeeper/zk3/data/myid

日誌路徑 配置

修改 bin 目錄的 zkEnv.sh
把 ZOO_LOG_DIR 設為

ZOO_LOG_DIR="../logs/"

啟動

/opt/zookeeper/zk1/bin/zkServer.sh start
/opt/zookeeper/zk2/bin/zkServer.sh start
/opt/zookeeper/z3/bin/zkServer.sh start

client 連接

隨機訪問任意server
create /test 123

/opt/zookerper/zk1/bin/zkCli.sh -server 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183

client 創建一個 test znode

隨機訪問任意節點

create /test /123

client 查看 test znode

get /test

查看 log

當有節點異動都可從這個 log 進行觀看

logs$ tail -f zookeeper.out

參考

https://juejin.im/post/5db059046fb9a0204875e6c7

Select a repo