Curator框架的使用

Curator框架的目的是减少用户的复杂度,毕竟原生的Zookeeper难以使用。

这里举一个使用例子。

第一步:建立连接

// 以下代码与192.168.1.101:2181建立了连接
CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.1.101:2181", new ExponentialBackoffRetry(1000, 3));
client.start();

这里的ExponentialBackoffRetry的含义是指数增长的重试间隔。根据这里的参数,第一次失败重试休息1000毫秒,第二次重试休息1000毫秒~3000毫秒,第三次失败重试休息1000毫秒~7000毫秒。这样指数增长。

第二步:监听节点下的数据

PathChildrenCache cache = new PathChildrenCache(client, "/test", true);
cache.start();
cache.getListenable().addListener(new MyListener(observer));

这样就可以监听test节点下的所有节点了。

第三步:实现事件处理

实现事件处理,只需实现PathChildrenCacheListener接口即可,示例如下。

public class MyListener implements PathChildrenCacheListener {
  @Override
  public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
    switch (event.getType()) {
      case CHILD_ADDED: {
        // 新的节点创建了
        ...
        break;
      }
      case CHILD_UPDATED: {
        // 节点数据更新了
        ...
        break;
      }
      case CHILD_REMOVED: {
        // 节点删掉了
        ...
        break;
      }
    }
  }
}

时间: 2024-08-06 06:12:40

Curator框架的使用的相关文章

Zookeeper--(五)Curator框架

-------------------------------------------------------------------------------------------------------- 回调函数 如果为null的话表示节点不存在 -------------------------------------------------------------------------------------------------------- Cruator的监听

zookeeper 编程框架 curator

Curator框架提供了一套高级的API, 简化了ZooKeeper的操作. 它增加了很多使用ZooKeeper开发的特性,可以处理ZooKeeper集群复杂的连接管理和重试机制. 这些特性包括: 自动化的连接管理: 重新建立到ZooKeeper的连接和重试机制存在一些潜在的错误case. Curator帮助你处理这些事情,对你来说是透明的. 清爽API: 简化了原生的ZooKeeper的方法,事件等 提供了一个现代的流式接口 提供了Recipes实现: 如前面的文章介绍的那样,基于这些Reci

Curator的使用

Curator 为了更好的实现Java操作zookeeper服务器,后来出现了Curator框架,非常的强大,目前已经是Apache的顶级项目,里面提供了更多丰富的操作,例如session超时重连.主从选举.分布式计数器.分布式锁等等适用于各种复杂的zookeeper场景的API封装 1 Curator框架使用(一) Curator框架中使用链式编程风格,易读性更强,使用工厂方法创建连接对象. 1.使用CuratorFrameworkFactory的两个静态工厂方法(参数不同)来实现 1.1 c

分布式服务治理框架Dubbo

前言 Dubbo是一个被国内很多互联网公司广泛使用的开源分布式服务治理框架,是一个非常全面的SOA基础框架,当当网在Dubbo基础上新增了一些功能,并将其命名为Dubbox(Dubbo eXtensions). 为什么需要Dubbo? 以前所有的业务处理,都在一个系统当中: 接着,这个大系统按照业务领域划分为N个业务系统: 各个业务系统之间不可避免需要交互,采用什么呢?HTTP的方式?WebService?... 我们将面临很多URL的管理,服务之间的调用链,依赖关系,服务的负载均衡.监控等等

zookeeper学习笔记-zkclient,curator使用

开源客户端,原生api的不足 连接的创建是异步的,需要开发人员自行编码实现等待 连接没有自动的超时重连机制 Zk本身没提供序列化机制,需要开发人员自行指定,从而实现数据的序列化和反序列化 Watcher注册一次只会生效一次,需要不断的重复注册 Watcher的使用方式不符合java本身的术语,如果采用监听器方式,更容易理解 不支持递归创建树形节点 开源客户端---ZkClient介绍 Github上一个开源的zk客户端,由datameer的工程师Stefan Groschupf和Peter Vo

关于Curator学习过程问题

今天在学习Curator框架,查询了很多别人的例子照写都报错.然后上Curator(http://curator.apache.org/index.html)官网去看example,还是不行,一直报这个错.百思不得其解. <span style="font-size:24px;">18:08:45.069 [main] WARN o.a.c.retry.ExponentialBackoffRetry - maxRetries too large (2147483647).

curator 实现分布式一致性锁

最近准备在项目中引入分布式锁,故而研究基于zookeeper的curator框架. 网上资料不多,自己研究其源码发现,这个框架已经帮我做了很多现成的实现. 下面介绍下锁的实现: 通过源码中LockingExample例子作为切入(推荐多利用现有资源,最快切入),为减小篇幅,代码仅保留关键部分. curator已经为我们准备好了锁的实现 ----InterProcessMutex,基于zookeeper跨jvm的公平互斥锁实现. ----------------------------------

15. 使用Apache Curator管理ZooKeeper

Apache ZooKeeper是为了帮助解决复杂问题的软件工具,它可以帮助用户从复杂的实现中解救出来. 然而,ZooKeeper只暴露了原语,这取决于用户如何使用这些原语来解决应用程序中的协调问题. 社区已经在ZooKeeper数据模型及其API之上开发了高级框架. Apache Curator是一个高级的包装类库和框架,使得ZooKeeper非常简单易用. Tips Curator最初由Netflix开发,现在是一个Apache项目. 项目页面位于http://curator.apache.

Curator实现zookeeper分布式锁的基本原理

一.写在前面 之前写过一篇文章(<拜托,面试请不要再问我Redis分布式锁的实现原理>),给大家说了一下Redisson这个开源框架是如何实现Redis分布式锁原理的,这篇文章再给大家聊一下ZooKeeper实现分布式锁的原理. 同理,我是直接基于比较常用的Curator这个开源框架,聊一下这个框架对ZooKeeper(以下简称zk)分布式锁的实现. 一般除了大公司是自行封装分布式锁框架之外,建议大家用这些开源框架封装好的分布式锁实现,这是一个比较快捷省事儿的方式. 二.ZooKeeper分布