java连接zookeeper的实现示例

更新时间：2023年11月01日 11:44:09 作者：曹朋羽

ZooKeeper官方提供了Java API,可以通过Java代码来连接zookeeper服务进行操作,本文就来介绍一下java连接zookeeper的实现示例,具有一定的参考价值,感兴趣的可以了解一下

API

ZooKeeper官方提供了Java API，可以通过Java代码来连接zookeeper服务进行操作。可以连接、创建节点、获取节点数据、监听节点变化等操作，具体有以下几个重要的类：

ZooKeeper：ZooKeeper类是Java API的核心类，用于与ZooKeeper服务器建立连接，并提供了一系列方法来操作ZooKeeper的节点。
Watcher：Watcher是ZooKeeper的一个回调接口，当节点发生变化时会调用相应的方法进行通知。
CreateMode：CreateMode枚举类定义了节点的类型，包括永久节点、临时节点、顺序节点和临时顺序节点。
Stat：Stat类表示节点的元数据信息，比如修改版本、数据长度、子节点数量等。

添加依赖

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

操作例子

String host = "localhost:2181";
//建立连接
zooKeeper = new ZooKeeper(host, 2000, null);
String path = "/test";
Watcher watcher = new Watcher() {
  @Override
  public void process(WatchedEvent watchedEvent) {
    System.out.println("Node changed: " + watchedEvent.getPath());
    System.out.println(watchedEvent);
  }
};
//获取节点状态 如果不存在返回null
Stat stat = zooKeeper.exists(path, false);
if(null != stat){
	System.out.println(stat.getCzxid()+"-"+stat.getAversion());
}

//创建节点 包含版本、时间、数据长度等信息
zooKeeper.create(path,"123".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
//添加watcher
zooKeeper.addWatch(path, watcher, AddWatchMode.PERSISTENT);

//获取节点数据
byte[] data = zooKeeper.getData(path, false, null);
System.out.println(new String(data));

zooKeeper.create(path+"/1","child1".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
//获取子节点
List<String> children = zooKeeper.getChildren(path, false);
System.out.println("childs size:"+children.size());
//删除子节点
zooKeeper.delete(path+"/1",-1);
zooKeeper.close();

zkClient

zkClient封装了zookeeper的官方api，简化了一些繁琐的操作，并提供了一些额外的功能，提高了开发效.

添加依赖

<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.11</version>
</dependency>

zkclient对节点数据的操作进行了序列化，这里先准备一个string类型的序列化类。需要实现ZkSerializer接口

public class ZkStringSerializer implements ZkSerializer {
    @Override
    public byte[] serialize(Object o) throws ZkMarshallingError {
        return String.valueOf(o).getBytes();
    }

    @Override
    public Object deserialize(byte[] bytes) throws ZkMarshallingError {
        return new String(bytes);
    }
}

基本操作

ZkClient zkClient = new ZkClient("localhost:2181");
//自定义序列化 否则报错
zkClient.setZkSerializer(new ZkStringSerializer());
String path = "/test";
//判断节点是否存在
boolean exist = zkClient.exists(path);
System.out.println(exist);
if(!exist){//创建节点
    zkClient.create(path,"123", CreateMode.PERSISTENT);
}
//读取节点数据
System.out.println((String) zkClient.readData(path));
zkClient.writeData(path,"456");//设置节点数据
System.out.println((String) zkClient.readData(path));
zkClient.delete(path);//删除节点

zkClient.close();

节点变化事件

String path = "/test";
/**
 * 节点变化事件
 * 只监听节点增减，不监听数据变化事件
 */
zkClient.subscribeChildChanges(path, new IZkChildListener() {
    @Override
    public void handleChildChange(String parentPath, List<String> children) throws Exception {
        System.out.println("节点"+parentPath+"发生变化");
        System.out.println(children);
    }
});
//节点操作，观察handleChildChange接收到对应事件
Thread.sleep(2000);
zkClient.createPersistent(path);
Thread.sleep(2000);
zkClient.createPersistent(path+"/child1");
Thread.sleep(2000);
zkClient.writeData(path+"/child1","123");
Thread.sleep(2000);
zkClient.delete(path+"/child1");
Thread.sleep(2000);
zkClient.delete(path);
Thread.sleep(100000);

节点数据变化事件

    String path = "/test";
    /**
     * 节点变化事件,只检测当前节点，感知不到其子节点
     * 节点被删除或节点数据变化
     */
    zkClient.subscribeDataChanges(path, new IZkDataListener() {
        @Override
        public void handleDataChange(String s, Object o) throws Exception {
            System.out.println("节点："+s+"数据变为:"+o);
        }

        @Override
        public void handleDataDeleted(String s) throws Exception {
            System.out.println("节点："+s+"删除");
        }
    });

    Thread.sleep(2000);
    zkClient.createPersistent(path);
    Thread.sleep(2000);
    zkClient.createPersistent(path+"/child1");
    Thread.sleep(2000);
    zkClient.delete(path+"/child1");
    Thread.sleep(2000);
    zkClient.writeData(path,"123");
    Thread.sleep(2000);
    zkClient.delete(path);
    Thread.sleep(100000);
}

Curator

curator是另一个java连接zookeeper类库。功能更加强大。提供了连接重试、分布式锁、选举、队列等多种实际场景的用例。这里先简单搞个使用例子。

添加依赖

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>5.1.0</version>
</dependency>

curator-framework是基础的依赖，一些特定的使用方式需要添加不同的依赖，有curator-recipes、curator-x-discovery、curator-x-async等。

基本操作

//创建连接
CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3));
client.start();
String path = "/test";
client.checkExists().forPath(path);//判断是否存在
client.create().forPath(path, "123".getBytes());//创建节点
byte[] data = client.getData().forPath(path);//获取数据
System.out.println(new String(data));
client.setData().forPath(path, "456".getBytes());//设置数据
client.delete().forPath(path);//删除节点

client.close();

节点监听

CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3));
client.start();
String path = "/test";
NodeCache  nodeCache = new NodeCache(client,path);
//添加监听
nodeCache.getListenable().addListener(new NodeCacheListener() {
    @Override
    public void nodeChanged() throws Exception {
        ChildData data = nodeCache.getCurrentData();
        if (data != null) {
            System.out.println("Node changed: " + data.getPath() + ", value: " + new String(data.getData()));
        } else {
            System.out.println("Node deleted: " + nodeCache.getPath());
        }
    }
});
nodeCache.start();
client.create().forPath(path);
client.setData().forPath(path, "123".getBytes());
client.delete().forPath(path);
client.close();

这里NodeCache被标识@Deprecated，也不知道被什么方式代替了，后面再研究。先简单使用。

到此这篇关于java连接zookeeper的实现示例的文章就介绍到这了,更多相关java连接zookeeper内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java读取XML实现过程(DOM方式)
文章介绍了如何使用Java的DOM方式读取XML文件,并详细说明了读取过程中需要注意的事项,如文件路径、节点层级和属性值的获取方式,作者通过一个示例代码展示了如何实现XML的读取,并总结了自己的经验,希望对读者有所帮助
2025-11-11
详解SpringBoot2.0的@Cacheable(Redis)缓存失效时间解决方案
这篇文章主要介绍了详解SpringBoot2.0的@Cacheable(Redis)缓存失效时间解决方案，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-04-04
Spring AOP底层源码深度解析之从动态代理到注解实现的完整架构
这篇文章详细介绍了Spring AOP的核心概念、实现方式、配置方法以及高级特性,从动态代理基础到性能优化,全面涵盖了Spring AOP的各个方面,帮助开发者深入理解并有效地应用Spring AOP,感兴趣的朋友跟随小编一起看看吧
2026-01-01
MyBatisPlus查询投影与查询条件详细讲解
这篇文章主要介绍了MyBatisPlus DQL编程控制中的查询投影、查询条件，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-08-08
springboot如何初始化执行sql语句
这篇文章主要介绍了springboot初始化执行sql语句的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-06-06
详解Java实现单例的五种方式
这篇文章主要介绍了详解Java实现单例的五种方式,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-07-07
Java中float类型的范围及其与十六进制的转换例子
这篇文章主要介绍了Java中float类型的范围及其与十六进制的转换例子,是Java入门学习中的基础知识,需要的朋友可以参考下
2015-10-10
RabbitMQ队列的选择及应用场景
本文介绍RabbitMQ的Classic、Quorum、Stream及懒队列,分别适用于单机、集群高可用、消息持久化与分布式备份、内存优化等场景,帮助选择合适队列类型以解决不同需求,感兴趣的跟随小编一起看看吧
2025-07-07
Java显式锁详情
这篇文章主要详细的介绍了shenJava显式锁常用的api及标准用法，感兴趣的朋友,需要的朋友可以参考下面文章里的内容
2021-09-09
Java设计模式之抽象工厂模式(Abstract Factory)
这篇文章主要为大家详细介绍了Java设计模式之抽象工厂模式，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-03-03

java连接zookeeper的实现示例

目录

API

zkClient

Curator

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具