5.zookeeper集成Java项目curator客户端

创建了一个SpringBoot项目，引入pom依赖

     <!--zookeeper--><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-client</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency>

配置application.yml属性

curator:#重试次数maxRetries: 3#重试间隔时间baseSleepTimeMs: 1000# zookeeper 地址 多个可用逗号分隔127.0.0.1:2181,127.0.0.1:2182connectString: 192.168.106.128:2181# session超时时间sessionTimeoutMs: 60000# 连接超时时间connectionTimeoutMs: 5000path: /distributed-lock

配置注入Bean

package com.example.zkConfig;import lombok.Data;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.RetryNTimes;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Data
@Configuration
public class ZookeeperConfig {@Value("${curator.maxRetries}")private int maxRetries;@Value("${curator.baseSleepTimeMs}")private int baseSleepTimeMs;@Value("${curator.connectString}")private String connectString;@Value("${curator.sessionTimeoutMs}")private int sessionTimeoutMs;@Value("${curator.connectionTimeoutMs}")private int connectionTimeoutMs;@Value("${curator.path}")private String path;//调用start初始化方法@Bean(initMethod = "start")public CuratorFramework curatorFramework(){return CuratorFrameworkFactory.newClient(this.connectString,this.sessionTimeoutMs,this.connectionTimeoutMs,new RetryNTimes(this.maxRetries,this.connectionTimeoutMs));}
}

测试文件ZkTest一些基本操作

package com.example;import org.apache.curator.framework.CuratorFramework;
import org.apache.zookeeper.CreateMode;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
public class ZkTest {@Autowiredprivate CuratorFramework curatorFramework;@Testpublic void test1() throws Exception {//创建持久节点
//        String s = curatorFramework.create().forPath("/test-node1");
//        创建临时序号节点String s = curatorFramework.create().withMode(CreateMode.EPHEMERAL_SEQUENTIAL).forPath("/test-node2", "abc".getBytes());System.out.println(s);}@Testpublic void test2() throws Exception {//获取节点的数据byte[] bytes = curatorFramework.getData().forPath("/test-node1");System.out.println(new String(bytes));}@Testpublic void test3() throws Exception {//修改节点的数据curatorFramework.setData().forPath("/test-node1","你好".getBytes());//获取节点的数据byte[] bytes = curatorFramework.getData().forPath("/test-node1");System.out.println(new String(bytes));}@Testpublic void test4() throws Exception {//创建若父节点不存在则先创建父节点String s = curatorFramework.create().creatingParentsIfNeeded().forPath("/node-parent/node-1");System.out.println(s);}@Testpublic void test5() throws Exception {//删除父节点 子节点存在也一并删除curatorFramework.delete().guaranteed().deletingChildrenIfNeeded().forPath("/node-parent");}}

5.zookeeper集成Java项目curator客户端相关推荐

【自撰】zooKeeper 集成 Java代码
导入maven依赖 <dependency><groupId>org.apache.zookeeper</groupId><artifactId>zoo ...
Zookeeper整合JAVA应用之Curator开源客户端使用案例
Curator是Netflix公司开源的一套ZooKeeper客户端框架,和ZkClient一样它解决了非常底层的细节开发工作,包括连接.重连.反复注册Watcher的问题以及NodeExistsEx ...
Zookeeper的java客户端Curator
Zookeeper的java客户端Curator 常见的zookeeper java API: Curator API 常用操作建立连接添加节点删除节点修改节点查询节点 watch事件监听 ...
Zookeeper分布式一致性原理（七）：Curator客户端
1. Curator简介 Curator是Netfix公司开源的一套Zookeeper客户端.Curator解决了很多Zookeeper客户端非常底层的细节开发工作,包括重连.反复注册Watcher和 ...
ZooKeeper ：Java客户端Watcher API介绍
ZooKeeper :Java客户端Watcher API介绍在上一篇博客中,博主给大家介绍了Java客户端的Session.ACL以及Znode API: ZooKeeper :Java客户端Se ...
zookeeper curator客户端之增删改查
zookeeper curator客户端之增删改查 zookeeper安装:https://www.cnblogs.com/zwcry/p/10272506.html curator客户端是Apach ...
ZooKeeper学习总结（2）——ZooKeeper开源Java客户端ZkClient使用
zkclient是zookeeper的Java客户端.它让Zookeeper API 使用起来更简单:它非常方便订阅各种事件并自动重新绑定事件(会话建立.节点修改.节点删除.子节点变更等):它提供了s ...
java pipeline 实现_Docker+Jenkins+Pipeline实现持续集成（二）java项目构建
插件推荐插件名作用 Blue Ocean Jenkins2.7以后可安装,是Jenkins的一种新视图,能够通过图形化的界面创建和编辑Jenkinsfile,实现pipeline as code ...
MyBatis系列之--Java 项目（非SpringBoot）集成MyBatis
MyBatis系列之--Java 项目(非SpringBoot)集成MyBatis 对MyBatis简单介绍核心接口SqlSessionFactory 实战 1. Maven创建Java项目 2. ...

5.zookeeper集成Java项目curator客户端

5.zookeeper集成Java项目curator客户端相关推荐

最新文章

热门文章