Java代码操作Zookeeper（使用 Apache Curator 库）

news2025/11/1 1:03:33

1. Zookeeper原生客户端库存在的缺点

  • 复杂性高：原生客户端库提供了底层的 API，需要开发者手动处理很多细节，如连接管理、会话管理、异常处理等。这增加了开发的复杂性，容易出错。
  • 连接管理繁琐：使用原生客户端库时，开发者需要手动管理与 ZooKeeper 的连接。这包括连接的建立、重连、会话超时处理等。
  • 异常处理复杂：原生客户端库的 API 抛出多种异常，如 KeeperException、InterruptedException 等。开发者需要手动处理这些异常，增加了代码的复杂性。
  • 缺少高级功能：原生客户端库缺少一些高级功能，如连接池管理、自动重试、负载均衡等。这些功能在实际应用中非常有用，但需要开发者自己实现或使用第三方库。
  • 缺少封装和抽象：原生客户端库提供了底层的 API，缺少更高层次的封装和抽象。开发者需要自己编写大量的代码来实现常见的功能，如分布式锁、配置管理等。
  • 性能调优困难：原生客户端库的性能调优需要开发者手动进行，如调整连接超时时间、会话超时时间等。这需要对 ZooKeeper 的工作原理有深入的理解。
  • 缺少社区支持：相比于一些更高级的客户端库（如 Curator），原生客户端库的社区支持相对较少。开发者在使用过程中遇到问题时，可能难以找到解决方案。

2. Apache Curator介绍

在这里插入图片描述

2.1 基本概述
  • 定义：Apache Curator是专为Apache ZooKeeper设计的Java/JVM客户端库，通过提供高级API框架及一系列实用工具，大幅降低使用ZooKeeper的复杂度并提升应用的可靠性。
  • 开发背景：Curator最初由Netflix公司开源，目前是Apache的顶级项目。
2.2 核心功能
  1. 高可用性连接管理：自动处理与ZooKeeper服务器的连接断开和重新连接，确保连接的稳定性和可靠性。
  2. 易于使用的API：封装复杂的ZooKeeper原语，提供更直观、简洁的使用方式，降低开发难度。
  3. 模式（Recipes）：预置了一系列常见的分布式计算模式，如leader选举、分布式锁、缓存机制等，开发者可以快速实现这些分布式系统经典难题。
  4. 服务发现与负载均衡：支持动态的服务注册与发现，便于构建云原生应用，提高系统的可扩展性和灵活性。
  5. 异步DSL：针对Java 8及以上版本提供了异步编程的支持，提高了响应速度和程序效率。

3. 使用指南

3.1 添加 Maven 依赖
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.12.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.12.0</version>
</dependency>
3.2 创建 Curator 客户端
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

public class CuratorExample {
    public static void main(String[] args) throws Exception {
        String connectString = "192.168.200.138:2181";
        String path = "/curator1";
        byte[] data = "myData".getBytes();

        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(5000, 10);
        // 创建 Curator 客户端
        CuratorFramework client = CuratorFrameworkFactory.newClient(connectString, retry);

        // 启动客户端
        client.start();

        // 创建节点
        client.create().withMode(CreateMode.PERSISTENT).forPath(path, data);

        // 获取节点数据
        byte[] retrievedData = client.getData().forPath(path);
        System.out.println("Retrieved data: " + new String(retrievedData));

        // 关闭客户端
        client.close();
    }
}
3.3 增删改查操作及Watcher监听
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;

public class CuratorExample {
    public static void main(String[] args) throws Exception {
        String connectString = "192.168.200.138:2181";
        String path = "/curator1";
        byte[] data1 = "myData1".getBytes();
        byte[] data2 = "myData2".getBytes();

        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(5000, 10);
        // 创建 Curator 客户端
        CuratorFramework client = CuratorFrameworkFactory.newClient(connectString, retry);

        // 启动客户端
        client.start();

        // 增加临时监听操作
        client.getCuratorListenable().addListener((CuratorFramework c, CuratorEvent event) -> {
            switch (event.getType()) {
                case WATCHED:
                    WatchedEvent watchedEvent = event.getWatchedEvent();
                    if (watchedEvent.getType() == Watcher.Event.EventType.NodeDataChanged) {
                        System.out.println("监听的数据变化为: " + new String(c.getData().forPath(path)));
                        System.out.println("触发事件");
                    }
            }
        });

        // 创建节点
        client.create().withMode(CreateMode.PERSISTENT).forPath(path, data1);

        // 获取节点数据
        byte[] retrievedData = client.getData().watched().forPath(path);
        System.out.println("原始数据: " + new String(retrievedData));

        // 修改节点数据
        client.setData().forPath(path, data2);
        Thread.sleep(2000);

        // 删除节点
        client.delete().forPath(path);
        Thread.sleep(2000);
    }
}
3.4 进行永久监听
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

public class PermanentWatcherExample {
    public static void main(String[] args) throws Exception {
        String connectString = "192.168.200.138:2181";
        String path = "/curator1";
        byte[] data1 = "myData1".getBytes();
        byte[] data2 = "myData2".getBytes();
        byte[] data3 = "myData3".getBytes();

        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(5000, 10);
        // 创建 Curator 客户端
        CuratorFramework client = CuratorFrameworkFactory.newClient(connectString, retry);

        // 启动客户端
        client.start();

        // 永久监听
        client.create().withMode(CreateMode.PERSISTENT).forPath(path, data1);
        NodeCache nodeCache = new NodeCache(client, path);
        nodeCache.start();
        nodeCache.getListenable().addListener(() -> {
            ChildData currentData = nodeCache.getCurrentData();
            if (currentData != null) {
                System.out.println("触发了永久监听的回调，当前值为：" + new String(currentData.getData()));
            }
        });

        client.setData().forPath(path, data1);
        Thread.sleep(2000);

        client.setData().forPath(path, data2);
        Thread.sleep(2000);

        client.setData().forPath(path, data3);
        Thread.sleep(2000);

        client.delete().forPath(path);
    }
}
3.5 使用分布式锁
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class DistributedLockExample {
    public static void main(String[] args) throws Exception {
        String connectString = "192.168.200.138:2181";
        String path = "/myLock";

        ExponentialBackoffRetry retry = new ExponentialBackoffRetry(5000, 10);
        // 创建 Curator 客户端
        CuratorFramework client = CuratorFrameworkFactory.newClient(connectString, retry);

        // 启动客户端
        client.start();

        // 创建分布式锁
        InterProcessMutex lock = new InterProcessMutex(client, path);

        // 获取锁
        lock.acquire();
        try {
            // 执行临界区代码
            System.out.println("Lock acquired, executing critical section...");
            Thread.sleep(2000);
        } finally {
            // 释放锁
            lock.release();
            System.out.println("Lock released.");
        }

        // 关闭客户端
        client.close();
    }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2249245.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Django实现智能问答助手-基础配置

Django实现智能问答助手-基础配置

设置 Django 项目、创建应用、定义模型和视图、实现问答逻辑&#xff0c;并设计用户界面。下面是一步一步的简要说明&#xff1a; 目录&#xff1a; QnAAssistant/ # 项目目录 │ ├── QnAAssistant/ # 项目文件夹 │ ├── init.py # 空文件 │ ├── settings.py # 项目配…
阅读更多...
【ESP32CAM+Android+C#上位机】ESP32-CAM在STA或AP模式下基于UDP与手机APP或C#上位机进行视频流/图像传输

【ESP32CAM+Android+C#上位机】ESP32-CAM在STA或AP模式下基于UDP与手机APP或C#上位机进行视频流/图像传输

前言： 本项目实现ESP32-CAM在STA或AP模式下基于UDP与手机APP或C#上位机进行视频流/图像传输。本项目包含有ESP32源码（arduino）、Android手机APP源码以及C#上位机源码，本文对其工程项目的配置使用进行讲解。实战开发，亲测无误。 AP模式，就是ESP32发出一个WIFI/热点提供给电…
阅读更多...
从〇开始深度学习(0)——背景知识与环境配置

从〇开始深度学习(0)——背景知识与环境配置

从〇开始深度学习(0)——背景知识与环境配置 文章目录 从〇开始深度学习(0)——背景知识与环境配置写在前面1.背景知识1.1.Pytorch1.2.Anaconda1.3.Pycharm1.4.CPU与GPU1.5.整体关系 2.环境配置2.1.准备工作2.1.1.判断有无英伟达显卡2.1.2.清理电脑里的旧环境 2.1.安装Anaconda…
阅读更多...
mac下Gpt Chrome升级成GptBrowser书签和保存的密码恢复

mac下Gpt Chrome升级成GptBrowser书签和保存的密码恢复

cd /Users/自己的用户名/Library/Application\ Support/ 目录下有 GPT\ Chrome/ Google/ GptBrowser/ GPT\ Chrome 为原来的chrome浏览器的文件存储目录. GptBrowser 为升级后chrome浏览器存储目录 书签所在的文件 Bookmarks 登录账号Login 相关的文件 拷贝到GptBrow…
阅读更多...
圆域函数的傅里叶变换和傅里叶逆变换

圆域函数的傅里叶变换和傅里叶逆变换

空域圆域函数的傅里叶变换 空域圆域函数&#xff08;也称为空间中的圆形区域函数&#xff09;通常指的是在二维空间中&#xff0c;以原点为中心、半径为 a a a的圆内取值为1&#xff0c;圆外取值为0的函数。这种函数可以表示为&#xff1a; f ( x , y ) { 1 if x 2 y 2 ≤ …
阅读更多...
Java基础——类型转化（强制转化）

Java基础——类型转化（强制转化）

目录 1.数字间的类型转换 &#xff08;1&#xff09; 隐式类型转换 &#xff08;2&#xff09;显式类型转换&#xff08;强制类型转换&#xff09; 2.类对象间的强制转换 &#xff08;1&#xff09; 向上转型 &#xff08;2&#xff09; 向下转型 将一个类型强制转换成另…
阅读更多...
数据结构C语言描述5(图文结合)--广义表讲解与实现

数据结构C语言描述5(图文结合)--广义表讲解与实现

前言 这个专栏将会用纯C实现常用的数据结构和简单的算法&#xff1b;有C基础即可跟着学习&#xff0c;代码均可运行&#xff1b;准备考研的也可跟着写&#xff0c;个人感觉&#xff0c;如果时间充裕&#xff0c;手写一遍比看书、刷题管用很多&#xff0c;这也是本人采用纯C语言…
阅读更多...
23种设计模式-装饰器(Decorator)设计模式

23种设计模式-装饰器(Decorator)设计模式

文章目录 一.什么是装饰器设计模式&#xff1f;二.装饰器模式的特点三.装饰器模式的结构四.装饰器模式的优缺点五.装饰器模式的 C 实现六.装饰器模式的 Java 实现七.代码解析八.总结 类图&#xff1a; 装饰器设计模式类图 一.什么是装饰器设计模式&#xff1f; 装饰器模式&…
阅读更多...
构建英语知识网站：Spring Boot框架解析

构建英语知识网站：Spring Boot框架解析

2相关技术 2.1 MYSQL数据库 MySQL是一个真正的多用户、多线程SQL数据库服务器。 是基于SQL的客户/服务器模式的关系数据库管理系统&#xff0c;它的有点有有功能强大、使用简单、管理方便、安全可靠性高、运行速度快、多线程、跨平台性、完全网络化、稳定性等&#xff0c;非常…
阅读更多...
数据结构之数组与链表的差异

数据结构之数组与链表的差异

一、数组 数组&#xff08;Array&#xff09;是由相同类型的元素&#xff08;element&#xff09;的集合所组成的数据结构&#xff0c;分配一块连续的内存来存储。利用元素的索引&#xff08;index&#xff09;可以计算出该元素对应的存储地址。最简单的数据结构类型是一维数组…
阅读更多...
RabbitMQ7：消息转换器

RabbitMQ7：消息转换器

欢迎来到“雪碧聊技术”CSDN博客&#xff01; 在这里&#xff0c;您将踏入一个专注于Java开发技术的知识殿堂。无论您是Java编程的初学者&#xff0c;还是具有一定经验的开发者&#xff0c;相信我的博客都能为您提供宝贵的学习资源和实用技巧。作为您的技术向导&#xff0c;我将…
阅读更多...
Ubuntu20.04+ROS 进行机械臂抓取仿真：环境搭建（一）

Ubuntu20.04+ROS 进行机械臂抓取仿真：环境搭建（一）

目录 一、从官网上下载UR机械臂 二、给UR机械臂添加夹爪 三、报错解决 本文详细介绍如何在Ubuntu20.04ROS环境中为Universal Robots的UR机械臂添加夹爪。首先从官方和第三方源下载必要的软件包&#xff0c;包括UR机械臂驱动、夹爪插件和相关依赖。然后&#xff0c;针对gazeb…
阅读更多...
(即插即用模块-Attention部分) 二十、(2021) GAA 门控轴向注意力

(即插即用模块-Attention部分) 二十、(2021) GAA 门控轴向注意力

文章目录 1、Gated Axial-Attention2、代码实现 paper&#xff1a;Medical Transformer: Gated Axial-Attention for Medical Image Segmentation Code&#xff1a;https://github.com/jeya-maria-jose/Medical-Transformer 1、Gated Axial-Attention 论文首先分析了 ViTs 在训…
阅读更多...
Git 进程占用报错-解决方案

Git 进程占用报错-解决方案

背景 大仓库&#xff0c;由于开发者分支较多&#xff0c;我们在使用 git pull 或 git push 等命令时&#xff08;与远端仓库交互的命令&#xff09;&#xff0c;不知之前配置了什么&#xff0c;我的电脑会必现以下报错&#xff08;有非常长一大串报错-不同分支的git进程占用报…
阅读更多...
【FPGA-MicroBlaze】串口收发以及相关函数讲解

【FPGA-MicroBlaze】串口收发以及相关函数讲解

前言 工具&#xff1a;Vivado2018.3及其所对应的SDK版本 目前网上有许多MicroBlaze 的入门教程&#xff0c;比如下面的这个参考文章&#xff0c;用串口打印一个hello world。 【FPGA】Xilinx MicroBlaze软核使用第一节&#xff1a;Hello World!_fpga软核microblaze-CSDN博客 个…
阅读更多...
代码美学2：MATLAB制作渐变色

代码美学2：MATLAB制作渐变色

效果&#xff1a; %代码美学&#xff1a;MATLAB制作渐变色 % 创建一个10x10的矩阵来表示热力图的数据 data reshape(1:100, [10, 10]);% 创建热力图 figure; imagesc(data);% 设置颜色映射为“cool” colormap(cool);% 在热力图上添加边框 axis on; grid on;% 设置热力图的颜色…
阅读更多...
Android下载出现open failed: EPERM (Operation not permitted)

Android下载出现open failed: EPERM (Operation not permitted)

今天帮忙给同事调一下apk&#xff0c;发现android 自动更新apk&#xff0c;下载apk的时候总是失败&#xff0c;总是卡在 输出流这一步了 于是第一步分析&#xff0c;立马想到权限 但是下载之前的读写内存的权限也都有了 什么android 10高版本的不开启分区存储也用了 android…
阅读更多...
使用爬虫时，如何确保数据的准确性？

使用爬虫时，如何确保数据的准确性？

在数字化时代&#xff0c;数据的准确性对于决策和分析至关重要。本文将探讨如何在使用Python爬虫时确保数据的准确性&#xff0c;并提供代码示例。 1. 数据清洗 数据清洗是确保数据准确性的首要步骤。在爬取数据后&#xff0c;需要对数据进行清洗&#xff0c;去除重复、无效和…
阅读更多...
uniapp中使用Mescroll实现下拉刷新与上拉加载项目实战

uniapp中使用Mescroll实现下拉刷新与上拉加载项目实战

如何在UniApp中使用Mescroll实现下拉刷新与上拉加载 前言 下拉刷新和上拉加载更多成为了提升用户体验不可或缺的功能。UniApp作为一个跨平台的应用开发框架&#xff0c;支持使用Vue.js语法编写多端&#xff08;iOS、Android、H5等&#xff09;应用。Mescroll作为一款专为Vue设…
阅读更多...
【接口自动化测试】一文从0到1详解接口测试协议！

【接口自动化测试】一文从0到1详解接口测试协议！

接口自动化测试是软件开发过程中重要的环节之一。通过对接口进行测试&#xff0c;可以验证接口的功能和性能&#xff0c;确保系统正常运行。本文将从零开始详细介绍接口测试的协议和规范。 定义接口测试协议 接口测试协议是指用于描述接口测试的规范和约定。它包含了接口的请求…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023