【Zookeeper】使用Curator操作Zookeeper

这篇具有很好参考价值的文章主要介绍了【Zookeeper】使用Curator操作Zookeeper。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

简介

Curator 是 Apache ZooKeeper 的Java客户端库。
Zookeeper现有常见的Java API如:原生JavaAPI、Curator、ZkClient等。

添加依赖

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

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>4.0.0</version>
</dependency>

基本操作

创建连接

  创建节点:create 持久 临时 顺序 数据
  1. 基本创建 :create().forPath("")
  2. 创建节点 带有数据:create().forPath("",data)
  3. 设置节点的类型:create().withMode().forPath("",data)
  4. 创建多级节点  /app1/p1 :create().creatingParentsIfNeeded().forPath("",data)
RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);// 尝试间隔时间,最大尝试次数
client = CuratorFrameworkFactory.builder()
        .connectString("localhost:2181") // 连接字符串。zk server 地址和端口 "192.168.149.135:2181,192.168.149.136:2181"
        .sessionTimeoutMs(60 * 1000) // 会话超时时间 单位ms
        .connectionTimeoutMs(15 * 1000) // 连接超时时间 单位ms
        .retryPolicy(retryPolicy) // 重试策略
        .namespace("itheima") // 根目录,后续的操作都在/itheima下进行
        .build();
//开启连接
client.start();

//执行相关操作
.......

//关闭连接
if (client != null) {
    client.close();
}

创建节点

不指定数据

//基本创建
//如果创建节点,没有指定数据,则默认将当前客户端的ip作为数据存储
String path = client.create().forPath("/app1");
System.out.println(path);

指定数据

//创建节点 带有数据
//如果创建节点,没有指定数据,则默认将当前客户端的ip作为数据存储
String path = client.create().forPath("/app2", "HelloWorld".getBytes());
System.out.println(path);

设置节点类型

//设置节点的类型(默认类型:持久化)
String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");// 创建临时节点
System.out.println(path);

节点可以分为四大类:

  • PERSISTENT 持久化节点

  • EPHEMERAL 临时节点,只在当前会话有效

  • PERSISTENT_SEQUENTIAL 持久化顺序节点

  • EPHEMERAL_SEQUENTIAL 临时顺序节点

创建多级节点

//创建多级节点  /app1/p1
//creatingParentsIfNeeded():如果父节点不存在,则创建父节点
String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
System.out.println(path);

查询节点

  查询节点:
  1. 查询数据:get: getData().forPath()
  2. 查询子节点: ls: getChildren().forPath()
  3. 查询节点状态信息:ls -s:getData().storingStatIn(状态对象).forPath()

查询节点

 //查询数据:get
 byte[] data = client.getData().forPath("/app1");
 System.out.println(new String(data));

查询子节点

// 查询子节点: ls
List<String> path = client.getChildren().forPath("/");

System.out.println(path);

查询状态信息

Stat status = new Stat();
System.out.println(status);
//查询节点状态信息:ls -s
client.getData().storingStatIn(status).forPath("/app1");
System.out.println(status);

Stat类导包:import org.apache.zookeeper.data.Stat;该类封装好了状态信息,如下图所示。
curator zookeeper,Java,zookeeper,分布式
czxid:节点被创建的事务ID
ctime: 创建时间
mzxid: 最后一次被更新的事务ID
mtime: 修改时间
pzxid:子节点列表最后一次被更新的事务ID
cversion:子节点的版本号
dataversion:数据版本号
aclversion:权限版本号
ephemeralOwner:用于临时节点,代表临时节点的事务ID,如果为持久节点则为0
dataLength:节点存储的数据的长度
numChildren:当前节点的子节点个数

修改

  修改数据
 1. 基本修改数据:setData().forPath()
 2. 根据版本修改: setData().withVersion().forPath()。  version 是通过查询出来的。目的就是为了让其他客户端或者线程不干扰我。
 client.setData().forPath("/app1", "itcast".getBytes());
Stat status = new Stat();
//查询节点状态信息:ls -s
client.getData().storingStatIn(status).forPath("/app1");


int version = status.getVersion();
System.out.println(version);
client.setData().withVersion(version).forPath("/app1", "hehe".getBytes());

删除节点

  删除节点: delete deleteall
  1. 删除单个节点:delete().forPath("/app1");
  2. 删除带有子节点的节点:delete().deletingChildrenIfNeeded().forPath("/app1");
  3. 必须成功的删除:为了防止网络抖动。本质就是重试。  client.delete().guaranteed().forPath("/app2");
  4. 回调:inBackground
// 删除单个节点
client.delete().forPath("/app1");
//删除带有子节点的节点
client.delete().deletingChildrenIfNeeded().forPath("/app4");
//必须成功的删除
client.delete().guaranteed().forPath("/app2");
//回调
client.delete().guaranteed().inBackground(new BackgroundCallback(){

    @Override
    public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
        System.out.println("我被删除了~");
        System.out.println(event);
    }
}).forPath("/app1");

Watch监听

Zookeeper允许用户在指定的事件桑拿注册Watcher,当一些特定的事件处罚时,Zookeeper服务端将通知感兴趣的客户端上,该机制是Zoookeeper实现分布式协调服务的重要特性。Zookeeper引入了Watcher机制来实现发布和订阅功能,能够让多个订阅者同时监听某个对象,当对象发生改变时会通知所有订阅者。

Curator引入了 Cache 来实现对 ZooKeeper 服务端事件的监听。提供了三种Watcher:

- NodeCache : 只是监听某一个特定的节点
- PathChildrenCache : 监控一个ZNode的子节点. 
- TreeCache : 可以监控整个树上的所有节点,类似于PathChildrenCacheNodeCache的组合
//1. 创建NodeCache对象
final NodeCache nodeCache = new NodeCache(client,"/app1");
//2. 注册监听
nodeCache.getListenable().addListener(new NodeCacheListener() {
  @Override
  public void nodeChanged() throws Exception {
      System.out.println("节点变化了~");

      //获取修改节点后的数据
      byte[] data = nodeCache.getCurrentData().getData();
      System.out.println(new String(data));
  }
});

//3. 开启监听.如果设置为true,则开启监听是,加载缓冲数据
nodeCache.start(true);

// 仅用于测试时方便查看
while (true){

}

curator zookeeper,Java,zookeeper,分布式

演示 PathChildrenCache:监听某个节点的所有子节点们

//1.创建监听对象
PathChildrenCache pathChildrenCache = new PathChildrenCache(client,"/app2",true);

//2. 绑定监听器
pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
    @Override
    public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
        System.out.println("子节点变化了~");
        System.out.println(event);
        //监听子节点的数据变更,并且拿到变更后的数据
        //1.获取类型
        PathChildrenCacheEvent.Type type = event.getType();
        //2.判断类型是否是update
        if(type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)){
            System.out.println("数据变了!!!");
            byte[] data = event.getData().getData();
            System.out.println(new String(data));

        }
    }
});
//3. 开启
pathChildrenCache.start();

演示 TreeCache:监听某个节点自己和所有子节点们

//1. 创建监听器
TreeCache treeCache = new TreeCache(client,"/app2");

//2. 注册监听
treeCache.getListenable().addListener(new TreeCacheListener() {
   @Override
   public void childEvent(CuratorFramework client, TreeCacheEvent event) throws Exception {
       System.out.println("节点变化了");
       System.out.println(event);
   }
});

//3. 开启
treeCache.start();

while (true){

}

参考:https://www.bilibili.com/video/BV1M741137qY文章来源地址https://www.toymoban.com/news/detail-729774.html

到了这里,关于【Zookeeper】使用Curator操作Zookeeper的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • curator实现的zookeeper可重入锁

    Curator是一个Apache开源的ZooKeeper客户端库,它提供了许多高级特性和工具类,用于简化在分布式环境中使用ZooKeeper的开发。其中之一就是可重入锁。 Curator提供了 InterProcessMutex 类来实现可重入锁。以下是使用Curator实现ZooKeeper可重入锁的示例: import org.apache.curator.framework.Curato

    2024年02月15日
    浏览(42)
  • ZooKeeper 实战(四) Curator Watch事件监听

    上一篇博客只介绍了有关Curator中对ZNode的CRUD操作,从本篇起开始逐步介绍更加高级的API操作。 ZooKeeper 中引入了Watcher机制来实现了发布/订阅功能能,能够让多个订阅者同时监听某一个对象,当一个对象自身状态变化时,会通知所有订阅者。虽然ZooKeeper原生支持通过注册Watc

    2024年02月02日
    浏览(45)
  • ZooKeeper 实战(五) Curator实现分布式锁

    1.1.分布式锁概念 分布式锁是一种用于实现分布式系统中的同步机制的技术。它允许在多个进程或线程之间实现互斥访问共享资源,以避免并发访问时的数据不一致问题。分布式锁的主要目的是在分布式系统中提供类似于全局锁的效果,以确保在任何时刻只有一个进程或线程

    2024年01月18日
    浏览(39)
  • ZooKeeper Java API 使用教程 - 同步与异步操作示例

    本教程详细介绍了如何使用ZooKeeper Java API进行节点数据的同步和异步获取。通过具体代码示例,展示了如何连接ZooKeeper服务器,获取子节点列表,以及如何处理节点数据变化的事件。

    2024年04月22日
    浏览(33)
  • java操作zookeeper

    创建一个maven项目在pom文件里引入如下依赖: 创建一个测试类进行相关操作的测试 连接客户端 关闭客户端 创建节点 获取节点数据 查询子节点 查询节点状态信息 更新节点数据 更新节点数据,带版本号 删除节点 删除节点,必须成功 删除节点,回调函数 监听节点的创建、修

    2024年02月16日
    浏览(40)
  • Java操作Zookeeper节点

    引入jar包: zookeeper的权限: ZooKeeper提供了如下几种验证模式(scheme): • digest:Client端由用户名和密码验证,譬如user:password,digest的密码生成方式是Sha1摘要的base64形式 • auth:不使用任何id,代表任何已确认用户。 • ip:Client端由IP地址验证,譬如172.2.0.0/24 • world:固定

    2024年02月10日
    浏览(40)
  • 六、ZooKeeper Java API操作

    目录 1、引入maven坐标 2、节点的操作 这里操作Zookeeper的JavaAPI使用的是一套zookeeper客户端框架 Curator ,解决了很多Zookeeper客户端非常底层的细节开发工作 。 Curator包含了几个包:

    2024年02月04日
    浏览(33)
  • ZooKeeper基础命令和Java客户端操作

    (1)Help (2)ls 使用 ls 命令来查看当前znode中所包含的内容 (3)ls2查看当前节点数据并能看到更新次数等数据 (4)stat查看节点状态 (5)set 1)设置节点的具体值 2)set 节点 value值 set /test atguigu (6)get 1)获得节点的值 2)get 节点 (7)create 1)普通创建 create /test demo001

    2024年02月10日
    浏览(50)
  • Java客户端_zkclient库操作Zookeeper

    使用zookeeper遇到问题: 重复注册watcher session失效重连 异常处理(删除节点不能有子节点,新增节点必须有父节点等) zkclient是Github上一个开源的Zookeeper客户端,在Zookeeper原生 API接口之上进行了包装,是一个更加易用的Zookeeper客户端。同时Zkclient在内部实现了诸如Session超时重

    2024年02月07日
    浏览(58)
  • windows下 java使用zookeeper案例

    countDownLatch.await(); System.out.println(“zookeeper connection success”); } /** * 创建节点 * @param path * @param data * @throws Exception */ public String createNode(String path, String data) throws Exception { return this.zookeeper.create(path, data.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); } /** * 获取路径下所有子节点 *

    2024年04月28日
    浏览(38)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包