Zookeeper JavaAPI操作（Curator API常用操作）

构建项目

zk版本：3.5.7，引入4.0.0的curator版本，Curator依赖的版本只能比zookeeper依赖的版本高。

Curator简单介绍

Curator是Netflix公司开源的一套zookeeper客户端框架，解决了很多Zookeeper客户端非常底层的细节开发工作，包括连接重连、反复注册Watcher和NodeExistsException异常等等，现在是Apache的开源项目。
Curator封装了很多功能（分布式锁、leader选举、分布式队列、共享计数器等等），更加简单易用

Curator对比zookeeper原生API

  • 原生API的超时重连，需要手动操作，而Curator封装了很多重连策略，自动重连
  • 原生API不支持递归创建节点，Curator可以递归创建节点
  • 是对原生API的进一步封装，功能更多，更容易使用
  • Curator 是Fluent的API风格（依赖于方法链、提高代码的易读性）

pom文件引入

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>curator-zk</artifactId><version>1.0-SNAPSHOT</version><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!-- https://mvnrepository.com/artifact/junit/junit --><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.10</version><scope>test</scope></dependency><!--        curator--><!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.0.0</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.0.0</version></dependency><!--        日志--><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.21</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.21</version><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.1</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin></plugins></build>
</project>

log4j.properties（resource目录下）

### set log levels - for more verbose logging change 'info' to 'debug' ###
log4j.rootLogger=off, stdout
### direct log messages to stdout ###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d{yyyy-MM-dd HH/:mm/:ss}]-%5p %c(line/:%L) %x-%m%n

建立连接

package com.tang.curator;import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.junit.Test;public class CuratorTest {/*** 建立连接*/@Testpublic  void testConnect() {//重试策略ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(3000,10);//第一种创建方式：通过构造器构造CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", 60*1000, 15*1000, retryPolicy);//第二种创建方式：通过builder模式链式编程client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(60*1000).connectionTimeoutMs(15*1000).retryPolicy(retryPolicy).namespace("zkProject").build();//开启连接client.start();}
}
构造参数意义
connectString连接url，集群用逗号分割 ，127.0.0.1:2181,127.0.0.1:2182
sessionTimeoutMs会话超时时间(建立连接后，会话断开的重连时间) 单位：毫秒，默认60秒
connectionTimeoutMs连接超时时间 单位：毫秒，默认15秒
retryPolicy重试策略
namespace默认一个根目录，以后的所有创建都会在此目录下进行

RetryPolicy相关（重试连接策略）

在这里插入图片描述
在这里插入图片描述

ExponentialBackoffRetry‌

特点‌：采用指数退避算法来实现重试机制。每次重试失败后，等待时间间隔会逐渐增加，直到达到最大重试次数或者重试成功为止。这种策略适用于需要逐渐延长重试间隔以减少对系统的冲击，同时确保最终能够成功连接的场景。
‌实现‌：ExponentialBackoffRetry实现了RetryPolicy接口，并提供了一些构造方法来设置重试的参数，如最大重试次数、初始等待时间、最大等待时间等‌

RetryNTimes‌

特点‌：简单地重试N次，不考虑重试之间的时间间隔。这种策略适用于希望快速重试且对重试次数有明确限制的场景。
‌实现‌：通过指定重试次数N来实例化该策略，当重试次数达到N时停止重试‌

RetryOneTime‌

特点‌：只重试一次，即如果初次尝试失败，则进行一次重试，然后停止。这种策略适用于对重试要求不高的场景，或者作为其他策略的补充。
‌注意‌：虽然这种策略较为简单，但在某些情况下可能仍然有用，特别是当希望快速失败而不是无限重试时。

RetryUntilElapsed‌

特点‌：在指定的总时间内不断重试，直到成功或时间耗尽。这种策略适用于对时间有明确要求，且希望在这段时间内尽可能多地尝试连接的场景。
‌实现‌：需要指定一个最长等待时间，在这段时间内会不断尝试重试，直到成功或时间到期‌

RetryForever‌

特点‌：永远重试，直到成功为止。这种策略适用于对连接成功有极高要求，且不介意无限重试的场景。
‌注意‌：在实际应用中应谨慎使用此策略，以避免因无限重试而导致的资源耗尽或其他问题‌

添加节点

有四种添加节点的方式：

  1. 基本创建：create().forPath()
  2. 创建带数据的节点：create().forPath(path,value)
  3. 设置节点类型：create().withMode().forPath()
  4. 创建多节点（父节点不存在会报错，创建时需要调用：creatingParentContainersIfNeeded方法）

节点类型是一个CreateMode的枚举，有以下四种类型：

节点名称枚举解释
持久节点‌Persistent节点创建后，会一直保存在ZooKeeper中，直到被明确删除
持久顺序节点PersistentSequential在创建子节点时，ZooKeeper会自动为节点名称添加一个数字后缀，以保证子节点的创建顺序
临时节点Ephemeral节点的生命周期与创建它的会话绑定在一起，会话结束后，节点也会被自动删除
‌临时顺序节点‌EphemeralSequential与持久顺序节点类似，但节点的生命周期是临时的，与会话绑定
/*** 创建节点*/@Testpublic void create() throws Exception {//1.基本创建//如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储client.create().forPath("/test");//2.创建带数据的节点，如果这里的path还是/test就会报错client.create().forPath("/test1","test".getBytes());}@Testpublic void testCreate2() throws Exception {// 设置节点类型 （默认：持久化）String path = client.create().withMode(CreateMode.EPHEMERAL) // 设置临时模式.forPath("/app3");//输出path为/app3System.out.println(path);}@Testpublic void testCreate3() throws Exception {// 创建多节点String path = client.create().creatingParentContainersIfNeeded() // 父节点不存在，则创建父节点.forPath("/app4/p2");//输出path为/app4/p2System.out.println(path);}

查询节点

  1. 查询数据：client.getData().forPath()
  2. 查询子节点：client.getChildren().forPath()
  3. 查询节点信息状态： client.getData().storingStatIn(stat).forPath()
 /*** 查询节点* @throws Exception*/@Testpublic void testGet() throws Exception {//1.查询数据：getbyte[] data = client.getData().forPath("/app1");System.out.println("1.查询数据："+new String(data));// 2.查询子节点：lsList<String> path  = client.getChildren().forPath("/app4");System.out.println("2."+path);//3.查询节点状态信息：ls -sStat stat = new Stat();client.getData().storingStatIn(stat).forPath("/app1");System.out.println("3."+stat.toString());}

修改节点

  1. 基本数据修改： client.setData().forPath()
  2. 根据版本修改：client.setData().withVersion().forPath()
    一般使用第二种修改方式，version 是通过查询出来的，目的是为了让其他客户端不干扰我修改（原子性操作）
	/*** 1.基本修改数据：.setData().forPath()* * @throws Exception*/@Testpublic void testSet() throws Exception {client.setData().forPath("/test","MarryChristmas".getBytes());}/***2.根据版本修改*  version 是通过查询出来的，目的是为了让其他客户端不干扰我（原子性操作）* @throws Exception*/@Testpublic void testSetForVersion() throws Exception {int version = 0;Stat stat = new Stat();client.getData().storingStatIn(stat).forPath("/test");version = stat.getVersion();client.setData().withVersion(version).forPath("/test","HappyNewYear".getBytes());}

删除节点

  1. 删除单个节点：client.delete().forPath()
  2. 删除带有子节点的节点： client.delete().deletingChildrenIfNeeded().forPath()
  3. 必须成功的删除：为了防止网络波动，本质就是重试：client.delete().guaranteed().forPath()
  4. 回调：inBackground（）
/*** 删除节点* 1.删除单个节点* 2.删除带有子节点的节点* 3.必须成功的删除:为了防止网络抖动，本质就是重试* 4.回掉* @throws Exception*/@Testpublic void testDelete() throws Exception {client.delete().forPath("/test1");client.delete().deletingChildrenIfNeeded().forPath("/app4");client.delete().guaranteed().forPath("/app4");client.delete().guaranteed().inBackground(new BackgroundCallback() {@Overridepublic void processResult(CuratorFramework curatorFramework, CuratorEvent curatorEvent) throws Exception {System.out.println("水逆退散！");}}).forPath("/test");}

完整代码：

package com.tang.curator;import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.BackgroundCallback;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;import java.util.List;public class CuratorTest {private  CuratorFramework client;/*** 建立连接*/@Before//@Before表示在测试方法执行前执行@Testpublic  void testConnect() {//重试策略ExponentialBackoffRetry retryPolicy = new ExponentialBackoffRetry(3000,10);//第一种创建方式：通过构造器构造client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", 60*1000, 15*1000, retryPolicy);//第二种创建方式：通过builder模式链式编程client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(60*1000).connectionTimeoutMs(15*1000).retryPolicy(retryPolicy).namespace("zkProject").build();//开启连接client.start();}/*** 创建节点*/@Testpublic void create() throws Exception {//1.基本创建//如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储client.create().forPath("/test");//2.创建带数据的节点，如果这里的path还是/test就会报错client.create().forPath("/test1","test".getBytes());}@Testpublic void testCreate2() throws Exception {// 设置节点类型 （默认：持久化）String path = client.create().withMode(CreateMode.EPHEMERAL) // 设置临时模式.forPath("/app3");//输出path为/app3System.out.println(path);}@Testpublic void testCreate3() throws Exception {// 创建多节点String path = client.create().creatingParentContainersIfNeeded() // 父节点不存在，则创建父节点.forPath("/app4/p2");//输出path为/app4/p2System.out.println(path);}/*** 查询节点* @throws Exception*/@Testpublic void testGet() throws Exception {//1.查询数据：getbyte[] data = client.getData().forPath("/app1");System.out.println("1.查询数据："+new String(data));// 2.查询子节点：lsList<String> path  = client.getChildren().forPath("/app4");System.out.println("2."+path);//3.查询节点状态信息：ls -sStat stat = new Stat();client.getData().storingStatIn(stat).forPath("/app1");System.out.println("3."+stat.toString());}/*** 1.基本修改数据：.setData().forPath()** @throws Exception*/@Testpublic void testSet() throws Exception {client.setData().forPath("/test","MarryChristmas".getBytes());}/***2.根据版本修改*  version 是通过查询出来的，目的是为了让其他客户端不干扰我（原子性操作）* @throws Exception*/@Testpublic void testSetForVersion() throws Exception {int version = 0;Stat stat = new Stat();client.getData().storingStatIn(stat).forPath("/test");version = stat.getVersion();client.setData().withVersion(version).forPath("/test","HappyNewYear".getBytes());}/*** 删除节点* 1.删除单个节点* 2.删除带有子节点的节点* 3.必须成功的删除:为了防止网络抖动，本质就是重试* 4.回掉* @throws Exception*/@Testpublic void testDelete() throws Exception {client.delete().forPath("/test1");client.delete().deletingChildrenIfNeeded().forPath("/app4");client.delete().guaranteed().forPath("/app4");client.delete().guaranteed().inBackground(new BackgroundCallback() {@Overridepublic void processResult(CuratorFramework curatorFramework, CuratorEvent curatorEvent) throws Exception {System.out.println("水逆退散！");}}).forPath("/test");}@Afterpublic void close() {if (client != null) {client.close();}}
}

参考博客：
https://blog.csdn.net/qq_37774171/article/details/122514318

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

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

相关文章

可搜索的下拉选择框：filterable属性详解

可搜索的下拉选择框：filterable属性详解

在前端开发中&#xff0c;下拉选择框&#xff08;Dropdown Select&#xff09;是一个常见的UI组件&#xff0c;它允许用户从一组预定义的选项中选择一个或多个值。然而&#xff0c;当选项数量较多时&#xff0c;手动查找特定的选项可能会变得繁琐。为了解决这个问题&#xff0c…
阅读更多...
精选9个自动化任务的Python脚本精选

精选9个自动化任务的Python脚本精选

大家好&#xff0c;我是老邓&#xff0c;今天我们来一起学习如何用Python进行一些常见的自动化操作&#xff0c;涉及文件处理、网络交互等实用技巧。即使你没有任何Python基础也没关系&#xff0c;我会用最通俗易懂的语言来讲解。 1. 对目录中的文件进行排序 import osdef so…
阅读更多...
滑动窗口 + 算法复习

滑动窗口 + 算法复习

维护一个满足条件的窗口大小&#xff0c;然后进行双指针移动 1.最长子串 题目链接&#xff1a;1.最长子串 - 蓝桥云课 #include<bits/stdc.h> #define int long long using namespace std; string s; int k; signed main() {int max_len0,left0;cin>>s>>k;…
阅读更多...
PDF书籍《手写调用链监控APM系统-Java版》第9章 插件与链路的结合：Mysql插件实现

PDF书籍《手写调用链监控APM系统-Java版》第9章 插件与链路的结合：Mysql插件实现

本人阅读了 Skywalking 的大部分核心代码&#xff0c;也了解了相关的文献&#xff0c;对此深有感悟&#xff0c;特此借助巨人的思想自己手动用JAVA语言实现了一个 “调用链监控APM” 系统。本书采用边讲解实现原理边编写代码的方式&#xff0c;看本书时一定要跟着敲代码。 作者…
阅读更多...
关于Vue的子组件改变父组件传来的值

关于Vue的子组件改变父组件传来的值

一、组件直接传值 大家都知道父子组件传值的方案&#xff0c;有以下几个&#xff0c;不再详细敖述 Props&#xff1a;父组件向子组件传递数据 $emit&#xff1a;子组件通过自定义事件向父组件传递数据 .sync修饰符&#xff1a;一个方便且强大的工具&#xff0c;可以简化父子组…
阅读更多...
Flink的Watermark水位线详解

Flink的Watermark水位线详解

一、Flink的时间语义 Flink有如下三种时间语义&#xff1a; Flink的三种时间语义-CSDN博客 在实际应用中&#xff0c;一般会采用事件时间语义。而正如前面所说的&#xff0c;事件时间语义需要等窗口的数据全部到齐了&#xff0c;才能进行窗口计算。那么&#xff0c;什么时候数…
阅读更多...
ES学习Promise对象（九）

ES学习Promise对象（九）

这里写目录标题 一、概念二、示例基本使用使用 Promise 对象封装Ajaxthen() 方法catch() 方法 一、概念 简单说就是一个容器&#xff0c;里面保存着某个未来才会结束的事件&#xff08;通常是一个异步操作&#xff09;的结果。Promise 是一个对象&#xff0c;Promise 提供统一…
阅读更多...
Kibana：LINUX_X86_64 和 DEB_X86_64两种可选下载方式的区别

Kibana：LINUX_X86_64 和 DEB_X86_64两种可选下载方式的区别

最近需要在vm&#xff08;操作系统是 Ubuntu 22.04.4 LTS&#xff0c;代号 Jammy。这是一个基于 x86_64 架构的 Linux 发行版&#xff09;上安装一个7.17.8版本的Kibana&#xff0c;并且不采用docker方式。 在下载的时候发现有以下两个选项&#xff0c;分别是 LINUX_X86_64 和 …
阅读更多...
CMake 构建项目并整理头文件和库文件

CMake 构建项目并整理头文件和库文件

本文将介绍如何使用 CMake 构建项目、编译生成库文件&#xff0c;并将头文件和库文件整理到统一的目录中以便在其他项目中使用。 1. 项目结构 假设我们正在构建一个名为 rttr 的开源库&#xff0c;初始的项目结构如下&#xff1a; D:\WorkCode\Demo\rttr-master\|- src\ …
阅读更多...
【FAQ】HarmonyOS SDK 闭源开放能力 — Vision Kit（2）

【FAQ】HarmonyOS SDK 闭源开放能力 — Vision Kit（2）

1.问题描述&#xff1a; 人脸活体检测返回上一页App由沉浸式变为非沉浸式多了上下安全区域。 解决方案&#xff1a; 检测结束后需要自己去设置沉浸式配置。 2.问题描述&#xff1a; Vision Kit文字识别是本地识别&#xff0c;还是上传至服务器&#xff0c;由服务器来识别文…
阅读更多...
AIA - IMSIC之二（附IMSIC处理流程图）

AIA - IMSIC之二（附IMSIC处理流程图）

本文属于《 RISC-V指令集基础系列教程》之一，欢迎查看其它文章。 1 ​​​​​​​通过IMSIC接收外部中断的CSR 软件通过《AIA - 新增的CSR》描述的CSR来访问IMSIC。 machine level 的 CSR 与 IMSIC 的 machine level interrupt file 可相互互动;而 supervisor level 的 CSR…
阅读更多...
Vue单页应用的配置

Vue单页应用的配置

前面通过几篇文章了解并掌握了 Vue 项目构建及运行的前期工作 。接下来我们可以走进 Vue 项目的内部&#xff0c;一探其内部配置的基本构成。 1. 路由配置 由于 Vue 这类型的框架都是以一个或多个单页构成&#xff0c;在单页内部跳转并不会重新渲染 HTML 文件&#xff0c;其路…
阅读更多...
CocosCreator-引擎案例-TS:spine

CocosCreator-引擎案例-TS:spine

工程1&#xff1a;LoadSpine&#xff1a;简单加载spine资源 建立工程&#xff0c;在层级上建立一个空对象&#xff0c;改名spine 在spine上添加spine组件&#xff1a; 添加组件>渲染组件>spine 在spine上挂上脚本loadspine onLoad () {cc.resources.load(loadSpine/ali…
阅读更多...
使用FreeNAS软件部署ISCSI的SAN架构存储（IP-SAN）练习题

使用FreeNAS软件部署ISCSI的SAN架构存储（IP-SAN）练习题

一&#xff0c;实验用到工具分别为&#xff1a; VMware虚拟机&#xff0c;安装教程&#xff1a;VMware Workstation Pro 17 安装图文教程 FreeNAS系统&#xff0c;安装教程&#xff1a;FreeNAS-11.2-U4.1安装教程2024&#xff08;图文教程&#xff09; 二&#xff0c;新建虚…
阅读更多...
【ANGULAR网站开发】初始环境搭建

【ANGULAR网站开发】初始环境搭建

1. 初始化angular项目 1.1 创建angular项目 需要安装npm和nodejs&#xff0c;这边不在重新安装 直接安装最新版本的angular npm install -g angular/cli安装指定大版本的angular npm install -g angular/cli181.2 启动angular 使用idea启动 控制台启动 ng serve启动成功…
阅读更多...
lua debug相关方法详解

lua debug相关方法详解

lua debug相关方法详解 1. debug.debug()2. debug.getinfo(func | level [, what])3. debug.getlocal(func-or-level, localindex)4. debug.setlocal(level, local_number, value)5. debug.getupvalue(func, upvalue_index)6. debug.setupvalue(func, upvalue_index, value)7. …
阅读更多...
《计算机网络(第7版)-谢希仁》期末考试复习题和答案（总结整理）

《计算机网络(第7版)-谢希仁》期末考试复习题和答案（总结整理）

目录 前言&#xff1a; 一、选择题。 二、填空题。 三、名词解释。 四、简答题。 前言&#xff1a; 这个自动标题自己带了序号&#xff0c;一开始想全部选项和题号都改过来的&#xff0c;结果一看一百多个全是&#xff0c;懒得改了 一、选择题。 1、广域网覆盖的地理范围…
阅读更多...
【再谈设计模式】享元模式~对象共享的优化妙手

【再谈设计模式】享元模式~对象共享的优化妙手

一、引言 在软件开发过程中&#xff0c;我们常常面临着创建大量细粒度对象的情况&#xff0c;这可能会导致内存占用过高、性能下降等问题。享元模式&#xff08;Flyweight Pattern&#xff09;就像是一位空间管理大师&#xff0c;它能够在不影响功能的前提下&#xff0c;有效地…
阅读更多...
Milvus×EasyAi：如何用java从零搭建人脸识别应用

Milvus×EasyAi：如何用java从零搭建人脸识别应用

如何从零搭建一个人脸识别应用&#xff1f;不妨试试原生Java人工智能算法&#xff1a;EasyAi Milvus 的组合拳。 本文将使用到的软件和工具包括&#xff1a; EasyAi&#xff1a;人脸特征向量提取Milvus&#xff1a;向量数据库用于高效存储和检索数据。 01. EasyAi&#xff1a;…
阅读更多...
NS3学习——tcpVegas算法代码详解（2）

NS3学习——tcpVegas算法代码详解（2）

NS3学习——tcpVegas算法代码详解&#xff08;1&#xff09;-CSDN博客 目录 4.TcpVegas类中成员函数 (5) CongestionStateSet函数 (6) IncreaseWindow函数 1.检查是否启用 Vgas 2.判断是否完成了一个“Vegas 周期” 2.1--if&#xff1a;判断RTT样本数量是否足够 2.2--e…
阅读更多...
最新文章

Copyright @ 2022~2023