文档章节

Curator Framework

蘑菇头老大
 蘑菇头老大
发布于 2014/08/01 13:13
字数 125
阅读 136
收藏 0

3 月,跳不动了?>>>

Framework 比较简单,就是一些CRUD,Watch :

package curator.framework;

import java.util.List;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

public class FrameworkDemo {

	public static void main(String[] args) {
		connection1();
	}

	private static void connection1() {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		CuratorFramework client = CuratorFrameworkFactory.builder()
				.connectString("127.0.0.1:2181")
				.sessionTimeoutMs(5000)
				.connectionTimeoutMs(10000)
				.retryPolicy(retryPolicy)
				.namespace("text").build();
		client.start();
		try {
			byte[] b = null;
			// 创建
			client.create().withMode(CreateMode.EPHEMERAL).forPath("/xx",new String("").getBytes());
			// 得到值
			client.getData().forPath("");
			// 得到子节点 List<String>
			List<String> ls = client.getChildren().forPath("");
			// 删除
			client.delete().forPath("");
			// 修改
			client.setData().forPath("", b);
		} catch (Exception e) {
		}
		client.close();
	}

	private static void connection2() {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retryPolicy);
		client.start();
		client.close();
	}
	
	
	
}

 

 

© 著作权归作者所有

上一篇: Curator counters
下一篇: Curator selector
蘑菇头老大
粉丝 2
博文 20
码字总数 7628
作品 0
杭州
私信 提问
加载中

评论(0)

跟着实例学习ZooKeeper的用法: Curator扩展库

还记得Curator提供哪几个组件吗? 我们不妨回顾一下: Recipes Framework Utilities Client Errors Extensions 前面的例子其实前五个组件都涉及到了, 比如Utilities例子的TestServer, Clien...

longbadx
2015/02/11
2.2K
0
storm 本地模式启动时 zookeeper抛异常

18:42:41.083 [SyncThread:0] DEBUG o.a.z.server.FinalRequestProcessor - Processing request:: sessionid:0x16078aaf41a0005 type:create cxid:0x2f zxid:0x22 txntype:-1 reqpath:n/a 18......

java菜鸟2016
2017/12/21
1K
1
Apache Curator 2.10.0 和 3.1.0 发布

Apache Curator 今天发布两个新版本,分别是 2.10.0 和 3.1.0 。 其中 2.10.0 改进内容: Bug [CURATOR-208] - InterProcessSemaphoreV2 swallows InterruptedException [CURATOR-209] - Ba......

红薯
2016/02/15
4K
0
Apache Curator Zookeeper客户端

Curator是Netflix公司开源的一个Zookeeper客户端,与Zookeeper提供的原生客户端相比,Curator的抽象层次更高,简化了Zookeeper客户端的开发量。 1.Zookeeper安装部署 Zookeeper的部署很简单,...

laigous
2017/03/02
162
0
Apache Curator 4.3.0 发布,ZooKeeper 简化服务

Apache Curator 4.3.0 发布了。Apache Curator 是用于 Apache ZooKeeper 的 Java / JVM 客户端库,是一个分布式协调服务。 Apache Curator 内置高级 API 框架和实用程序,可使 Apache ZooKe...

xplanet
03/03
1.5K
1

没有更多内容

加载失败,请刷新页面

加载更多

mapbox

Mapbox是一个可以跨行业使用的开发平台,我们可以利用它对地图进行创建和定制,以解决地图、数据和空间分析等问题。 Leaflet 轻量 WebGIS 前端类库 Leaflet 是一个为建设移动设备友好的互动地...

东东笔记
31分钟前
32
0
看你有多色游戏案例

看你有多色游戏案例 游戏规则 这款游戏的玩法就是找出所有风格中颜色比较淡的,随着游戏进行后面的方块会越来越多, 这个游戏主要是考验玩家的眼力和注意力, 游戏截图 部分代码 mian.html ...

板栗z丶
今天
27
0
【SpringBoot MQ 系列】RabbitListener 消费基本使用姿势介绍

【MQ 系列】RabbitListener 消费基本使用姿势介绍 之前介绍了 rabbitmq 的消息发送姿势,既然有发送,当然就得有消费者,在 SpringBoot 环境下,消费可以说比较简单了,借助@RabbitListener...

小灰灰Blog
今天
29
0
罗永浩回应做主播带货赚钱还债:主播赚的不是脏钱

  罗永浩的抖音带货生涯,将于 4 月 1 日晚 20 点开始。   虽然老罗对自己带货能力,信心满满,但也有粉丝对其表达了对他直播带货感到失望。   今日,罗永浩发布微博回应称, 不应该感...

水果黄瓜
今天
18
0
二维码传输文件

这是我大概在5,6年前写的东西,当时种种原因,删除了,现在有空闲时间,补发一下。 二维码是现在非常常用的一种信息传播载体,通过智能手机,可以方便快捷的传输小容量信息,是否可以通过二...

豆豆爹地
今天
20
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部