Zookeeper入門(mén)看這篇就夠了
簡(jiǎn)介
Zookeeper 是一個(gè)分布式應(yīng)用程序的分布式開(kāi)源協(xié)調(diào)服務(wù)。是Apache Hadoop 的一個(gè)子項(xiàng)目，主要用來(lái)解決分布式應(yīng)用中經(jīng)常遇到的一些數(shù)據(jù)管理問(wèn)題，例如：統(tǒng)一命名服務(wù)、狀態(tài)同步服務(wù)、集群管理、分布式應(yīng)用配置項(xiàng)的管理等。
Zookeeper 工作原理
ZooKeeper 核心是原子廣播，該機(jī)制保證了各個(gè)Server之間的同步，實(shí)現(xiàn)這個(gè)機(jī)制的協(xié)議叫做 Zab協(xié)議 ，Zab協(xié)議有兩個(gè)模式，他們分別是 “恢復(fù)模式 & 廣播模式”。
恢復(fù)模式
Zab協(xié)議會(huì)讓ZK集群進(jìn)入崩潰恢復(fù)模式的情況如下：
(1)當(dāng)服務(wù)框架在啟動(dòng)過(guò)程中(2)當(dāng)Leader服務(wù)器出現(xiàn)網(wǎng)絡(luò)中斷，崩潰退出與重啟等異常情況。(3)當(dāng)集群中已經(jīng)不存在過(guò)半的服務(wù)器與Leader服務(wù)器保持正常通信。
在所有的follower服務(wù)器中選舉一臺(tái)為L(zhǎng)eader，當(dāng)leader被選舉出來(lái)，集群中有多數(shù)服務(wù)與新的Leader完成狀態(tài)同步之后就會(huì)退出恢復(fù)模式，用來(lái)保證至少有一半的follower能和Leader保持?jǐn)?shù)據(jù)一致，當(dāng)多數(shù)的follower集群與leader數(shù)據(jù)保持一致的時(shí)候，就會(huì)進(jìn)入消息廣播模式。
狀態(tài)同步保證了 Leader 和 Server具有相同的系統(tǒng)狀態(tài)，所謂的狀態(tài)同步其實(shí)就是數(shù)據(jù)的同步。
一旦leader 已經(jīng)和多數(shù)的follower進(jìn)行狀態(tài)同步之后，它就開(kāi)始廣播消息，并且進(jìn)入廣播模式，這時(shí)候當(dāng)一個(gè)server加入Zookeeper 服務(wù)中，它會(huì)在恢復(fù)模式下啟動(dòng)，發(fā)現(xiàn)leader，并和leader進(jìn)行狀態(tài)同步，同步結(jié)束后，它也參與消息廣播，Zookeeper服務(wù)一直維持在 Broadcast狀態(tài)，直到leader崩潰了或者leader失去了大部分的followers支持。
廣播模式
消息廣播模式，Zab協(xié)議消息廣播過(guò)程使用的是原子廣播協(xié)議，類(lèi)似于一個(gè)二階段提交，但是又有點(diǎn)不一樣，并不是所有的follower節(jié)點(diǎn)都需要返回ack才進(jìn)行一致性事務(wù)完成，只需要多數(shù)以上即可。
針對(duì)每個(gè)客戶(hù)端的事務(wù)請(qǐng)求，leader服務(wù)器會(huì)為其生成對(duì)應(yīng)的事務(wù)Proposal，并將其發(fā)送給集群中其余所有的機(jī)器，然后再分別收集各自的選票，最后進(jìn)行事務(wù)提交。
- leader 接收到消息請(qǐng)求后，將消息賦予一個(gè)全局唯一的 64 位自增的 Id，我們通常稱(chēng)之為zxid，通過(guò) zxid 的大小比較即可實(shí)現(xiàn)有序的特性。
- leader 通過(guò) 隊(duì)列 保證發(fā)送的順序性，將帶有zxid的消息作為一個(gè)提案(proposal)分發(fā)給所有follower
- 當(dāng)follower 接收到proposal，先將proposal寫(xiě)到本地事務(wù)日志，寫(xiě)事務(wù)成功后再向Leader 回一個(gè)ACK確認(rèn)
- 當(dāng)leader 接收到多數(shù)的ack確認(rèn)后，leader 會(huì)向所有follower 發(fā)送 commit 命令，同意會(huì)在本地執(zhí)行該消息。
- 當(dāng)follower 收到消息 commit 命令后，就會(huì)執(zhí)行該消息。
消息廣播模式流程示意圖如下：
首先客戶(hù)端會(huì)輪詢(xún)Zookeeper集群中的各個(gè)節(jié)點(diǎn)，當(dāng)輪詢(xún)到一臺(tái)是follower，如果是讀的請(qǐng)求，follower會(huì)返回請(qǐng)求結(jié)果，如果是增刪改操作，follower 會(huì)向leader生成事務(wù)請(qǐng)求，針對(duì)客戶(hù)端的事務(wù)請(qǐng)求，針對(duì)客戶(hù)端的事務(wù)請(qǐng)求，leader會(huì)為這個(gè)生成對(duì)應(yīng)的事務(wù)Proposal，然后發(fā)送集群中所有follower服務(wù)器，然后分別在收集各自的選票，最后進(jìn)行事務(wù)提交。
Zab協(xié)議的二階段提交，在提交過(guò)程中移除了中斷提交過(guò)程的操作，對(duì)于Zookeeper集群來(lái)說(shuō)，超過(guò)半數(shù)反饋Ack確認(rèn)就代表事務(wù)成功，這種方式無(wú)法完成所有節(jié)點(diǎn)事務(wù)一致性問(wèn)題，所以Zab協(xié)議采用恢復(fù)模式來(lái)解決數(shù)據(jù)不一致的問(wèn)題。
消息廣播協(xié)議是基于具有FIFO特性的TCP協(xié)議進(jìn)行通訊，因此可以保證消息廣播過(guò)程中的接收和發(fā)送的順序性。
事務(wù)ID
為了保證事務(wù)的順序一致性，Zookeeper 采用了遞增的事務(wù)ID號(hào)(zxid)來(lái)標(biāo)識(shí)事務(wù)，所有的操作(proposal)都會(huì)在被提出時(shí)加上zxid，zxid是一個(gè)64位的數(shù)字，他高32位是epoch用來(lái)標(biāo)識(shí)leader關(guān)系是否發(fā)生變化，每當(dāng)有新的leader 被選舉出來(lái)，都會(huì)有一個(gè)新的epoch，標(biāo)識(shí)當(dāng)前屬于哪個(gè)leader的領(lǐng)導(dǎo)。
對(duì)于Zookeeper 來(lái)說(shuō)，每次的變化都會(huì)產(chǎn)生一個(gè)唯一的事務(wù)id，zxid(ZooKeeper Transaction Id)通過(guò)zxid ，可以確定更新操作的先后順序，如果說(shuō) zxid1 小于 zxid2，說(shuō)明 zxid1比zxid先發(fā)生。
Zookeeper 模型
Zookeeper 是一個(gè)目錄樹(shù)結(jié)構(gòu)，名稱(chēng)是由斜杠 (/) 分隔的一系列路徑元素。ZooKeeper 命名空間中的每個(gè)節(jié)點(diǎn)都由路徑標(biāo)識(shí)。
ZooKeeper 層級(jí)樹(shù)狀結(jié)構(gòu)
根節(jié)點(diǎn) / 包含兩個(gè)節(jié)點(diǎn)(/modele1 & /module2)，其中節(jié)點(diǎn) /module1 包含三個(gè)子節(jié)點(diǎn)(/module1/app1 & /module1/app2 & /module1/app3)，在Zookeeper 中，節(jié)點(diǎn)以絕對(duì)路徑表示，不存在相對(duì)路徑，出了根節(jié)點(diǎn)以外，其他節(jié)點(diǎn)不能以 / 結(jié)尾。
特性
資源共享： 例如存儲(chǔ)空間，計(jì)算能力，數(shù)據(jù)，和服務(wù)等等
擴(kuò)展性： 從軟件和硬件上增加系統(tǒng)的規(guī)模
并發(fā)性： 多個(gè)用戶(hù)同時(shí)訪(fǎng)問(wèn)
性能： 確保當(dāng)負(fù)載增加的時(shí)候，系統(tǒng)想要時(shí)間不會(huì)有影響
容錯(cuò)性： 盡管一些組件暫時(shí)不可用了，整個(gè)系統(tǒng)仍然是可用的
API抽象： 系統(tǒng)的獨(dú)立組件對(duì)用戶(hù)隱藏，僅僅暴露服務(wù)
Zookeeper的角色
領(lǐng)導(dǎo)者(leader) ：負(fù)責(zé)進(jìn)行投票的發(fā)起和決議，更新系統(tǒng)狀態(tài)
學(xué)習(xí)者(learner) ：包括跟隨者(follower)和觀(guān)察者(observer)，follower用于接受客戶(hù)端請(qǐng)求并想客戶(hù)端返回結(jié)果，在選主過(guò)程中參與投票
Observer ：可以接受客戶(hù)端連接，將寫(xiě)請(qǐng)求轉(zhuǎn)發(fā)給leader，但observer不參加投票過(guò)程，只同步leader的狀態(tài)，observer的目的是為了擴(kuò)展系統(tǒng)，提高讀取速度
客戶(hù)端(client) ：請(qǐng)求發(fā)起方
保證
順序一致性： 客戶(hù)端的更新將按發(fā)送順序應(yīng)用。
原子性： 更新成功或失敗，沒(méi)有部分結(jié)果。
統(tǒng)一視圖： 無(wú)論服務(wù)器連接到哪個(gè)服務(wù)器，客戶(hù)端都將看到相同的服務(wù)視圖。即，即使客戶(hù)端故障轉(zhuǎn)移到具有相同會(huì)話(huà)的不同服務(wù)器，客戶(hù)端也永遠(yuǎn)不會(huì)看到系統(tǒng)的舊視圖。
可靠性： 一旦應(yīng)用更新了，它將從那時(shí)起一直存在，直到客戶(hù)端覆蓋更新。
及時(shí)性： 系統(tǒng)的客戶(hù)視圖保證在特定時(shí)間范圍內(nèi)是最新的。
Znode 節(jié)點(diǎn)
Znode有兩種類(lèi)型：持久節(jié)點(diǎn)和臨時(shí)節(jié)點(diǎn) ，Znode的類(lèi)型在創(chuàng)建的之后就不能在進(jìn)行修改了。
臨時(shí)節(jié)點(diǎn)
- 臨時(shí)節(jié)點(diǎn)在客戶(hù)端會(huì)話(huà)結(jié)束的時(shí)候，Zookeeper 會(huì)將臨時(shí)節(jié)點(diǎn)(znode)刪除，并且臨時(shí)節(jié)點(diǎn)不能有子節(jié)點(diǎn)。利用臨時(shí)節(jié)點(diǎn)的特性，我們可以使用臨時(shí)節(jié)點(diǎn)來(lái)進(jìn)行集群管理以及發(fā)現(xiàn)服務(wù)的上下線(xiàn)等。
創(chuàng)建臨時(shí)節(jié)點(diǎn)命令：create-e/module1/app1 app1創(chuàng)建一個(gè)臨時(shí)節(jié)點(diǎn)為 “/module1/app1” ，數(shù)據(jù)為 “app1”
持久節(jié)點(diǎn)
- 持久節(jié)點(diǎn)不依賴(lài)于客戶(hù)端會(huì)話(huà)，只有當(dāng)客戶(hù)端明確要?jiǎng)h除持久節(jié)點(diǎn)(znode)的時(shí)候才會(huì)被刪除
創(chuàng)建臨時(shí)節(jié)點(diǎn)命令：create/module1 module1創(chuàng)建一個(gè)臨時(shí)節(jié)點(diǎn)為 “/module1” ，數(shù)據(jù)為 “module1”
順序節(jié)點(diǎn)
- ZooKeeper 中還提供了一種順序節(jié)點(diǎn)的類(lèi)型，每次創(chuàng)建順序節(jié)點(diǎn)時(shí)候，ZooKeeper 都會(huì)在路徑后面自動(dòng)添加10為的數(shù)據(jù)中，例如0000000001 計(jì)數(shù)器會(huì)保證在同一父節(jié)點(diǎn)下唯一，創(chuàng)建節(jié)點(diǎn)的時(shí)候會(huì)添加順序，常見(jiàn)分布式鎖。
順序節(jié)點(diǎn)只是節(jié)點(diǎn)的一種特性，也就說(shuō)不管是 持久節(jié)點(diǎn)還是 臨時(shí)節(jié)點(diǎn) 都可以設(shè)置為順序節(jié)點(diǎn)，所以Znode類(lèi)型可以理解為 4種類(lèi)型：
- 持久節(jié)點(diǎn)
- 臨時(shí)節(jié)點(diǎn)
- 持久順序節(jié)點(diǎn)
- 臨時(shí)順序節(jié)點(diǎn)
創(chuàng)建順序節(jié)點(diǎn)命令(加上 “-s”參數(shù))：create-s/module1/app app我們會(huì)看到 Created/module1/app0000000001意思是我們創(chuàng)建了一個(gè)持久順序節(jié)點(diǎn)“/module1/app0000000001” 如果再執(zhí)行上面命令 會(huì)生成節(jié)點(diǎn) “/module1/app0000000002”，同理 如果我們 create-s后面添加 -e 參數(shù)，就表示我們創(chuàng)建了一個(gè)臨時(shí)節(jié)點(diǎn)。
節(jié)點(diǎn)數(shù)據(jù)
- 創(chuàng)建節(jié)點(diǎn)的時(shí)候，我們可以指定節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)，ZooKeeper可以保證讀寫(xiě)都是原子操作，而且每次讀寫(xiě)操作都是對(duì)數(shù)據(jù)的完整讀取或者完成寫(xiě)入，不提供對(duì)數(shù)據(jù)的部分讀取或者寫(xiě)入操作。
- ZooKeeper 雖然提供了節(jié)點(diǎn)存儲(chǔ)數(shù)據(jù)的功能，但是我們并不能把它當(dāng)成一個(gè)數(shù)據(jù)庫(kù)，重點(diǎn)不要把Zookeeper 當(dāng)成數(shù)據(jù)庫(kù)用，因?yàn)閆ookeeper 規(guī)定了節(jié)點(diǎn)的數(shù)據(jù)大小不能超過(guò)1M，所以我們不能在節(jié)點(diǎn)上存儲(chǔ)過(guò)多的數(shù)據(jù)，盡可能保證小的數(shù)據(jù)量，因?yàn)閿?shù)據(jù)過(guò)大，會(huì)導(dǎo)致ZK的性能下降。
- 如果確實(shí)需要存儲(chǔ)大量的數(shù)據(jù)，一般可以在分布式數(shù)據(jù)庫(kù)或者Redis保存這部分?jǐn)?shù)據(jù)，然后在Znode中保留數(shù)據(jù)庫(kù)中的索引。
Zookeeper單機(jī)模式安裝
java 環(huán)境
配置JAVA環(huán)境，檢驗(yàn)環(huán)境 java-version
下載安裝Zookeeper
下載地址：https://zookeeper.apache.org/releases.html
下載解壓Zookeeper
- cd /usr/local/
- wget https://dlcdn.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
- tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz
- cd zookeeper-3.7.0/
重命名配置文件 zoo_sample.cfg
- cp conf
- /
- zoo_sample
- .
- cfg conf
- /
- zoo
- .
- cfg
啟動(dòng)ZK
- ./
- bin
- /
- zkServer
- .
- sh start
連接ZK客戶(hù)端
- ./
- bin
- /
- zkCli
- .
- sh
當(dāng)我們看到下圖的信息的時(shí)候，表示我們啟動(dòng)成功
Zookeeper命令
基本命令
- create : 在樹(shù)中的某個(gè)位置創(chuàng)建一個(gè)節(jié)點(diǎn)
- delete : 刪除一個(gè)節(jié)點(diǎn)存在：測(cè)試節(jié)點(diǎn)是否存在于某個(gè)位置
- get data : 從節(jié)點(diǎn)讀取數(shù)據(jù)
- set data： 將數(shù)據(jù)寫(xiě)入節(jié)點(diǎn)
- get children : 檢索節(jié)點(diǎn)的子節(jié)點(diǎn)列表
- sync : 等待數(shù)據(jù)被傳播
操作Zookeeper
查看Zookeeper中包含的key
- ls
- /
創(chuàng)建一個(gè)新的Znode 創(chuàng)建成功以后我們可以使用 ls/查看我們創(chuàng)建的內(nèi)容
- create /zkMxn muxiaonong ls /[zkMxn, zookeeper]
get命令獲取創(chuàng)建Znode的內(nèi)容
- get /zkMxn
set 命令來(lái)對(duì) zk 所關(guān)聯(lián)的字符串進(jìn)行設(shè)置
- set /zkMxn mxn666
刪除Znode
- delete /zkMxn
Java Api操作 ZK
1. 導(dǎo)入Jar包
- <dependency>
- <groupId>org.apache.zookeeper</groupId>
- <artifactId>zookeeper</artifactId>
- <version>3.6.3</version>
- </dependency>
- <!--junit單元測(cè)試-->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <version>4.13.2</version>
- <scope>runtime</scope>
- </dependency>
2. API操作Zookeeper
創(chuàng)建Zookeeper對(duì)象
- public ZooKeeper(String connectString, int sessionTimeout, Watcher watcher) throws IOException {
- this(connectString, sessionTimeout, watcher, false);
- }
connectString： 連接的地址，包括主機(jī)名和端口號(hào)，多個(gè)的話(huà)用逗號(hào)隔開(kāi)
sessionTimeout： 等待客戶(hù)端通信的最長(zhǎng)時(shí)間，客戶(hù)端如果超過(guò)這個(gè)時(shí)間沒(méi)有和服務(wù)端進(jìn)行通信，那么就認(rèn)為該客戶(hù)端已經(jīng)終止，一般設(shè)置值為 5-10秒，單位為毫秒
watcher： 監(jiān)聽(tīng)器，用于接收會(huì)話(huà)事件的接口，需要自己定義，實(shí)現(xiàn)process()方法
連接Zookeeper
- Zookeeper zkClient = "";
- String connectStr = "192.168.2.1:2181";
- zkClient = new ZooKeeper(connectStr, 5000, new Watcher() {
- @Override
- public void process(WatchedEvent watchedEvent) { }
- });
創(chuàng)建節(jié)點(diǎn)
- public ZooKeeper(String connectString, int sessionTimeout, Watcher watcher) throws IOException {
- this(connectString, sessionTimeout, watcher, false);
- }
- path： 節(jié)點(diǎn)路徑
- data： 節(jié)點(diǎn)數(shù)據(jù)
- acl： 節(jié)點(diǎn)權(quán)限，例如： ZooDefs.Ids.OPEN_ACL_UNSAFE
OPENACLUNSAFE：完全開(kāi)發(fā)，采用world驗(yàn)證模式，由于每個(gè)ZK連接都有world驗(yàn)證模式，所以當(dāng)我們節(jié)點(diǎn)設(shè)置了該參數(shù)時(shí)，對(duì)所有連接開(kāi)放 CREATORALLACL：創(chuàng)建該Znode連接的擁有所有權(quán)限，這里采用的是auth驗(yàn)證模式，用sessionID做驗(yàn)證，如果設(shè)置了該參數(shù)，只有創(chuàng)建改Znode節(jié)點(diǎn)的連接才能對(duì)這個(gè)Znode進(jìn)行任何操作 READACLUNSAFE：所有的客戶(hù)端都可讀，這里采用world驗(yàn)證模式，和第一條同理，所有連接都可以讀取該znode
createMode： 節(jié)點(diǎn)類(lèi)型，例如： CreateMode.PERSISTENT PERSISTENT：持久節(jié)點(diǎn) PERSISTENTSEQUENTIAL：持久有序節(jié)點(diǎn) EPHEMERAL：短暫節(jié)點(diǎn) EPHEMERALSEQUENTIAL：短暫有序節(jié)點(diǎn)
完整APIDemo：
- import lombok.extern.slf4j.Slf4j;
- import org.apache.zookeeper.*;
- import org.apache.zookeeper.data.Stat;
- import java.io.IOException;
- import java.io.UnsupportedEncodingException;
- import java.util.concurrent.CountDownLatch;
- /** @Author mxn
- * @Description //TODO ZooKeeper Java API測(cè)試
- * @Date 10:22 2021/9/29
- * @Param
- * @return
- **/
- @Slf4j
- public class ZookeeperTest {
- // IP 和端口
- private final static String ipAddress = "192.168.2.123:2181";
- public static void main(String[] args) {
- ZookeeperTest test = new ZookeeperTest();
- String key = "/zkMxn";
- String value = "wo is muxiaonong";
- //創(chuàng)建Znode
- test.add(key,value);
- // 獲取節(jié)點(diǎn)數(shù)據(jù)
- // test.get(key);
- //修改節(jié)點(diǎn)數(shù)據(jù)
- // test.modify(key,"wo is zhuzhuxia");
- //刪除節(jié)點(diǎn)
- // test.delete(key);
- }
- /**
- * @return
- * @Author mxn
- * @Description //TODO 獲取ZooKeeper連接
- * @Date 10:22 2021/9/29
- * @Param
- **/
- public static ZooKeeper getConntection() {
- ZooKeeper zooKeeper = null;
- try {
- final CountDownLatch countDownLatch = new CountDownLatch(1);
- //watch機(jī)制(回調(diào))，監(jiān)聽(tīng)是否連接成功
- zooKeeper = new ZooKeeper(ipAddress, 5000, new Watcher() {
- @Override
- public void process(WatchedEvent watchedEvent) {
- if (Event.KeeperState.SyncConnected == watchedEvent.getState()) {
- //如果受收到了服務(wù)端的響應(yīng)事件，連接成功
- countDownLatch.countDown();
- }
- }
- });
- countDownLatch.await();
- log.info("zookeeper狀態(tài)：{}",zooKeeper.getState());//CONNECTED
- } catch (IOException e) {
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- return zooKeeper;
- }
- /** @Author lyy
- * @Description //TODO 關(guān)閉ZooKeeper連接
- * @Date 14:57 2021/9/29
- * @Param
- * @return
- **/
- public static void closeConnection(ZooKeeper zooKeeper) {
- try {
- // zooKeeper.close();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- /** @Author lyy
- * @Description //TODO 添加節(jié)點(diǎn)
- * @Date 13:36 2021/9/29
- * @Param
- * @return
- **/
- public void add(String key ,String value) {
- ZooKeeper zooKeeper = ZookeeperTest.getConntection();
- try {
- //參數(shù)類(lèi)型
- //1.key
- //2.value
- //3.對(duì)應(yīng)的ACL,當(dāng)前節(jié)點(diǎn)的權(quán)限控制
- //4.設(shè)置當(dāng)前節(jié)點(diǎn)類(lèi)型
- zooKeeper.create(key, value.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
- ZookeeperTest.closeConnection(zooKeeper);
- } catch (KeeperException e) {
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- /** @Author lyy
- * @Description //TODO 獲取節(jié)點(diǎn)信息
- * @Date 14:57 2021/9/29
- * @Param
- * @return
- **/
- public void get(String key) {
- ZooKeeper zooKeeper = ZookeeperTest.getConntection();
- Stat stat = new Stat();
- String data = null;
- try {
- byte[] bytes = zooKeeper.getData(key, null, stat);
- data = new String(bytes, "gbk");
- log.info("當(dāng)前節(jié)點(diǎn)信息:{}",data);
- ZookeeperTest.closeConnection(zooKeeper);
- } catch (KeeperException e) {
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
- }
- /** @Author lyy
- * @Description //TODO 修改節(jié)點(diǎn)信息
- * @Date 14:57 2021/9/29
- * @Param
- * @return
- **/
- public void modify(String key,String newValue) {
- ZooKeeper zooKeeper = ZookeeperTest.getConntection();
- Stat stat = new Stat();
- //version樂(lè)觀(guān)鎖概念,此處需要獲取version信息，則需要先get拿到節(jié)點(diǎn)信息
- try {
- //獲取節(jié)點(diǎn)(修改需要version信息)
- zooKeeper.getData(key, null, stat);
- //再修改
- zooKeeper.setData(key, newValue.getBytes(), stat.getVersion());
- ZookeeperTest.closeConnection(zooKeeper);
- } catch (KeeperException e) {
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- /** @Author lyy
- * @Description //TODO 刪除節(jié)點(diǎn)
- * @Date 14:57 2021/9/29
- * @Param
- * @return
- **/
- public void delete(String key) {
- ZooKeeper zooKeeper = ZookeeperTest.getConntection();
- Stat stat = new Stat();
- try {
- //獲取節(jié)點(diǎn)(刪除需要version信息)
- zooKeeper.getData(key, null, stat);
- //刪除節(jié)點(diǎn)
- zooKeeper.delete(key, stat.getVersion());
- ZookeeperTest.closeConnection(zooKeeper);
- } catch (KeeperException e) {
- e.printStackTrace();
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
總結(jié)
到這里我們對(duì)Zookeeper 大概有個(gè)入門(mén)級(jí)的了解了，不過(guò)Zookeeper遠(yuǎn)遠(yuǎn)比我們這里講述的功能多，如何用Zookeeper實(shí)現(xiàn)集群管理、分布式鎖，隊(duì)列等等，小農(nóng)會(huì)在后面的文章中進(jìn)行講解，關(guān)注我，后續(xù)精彩內(nèi)容第一時(shí)間推送。
