续前话,Zookeeper的环境已经搭建好了.接下来就是利用Java实现与zookeeper的连接,达到和ZOOKEEPER_HOME\bin\zkCli.sh中的部分基础功能.
具体的zookeeper的安装见
ZooKeeper起步配置.
import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.KeeperState;
/**
* @author ruodao
* @since 1.0
* 2010-2-18 下午08:57:36
*/
public class AbstractZooKeeper implements Watcher {
private static final int SESSION_TIME = 2000;
protected ZooKeeper zooKeeper;
protected CountDownLatch countDownLatch = new CountDownLatch(1);
public void connect(String hosts) throws IOException, InterruptedException{
zooKeeper = new ZooKeeper(hosts,SESSION_TIME,this);
countDownLatch.await();
}
public void process(WatchedEvent event) {
if(event.getState() == KeeperState.SyncConnected){
countDownLatch.countDown();
}
}
public void close() throws InterruptedException{
zooKeeper.close();
}
}
下面一段代码实现了简单的操作,添加,获取数据,获取子节点.
import java.util.Arrays;
import java.util.List;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs.Ids;
/**
* @author ruodao
* @since 1.0
* 2010-2-18 下午09:03:21
*/
public class ZooKeeperOperator extends AbstractZooKeeper {
/**
* 创建持久态的znode,比支持多层创建.比如在创建/parent/child的情况下,无/parent.无法通过.
* @param path eg: /parent/child1
* @param data
* @throws InterruptedException
* @throws KeeperException
*/
public void create(String path,byte[] data) throws KeeperException, InterruptedException{
this.zooKeeper.create(path, data, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT/*此处创建的为持久态的节点,可为瞬态*/);
}
/**
* 获取节点的孩子信息
* @param path
* @throws KeeperException
* @throws InterruptedException
*/
public void getChild(String path) throws KeeperException, InterruptedException{
try {
List<String> children = this.zooKeeper.getChildren(path, false);
if (children.isEmpty()) {
System.out.printf("没有节点在%s中.", path);
return;
}else{
System.out.printf("节点%s中存在的节点:\n", path);
for(String child: children){
System.out.println(child);
}
}
} catch (KeeperException.NoNodeException e) {
System.out.printf("%s节点不存在.", path);
throw e;
}
}
public byte[] getData(String path) throws KeeperException, InterruptedException {
return this.zooKeeper.getData(path, false,null);
}
}
main函数
public static void main(String[] args) {
try {
ZooKeeperOperator zkoperator = new ZooKeeperOperator();
zkoperator.connect("192.168.0.115");
byte[] data = new byte[]{'d','a','t','a'};
zkoperator.create("/root",null);
System.out.println(Arrays.toString(zkoperator.getData("/root")));
zkoperator.create("/root/child1",data);
System.out.println(Arrays.toString(zkoperator.getData("/root/child1")));
zkoperator.create("/root/child2",data);
System.out.println(Arrays.toString(zkoperator.getData("/root/child2")));
System.out.println("节点孩子信息:");
zkoperator.getChild("/root");
zkoperator.close();
} catch (Exception e) {
e.printStackTrace();
}
}
到这里,一个简单的程序已经可以运行了.以下是linux上的截图.
- 大小: 109 KB
分享到:
相关推荐
zookeeper Java api - curator 5.6.0
NULL 博文链接:https://rd-030.iteye.com/blog/2299803
zookeeper java的API开发文档,里面的内容十分详细,对于想了解zookeeper的API是十分有帮助的呢
本文主要通过实例给大家详细分析了ZooKeeper用JAVA实现API编程的知识要点。
5、zookeeper的java -Curator(服务注册与发现)...该示例会涉及到本专栏下的其他文章,比如:4、zookeeper的java三种客户端介绍-Curator(crud、事务操作、监听、分布式计数器、分布式锁) 等文章,都是在该专栏下的。
Zookeeper对java支持的原生API,Zookeeper版本:3.4.10
实验十 Zookeeper Java API编程 82 第四章 分布式离线计算框架MapReduce 85 实验十一 MapReduce单词计数 85 实验十二 MapReduce数据去重 94 实验十三 MapReduce单表关联 103 第五章 统一资源管理系统YARN 114 实验十...
java开发
官方源码不含API的java doc,自行抽取制作的CHM,针对3.3.2版本
今天小编就为大家分享一篇关于使用JMX监控Zookeeper状态Java API,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
java客户端使用api访问zookeeper,增删改查Znode,多有的操作都有同步和异步的方式,代码简单,易懂
zookeeper节点三种方式监控,第一种实现zookeeper原生API进行监控操作,第二种实现zkclient进行监控 ,第三种实现curator进行监控。程序中包含使用的jar,在eclipse下可直接运行。希望对您有所帮助。
NULL 博文链接:https://zhaoshijie.iteye.com/blog/2175835
ZooKeeper包含一个简单的原语集,提供Java和C的接口。 如果文件打开看不到右边的内容,是因为你的操作系统为了安全对下载的chm文件进行了锁定,只需要在打开前右键单击该chm文件选择“属性”,然后在“常规”选项卡...
zookeeper java api 创建,删除,查看,设置,权限,是否存在
12.zookeeper的java户端api基本功能操作示范.mp4
标签:apache、zookeeper、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心...
简单、高效的Zookeeper Java客户端。 让Zookeeper API 使用起来更简单 非常方便订阅各种事件并自动重新绑定事件(会话建立、节点修改、节点删除、子节点变更等) session过期自动重连、机制 快速入门 下面部分...
标签:apache、zookeeper、jar包、java、API文档、中文版; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...