ZooKeeper 是一個典型的分布式數(shù)據(jù)一致性解決方案，分布式應用程序可以基于 ZooKeeper 實現(xiàn)諸如數(shù)據(jù)發(fā)布/訂閱、負載均衡、命名服務、分布式協(xié)調/通知、集群管理、Master 選舉、分布式鎖和分布式隊列等功能。

Zookeeper 一個最常用的使用場景就是用于擔任服務生產(chǎn)者和服務消費者的注冊中心。 服務生產(chǎn)者將自己提供的服務注冊到Zookeeper中心，服務的消費者在進行服務調用的時候先到Zookeeper中查找服務，獲取到服務生產(chǎn)者的詳細信息之后，再去調用服務生產(chǎn)者的內容與數(shù)據(jù)。如下圖所示，在 Dubbo架構中 Zookeeper 就擔任了注冊中心這一角色。

maven依賴

<dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.0</version></dependency>

程序其它依賴：

<!-- Logger（log4j2） --><dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.11.2</version></dependency><!-- Log4j 1.x API Bridge --><dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-1.2-api</artifactId> <version>2.11.2</version></dependency><!-- SLF4J Bridge --><dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-slf4j-impl</artifactId> <version>2.11.2</version></dependency><dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.6.0</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions></dependency>

API操作代碼：

package com.zhi.test;import java.util.List;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.apache.zookeeper.CreateMode;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.Watcher;import org.apache.zookeeper.ZooDefs.Ids;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.data.Stat;import org.junit.jupiter.api.AfterAll;import org.junit.jupiter.api.BeforeAll;import org.junit.jupiter.api.MethodOrderer;import org.junit.jupiter.api.Order;import org.junit.jupiter.api.Test;import org.junit.jupiter.api.TestInstance;import org.junit.jupiter.api.TestInstance.Lifecycle;import org.junit.jupiter.api.TestMethodOrder;/** * Zookeeper操作測試 * * @author 張遠志 * @since 2020年5月3日14:31:28 * */@TestInstance(Lifecycle.PER_CLASS)@TestMethodOrder(MethodOrderer.OrderAnnotation.class)public class ZookeeperTest { private final Logger logger = LogManager.getLogger(this.getClass()); private ZooKeeper zooKeeper; private final String path = '/test'; @BeforeAll public void init() throws Exception { zooKeeper = new ZooKeeper('192.168.59.131:2181', 60000, new Watcher() { public void process(WatchedEvent event) {logger.info('事件類型：{}，路徑：{}', event.getType(), event.getPath()); } }); } /** * 添加數(shù)據(jù)，當路徑已經(jīng)存在時會報錯，初始版本號為0。第三個參數(shù)是權限控制。 <br> * 第四個參數(shù)，CreateMode： * <li>PERSISTENT：持久化保存 * <li>PERSISTENT_SEQUENTIAL：持久化保存，并且路徑附加一個自動增長的序號 * <li>EPHEMERAL：臨時數(shù)據(jù)，客戶端斷開連接時自動刪除數(shù)據(jù)（dubbo就是采用這種機制） * <li>EPHEMERAL_SEQUENTIAL：客戶端斷開連接時自動刪除數(shù)據(jù)，并且路徑會附加一個自動增長的序號 * <li>CONTAINER： * <li>PERSISTENT_WITH_TTL：客戶端斷開連接時自動刪除數(shù)據(jù)，當節(jié)點在指定時間沒有被修改且沒有子目錄時，數(shù)據(jù)會被刪除 * <li>PERSISTENT_SEQUENTIAL_WITH_TTL：客戶端斷開連接時自動刪除數(shù)據(jù)，路徑會附加一個自動增長的序號，且當節(jié)點在指定時間沒有被修改且沒有子目錄時，數(shù)據(jù)會被刪除 */ @Order(1) @Test public void create() { try { String back = zooKeeper.create(path, '這是一個測試'.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); logger.info('添加一條數(shù)據(jù)成功，實際路徑：{}', back); } catch (Exception e) { logger.error('調用create出錯', e); } } /** * 判斷路徑是否存在，不存在時返回null */ @Order(2) @Test public void exists() { try { Stat stat = zooKeeper.exists(path, false); logger.info('路徑為{}的節(jié)點{}存在', path, stat == null ? '不' : ''); } catch (Exception e) { logger.error('調用exists出錯', e); } } /** * 查詢數(shù)據(jù)，路徑不存在時會報錯 */ @Order(3) @Test public void find() { try { byte[] bits = zooKeeper.getData(path, false, new Stat()); // 路徑不存在時會報錯 String data = new String(bits); logger.info('路徑{}查詢到數(shù)據(jù)：{}', path, data); } catch (Exception e) { logger.error('調用getData出錯', e); } } /** * 獲取子目錄，結果為空時返回一個長度為0的ArrayList */ @Order(3) @Test public void children() { try { List<String> list = zooKeeper.getChildren(path, false); logger.info('路徑{}的子目錄有：{}', path, String.join('、', list.toArray(new String[0]))); } catch (Exception e) { logger.error('調用getChildren出錯', e); } } /** * 修改數(shù)據(jù)，路徑不存在時會報錯，版本號與存儲中不一致時也報錯 */ @Order(4) @Test public void udpate() { try { Stat stat = zooKeeper.exists(path, false); if (stat != null) {stat = zooKeeper.setData(path, '這是一個修改測試'.getBytes(), stat.getVersion()); // 版本號為-1時不做版本校驗logger.info('數(shù)據(jù)修改成功，原版本號：{}，新版本號：{}', stat.getAversion(), stat.getVersion()); } } catch (Exception e) { logger.error('調用setData出錯', e); } } /** * 刪除節(jié)點，路徑不存在時報錯，版本號不一致時也會報錯 */ @Order(5) @Test public void delete() { try { zooKeeper.delete(path, -1); // -1表示不做版本校驗 logger.info('根據(jù)path刪除數(shù)據(jù)成功'); } catch (Exception e) { logger.error('調用delete出錯', e); } } @AfterAll public void destory() throws Exception { if (zooKeeper != null) { zooKeeper.close(); } }}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網(wǎng)。