ZooKeeper入門教程二在單機和集群環(huán)境下的安裝搭建及使用
通過本篇學(xué)習(xí)掌握zookeeper環(huán)境的搭建，為后續(xù)學(xué)習(xí)做好準(zhǔn)備
1、下載
首先我們下載最新穩(wěn)定版本的zookeeper
http://m.fzitv.net/softs/578345.html
2、解壓
下載完成后，我們解開壓縮包
3、創(chuàng)建配置文件
解壓后的路徑下找到conf文件夾，進入conf文件夾復(fù)制zoo_sample.cfg，命名為zoo.cfg
# 每個tick的毫秒數(shù)。后面的initLimit和syncLimit都以tick為單位 tickTime=2000 #初始化同步階段時長 initLimit=10 # 同步確認時長 syncLimit=5 # 快照存儲路徑，不要使用/tmp。這里使用只是為了示例 dataDir=/tmp/zookeeper # 客戶端端口好 clientPort=2181 #可連接的client的最大數(shù) #如果需要處理更多的clinet，請增加此數(shù)量 #maxClientCnxns=60 # Be sure to read the maintenance section of the # # administrator guide before turning on autopurge. # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance # # The number of snapshots to retain in dataDir #autopurge.snapRetainCount=3 # Purge task interval in hours # Set to "0" to disable auto purge feature #autopurge.purgeInterval=1
對于學(xué)習(xí)來說，一般無需做修改。生產(chǎn)環(huán)境，需要修改dataDir。其他參數(shù)后續(xù)調(diào)優(yōu)。
4、單機啟動ZooKeeper
在ZooKeeper根目錄下執(zhí)行 bin/zkServer.sh start
? zookeeper-3.4.12 bin/zkServer.sh start ZooKeeper JMX enabled by default Using config: /Users/yimingli/dev/tool/zookeeper-3.4.12/bin/../conf/zoo.cfg Starting zookeeper ... STARTED
5、通過客戶端連接ZooKeeper
? zookeeper-3.4.12 bin/zkCli.sh
6、通過客戶端執(zhí)行基本命令
1、創(chuàng)建znode，名為/my_test，攜帶數(shù)據(jù)testData
[zk: localhost:2181(CONNECTED) 0] create /my_test testData
2、查看znode信息
[zk: localhost:2181(CONNECTED) 2] get /my_test
返回如下：
testData cZxid = 0x2e9 ctime = Mon Oct 29 10:50:46 CST 2018 mZxid = 0x2e9 mtime = Mon Oct 29 10:50:46 CST 2018 pZxid = 0x2e9 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 8 numChildren = 0
3、修改znode數(shù)據(jù)
[zk: localhost:2181(CONNECTED) 3] set /my_test testDataV2
4、創(chuàng)建子znode
[zk: localhost:2181(CONNECTED) 0] create /my_test/tester1 testData
5、列出子znode
[zk: localhost:2181(CONNECTED) 5] ls /my_test [tester1]
6、刪除znode
有子節(jié)點的znode不能直接刪除，否則會報錯。
[zk: localhost:2181(CONNECTED) 6] delete /my_test Node not empty: /my_test
我們刪除/my_test/tester1。
[zk: localhost:2181(CONNECTED) 8] delete /my_test/tester1
再次查看該znode。
[zk: localhost:2181(CONNECTED) 9] get /my_test/tester1 Node does not exist: /my_test/tester1
已經(jīng)被成功刪除了。
7、集群配置和啟動
我們配置和啟動一個三臺server的集群。
1、修改zoo.cfg文件
tickTime=2000 dataDir=/var/lib/zookeeper clientPort=2181 initLimit=5 syncLimit=2 server.1=ip1:2888:3888 server.2=ip2:2888:3888 server.3=ip3:2888:3888
initLimit，zookeeper用來限制zookeeper服務(wù)器連接到leader的時長。
syncLimit，一個服務(wù)器多久在leader那里過期。
以上兩種過期時間，單位都是tickTime，
本例initLimit時長為5個tickTime＝5*2000ms＝10秒
server.x列出了所有的zookeeper服務(wù)。集群啟動它通過查看data下面的myid來知道自己是哪臺服務(wù)器。
2888用來連接其它server。3888用來leader選舉。
2、復(fù)制2份zookeeper到另外兩臺server上。
3、在配置的dataDir路徑下創(chuàng)建myid文件,文件內(nèi)容為對應(yīng)自己的server.x的x值。比如zoo1這臺sever，myid文件中內(nèi)容為1.
4、啟動每個zookeeper
5、查看本機狀態(tài)，是leader還是follower
? zookeeper-3.4.12 bin/zkServer.sh status
至此我們已經(jīng)把zookeeper集群啟動起來了，并且做了驗證，有一臺是leader，另外兩臺是follower。
我們還可以做個實驗，看zookeeper集群是否工作正常。
1、連接其中一臺server，創(chuàng)建一個znode。
? zookeeper-3.4.12 bin/zkCli.sh -server ip1:2181 [zk: ip1:2181(CONNECTED) 10] create /zk_test my_data
2、連接另外一臺server，列出所有根節(jié)點下znode。
? zookeeper-3.4.12 bin/zkCli.sh -server ip2:2181 [zk: ip2:2181(CONNECTED) 10] ls /
輸出如下：
[zk_test]
可以看到集群已經(jīng)能夠正常工作，server間可以正常進行數(shù)據(jù)的復(fù)制。
客戶端連接集群方法如下：
? zookeeper-3.4.12 bin/zkCli -server ip1:2181,ip2:2181,ip3:2181
客戶端會自動隨機選擇集中一臺連接。
小結(jié)：
至此，ZooKeeper單機環(huán)境和集群環(huán)境的搭建講解完成，更多關(guān)于ZooKeeper單機集群環(huán)境的安裝搭建使用的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
下面小編就為大家?guī)硪黄猨ava在文件尾部追加內(nèi)容的簡單實例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-12-12
這篇文章主要為大家詳細介紹了java實現(xiàn)上傳和下載工具類,文件上傳到ftp服務(wù)工具類，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
這篇文章主要介紹了mybatisplus中的xml對象參數(shù)傳遞問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-11-11
這篇文章主要介紹了Java中&和&&的區(qū)別，＆＆邏輯與｜｜邏輯或 它們都是邏輯運算符，＆ 按位與｜按位或它們都是位運算符，更多詳細內(nèi)容請需要的小伙伴了解下面文章內(nèi)容2022-01-01
springboot如何接收get和post請求參數(shù)
這篇文章主要介紹了springboot如何接收get和post請求參數(shù),本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-06-06
這篇文章主要介紹了Springboot整合log4j2日志全解總結(jié)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-12-12
java多次嵌套循環(huán)查詢數(shù)據(jù)庫導(dǎo)致代碼中數(shù)據(jù)處理慢的解決
這篇文章主要介紹了java多次嵌套循環(huán)查詢數(shù)據(jù)庫導(dǎo)致代碼中數(shù)據(jù)處理慢的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-03-03
這篇文章主要給大家介紹了關(guān)于java中join方法的理解與說明的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-01-01
Android官方對協(xié)程的定義-協(xié)程是一種并發(fā)設(shè)計模式，您可以在Android平臺上使用它來簡化異步執(zhí)行的代碼。協(xié)程是在版本1.3中添加到Kotlin的，它基于來自其他語言的既定概念2022-11-11
springboot整合RabbitMQ發(fā)送短信的實現(xiàn)
本文會和SpringBoot做整合，實現(xiàn)RabbitMQ發(fā)送短信，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05