欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java使用Curator進(jìn)行ZooKeeper操作的詳細(xì)教程

 更新時(shí)間:2025年04月01日 15:25:31   作者:拾荒的小海螺  
Apache Curator 是一個(gè)基于 ZooKeeper 的 Java 客戶端庫,它極大地簡化了使用 ZooKeeper 的開發(fā)工作,在分布式系統(tǒng)中,ZooKeeper 通常被用來作為協(xié)調(diào)服務(wù),而 Curator 則為我們提供了更簡潔易用的接口,本文將介紹 Curator 的核心功能及實(shí)踐樣例,需要的朋友可以參考下

1、簡述

Apache Curator 是一個(gè)基于 ZooKeeper 的 Java 客戶端庫,它極大地簡化了使用 ZooKeeper 的開發(fā)工作。Curator 提供了高層次的 API,封裝了很多復(fù)雜的 ZooKeeper 操作,例如連接管理、分布式鎖、Leader 選舉等。

在分布式系統(tǒng)中,ZooKeeper 通常被用來作為協(xié)調(diào)服務(wù),而 Curator 則為我們提供了更簡潔易用的接口,減少了開發(fā)的復(fù)雜性。本文將介紹 Curator 的核心功能及實(shí)踐樣例。

2、核心功能

Apache Curator是一個(gè)比較完善的ZooKeeper客戶端框架,通過封裝的一套高級API 簡化了ZooKeeper的操作。Curator主要解決了三類問題:

  • 封裝ZooKeeper client與ZooKeeper server之間的連接處理
  • 提供了一套Fluent風(fēng)格的操作API
  • 提供ZooKeeper各種應(yīng)用場景(recipe, 比如:分布式鎖服務(wù)、集群領(lǐng)導(dǎo)選舉、共享計(jì)數(shù)器、緩存機(jī)制、分布式隊(duì)列等)的抽象封裝

Curator 提供了以下核心組件:

2.1 CuratorFramework

CuratorFramework 是 Curator 的核心類,用于與 ZooKeeper 服務(wù)交互。

2.2 Recipes

Curator 提供了多種常見分布式模式的實(shí)現(xiàn),包括:

  • 分布式鎖 (InterProcessMutex)
  • 分布式隊(duì)列 (DistributedQueue)
  • Leader 選舉 (LeaderSelector)
  • 節(jié)點(diǎn)緩存 (NodeCache)
  • 路徑緩存 (PathChildrenCache)
  • 樹緩存 (TreeCache)

3、示例實(shí)踐

Curator中提供了Zookeeper各種應(yīng)用場景(Recipe,如共享鎖服務(wù)、Master選舉機(jī)制和分布式計(jì)算器等)的抽象封裝。

3.1 依賴引入

在使用 Curator 前,需要在項(xiàng)目中引入相關(guān)的依賴:

<!-- zookeeper支持 -->
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.6.4</version>
</dependency>
<!-- curator-recipes -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>5.5.0</version>
</dependency>
<!-- curator-framework -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>5.5.0</version>
</dependency>

3.2 初始化 CuratorFramework

以下代碼展示了如何初始化 CuratorFramework:

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class CuratorExample {
    public static void main(String[] args) {
        // 創(chuàng)建 CuratorFramework 實(shí)例
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181") // ZooKeeper 地址
                .sessionTimeoutMs(5000)
                .connectionTimeoutMs(3000)
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();

        // 啟動客戶端
        client.start();

        System.out.println("CuratorFramework 已啟動");

        // 關(guān)閉客戶端
        client.close();
    }
}

3.3 分布式鎖

分布式鎖是分布式系統(tǒng)中的一個(gè)重要功能,用于協(xié)調(diào)多進(jìn)程/線程間的訪問。

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;

import java.util.concurrent.TimeUnit;

public class DistributedLockExample {
    public static void main(String[] args) throws Exception {
        // 初始化 CuratorFramework
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建分布式鎖
        InterProcessMutex lock = new InterProcessMutex(client, "/distributed-lock");

        // 嘗試獲取鎖
        if (lock.acquire(10, TimeUnit.SECONDS)) {
            try {
                System.out.println("成功獲取鎖,執(zhí)行任務(wù)...");
                Thread.sleep(5000); // 模擬任務(wù)
            } finally {
                lock.release();
                System.out.println("鎖已釋放");
            }
        } else {
            System.out.println("未能獲取鎖");
        }

        client.close();
    }
}

3.4 Leader 選舉

Curator 的 LeaderSelector 提供了簡單易用的 Leader 選舉功能。

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.framework.recipes.leader.LeaderSelector;
import org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter;

public class LeaderElectionExample {
    public static void main(String[] args) throws InterruptedException {
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建 LeaderSelector
        LeaderSelector leaderSelector = new LeaderSelector(client, "/leader-election", new LeaderSelectorListenerAdapter() {
            @Override
            public void takeLeadership(CuratorFramework client) throws Exception {
                System.out.println("成為 Leader,執(zhí)行任務(wù)...");
                Thread.sleep(3000); // 模擬任務(wù)
                System.out.println("任務(wù)完成,釋放 Leader 權(quán)限");
            }
        });

        leaderSelector.autoRequeue(); // 自動重新排隊(duì)參與選舉
        leaderSelector.start();

        Thread.sleep(Integer.MAX_VALUE); // 保持主線程運(yùn)行
        client.close();
    }
}

3.5 節(jié)點(diǎn)緩存

NodeCache 用于監(jiān)聽特定節(jié)點(diǎn)的數(shù)據(jù)變更。

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class NodeCacheExample {
    public static void main(String[] args) throws Exception {
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建 NodeCache
        NodeCache nodeCache = new NodeCache(client, "/test-node");
        nodeCache.getListenable().addListener(() -> {
            System.out.println("節(jié)點(diǎn)數(shù)據(jù)變更,新的數(shù)據(jù)為:" + new String(nodeCache.getCurrentData().getData()));
        });

        nodeCache.start();

        // 創(chuàng)建節(jié)點(diǎn)并修改數(shù)據(jù)
        client.create().orSetData().forPath("/test-node", "initial-data".getBytes());
        Thread.sleep(1000);
        client.setData().forPath("/test-node", "updated-data".getBytes());

        Thread.sleep(5000); // 保持運(yùn)行觀察結(jié)果
        client.close();
    }
}

4、總結(jié)

Curator 提供了強(qiáng)大的 ZooKeeper 封裝功能,極大地簡化了開發(fā)流程。在分布式系統(tǒng)中,通過 Curator 可以實(shí)現(xiàn)諸如分布式鎖、Leader 選舉和節(jié)點(diǎn)監(jiān)聽等功能,幫助開發(fā)者快速構(gòu)建穩(wěn)定的分布式服務(wù)。

以上就是Java使用Curator進(jìn)行ZooKeeper操作的詳細(xì)教程的詳細(xì)內(nèi)容,更多關(guān)于Java Curator進(jìn)行ZooKeeper操作的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • SpringBoot如何監(jiān)聽redis?Key變化事件案例詳解

    SpringBoot如何監(jiān)聽redis?Key變化事件案例詳解

    項(xiàng)目中需要監(jiān)聽redis的一些事件比如鍵刪除,修改,過期等,下面這篇文章主要給大家介紹了關(guān)于SpringBoot如何監(jiān)聽redis?Key變化事件的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2022-08-08
  • Spring?Boot?使用?Hutool-jwt?實(shí)現(xiàn)?token?驗(yàn)證功能

    Spring?Boot?使用?Hutool-jwt?實(shí)現(xiàn)?token?驗(yàn)證功能

    JWT?就是一種網(wǎng)絡(luò)身份認(rèn)證和信息交換格式,這篇文章主要介紹了Spring Boot使用Hutool-jwt實(shí)現(xiàn)token驗(yàn)證,需要的朋友可以參考下
    2023-07-07
  • 詳解Spring Boot Security工作流程

    詳解Spring Boot Security工作流程

    Spring Security,這是一種基于 Spring AOP 和 Servlet 。這篇文章主要介紹了Spring Boot Security的相關(guān)知識,需要的朋友可以參考下
    2019-04-04
  • java web服務(wù)器實(shí)現(xiàn)跨域訪問

    java web服務(wù)器實(shí)現(xiàn)跨域訪問

    這篇文章主要為大家詳細(xì)介紹了java web服務(wù)器實(shí)現(xiàn)跨域訪問,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-08-08
  • sprintboot使用spring-security包,緩存內(nèi)存與redis共存方式

    sprintboot使用spring-security包,緩存內(nèi)存與redis共存方式

    這篇文章主要介紹了sprintboot使用spring-security包,緩存內(nèi)存與redis共存方式,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • SpringBoot基于Shiro處理ajax請求代碼實(shí)例

    SpringBoot基于Shiro處理ajax請求代碼實(shí)例

    這篇文章主要介紹了SpringBoot基于Shiro處理ajax請求代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-06-06
  • SpringBoot中的Future接口詳解

    SpringBoot中的Future接口詳解

    這篇文章主要介紹了SpringBoot中的Future接口詳解,在異步編程中,我們通常需要處理一些耗時(shí)的操作,一種常見的做法是使用 Future 接口來代表一個(gè)異步操作的結(jié)果,需要的朋友可以參考下
    2023-07-07
  • 詳解JDK9特性之JPMS模塊化

    詳解JDK9特性之JPMS模塊化

    JDK9引入了一個(gè)特性叫做JPMS(Java Platform Module System),也可以叫做Project Jigsaw。模塊化的本質(zhì)就是將一個(gè)大型的項(xiàng)目拆分成為一個(gè)一個(gè)的模塊,每個(gè)模塊都是獨(dú)立的單元,并且不同的模塊之間可以互相引用和調(diào)用。本文將詳細(xì)介紹JDK9特性之JPMS模塊化。
    2021-06-06
  • SpringBoot與Postman實(shí)現(xiàn)REST模擬請求的操作

    SpringBoot與Postman實(shí)現(xiàn)REST模擬請求的操作

    這篇文章主要介紹了SpringBoot與Postman實(shí)現(xiàn)REST模擬請求的操作,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-06-06
  • java 實(shí)現(xiàn)讀取txt文本數(shù)據(jù)并以數(shù)組形式一行一行取值

    java 實(shí)現(xiàn)讀取txt文本數(shù)據(jù)并以數(shù)組形式一行一行取值

    今天小編就為大家分享一篇java 實(shí)現(xiàn)讀取txt文本數(shù)據(jù)并以數(shù)組形式一行一行取值,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-07-07

最新評論