Zookeeper JAVA API
/* * ZookeeperTest.java */ package com.x.zookeeper; import java.io.IOException; import java.util.List; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.ZooDefs.Ids; import org.apache.zookeeper.data.Stat; import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * * @author http://blog.csdn.net/java2000_wl * @version <b>1.0</b> */ public class ZookeeperTest { private static final int SESSION_TIMEOUT = 30000; public static final Logger LOGGER = LoggerFactory.getLogger(ZookeeperTest.class); private Watcher watcher = new Watcher() { public void process(WatchedEvent event) { LOGGER.info("process : " + event.getType()); } }; private ZooKeeper zooKeeper; /** * 连接zookeeper * <br>------------------------------<br> * @throws IOException */ @Before public void connect() throws IOException { zooKeeper = new ZooKeeper("localhost:2181,localhost:2182,localhost:2183", SESSION_TIMEOUT, watcher); } /** * 关闭连接 * <br>------------------------------<br> */ @After public void close() { try { zooKeeper.close(); } catch (InterruptedException e) { e.printStackTrace(); } } /** * 创建一个znode * 1.CreateMode 取值 * PERSISTENT:持久化,这个目录节点存储的数据不会丢失 * PERSISTENT_SEQUENTIAL:顺序自动编号的目录节点,这种目录节点会根据当前已近存在的节点数自动加 1,然后返回给客户端已经成功创建的目录节点名; * EPHEMERAL:临时目录节点,一旦创建这个节点的客户端与服务器端口也就是 session过期超时,这种节点会被自动删除 * EPHEMERAL_SEQUENTIAL:临时自动编号节点 * <br>------------------------------<br> */ @Test public void testCreate() { String result = null; try { result = zooKeeper.create("/zk001", "zk001data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } LOGGER.info("create result : {}", result); } /** * 删除节点 忽略版本 * <br>------------------------------<br> */ @Test public void testDelete() { try { zooKeeper.delete("/zk001", -1); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } } /** * 获取数据 * <br>------------------------------<br> */ @Test public void testGetData() { String result = null; try { byte[] bytes = zooKeeper.getData("/zk001", null, null); result = new String(bytes); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } LOGGER.info("getdata result : {}", result); } /** * 获取数据 设置watch * <br>------------------------------<br> */ @Test public void testGetDataWatch() { String result = null; try { byte[] bytes = zooKeeper.getData("/zk001", new Watcher() { public void process(WatchedEvent event) { LOGGER.info("testGetDataWatch watch : {}", event.getType()); } }, null); result = new String(bytes); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } LOGGER.info("getdata result : {}", result); // 触发wacth NodeDataChanged try { zooKeeper.setData("/zk001", "testSetData".getBytes(), -1); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } } /** * 判断节点是否存在 * 设置是否监控这个目录节点,这里的 watcher 是在创建 ZooKeeper实例时指定的 watcher * <br>------------------------------<br> */ @Test public void testExists() { Stat stat = null; try { stat = zooKeeper.exists("/zk001", false); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } Assert.assertNotNull(stat); LOGGER.info("exists result : {}", stat.getCzxid()); } /** * 设置对应znode下的数据 , -1表示匹配所有版本 * <br>------------------------------<br> */ @Test public void testSetData() { Stat stat = null; try { stat = zooKeeper.setData("/zk001", "testSetData".getBytes(), -1); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } Assert.assertNotNull(stat); LOGGER.info("exists result : {}", stat.getVersion()); } /** * 判断节点是否存在, * 设置是否监控这个目录节点,这里的 watcher 是在创建 ZooKeeper实例时指定的 watcher * <br>------------------------------<br> */ @Test public void testExistsWatch1() { Stat stat = null; try { stat = zooKeeper.exists("/zk001", true); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } Assert.assertNotNull(stat); try { zooKeeper.delete("/zk001", -1); } catch (Exception e) { e.printStackTrace(); } } /** * 判断节点是否存在, * 设置监控这个目录节点的 Watcher * <br>------------------------------<br> */ @Test public void testExistsWatch2() { Stat stat = null; try { stat = zooKeeper.exists("/zk002", new Watcher() { @Override public void process(WatchedEvent event) { LOGGER.info("testExistsWatch2 watch : {}", event.getType()); } }); } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } Assert.assertNotNull(stat); // 触发watch 中的process方法 NodeDataChanged try { zooKeeper.setData("/zk002", "testExistsWatch2".getBytes(), -1); } catch (Exception e) { e.printStackTrace(); } // 不会触发watch 只会触发一次 try { zooKeeper.delete("/zk002", -1); } catch (Exception e) { e.printStackTrace(); } } /** * 获取指定节点下的子节点 * <br>------------------------------<br> */ @Test public void testGetChild() { try { zooKeeper.create("/zk/001", "001".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); zooKeeper.create("/zk/002", "002".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); List<String> list = zooKeeper.getChildren("/zk", true); for (String node : list) { LOGGER.info("node {}", node); } } catch (Exception e) { LOGGER.error(e.getMessage()); Assert.fail(); } } }
相关推荐
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”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...