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**是Apache ZooKeeper项目的一部分,它为Java开发者提供了便捷的方式来与ZooKeeper集群进行交互。ZooKeeper是一个分布式的、开放源码的服务,主要用于维护配置信息、命名服务、分布式同步和组...
Zookeeper Java API 使用指南 Zookeeper 是一个广泛使用的分布式协调服务,提供了高效、可靠、可扩展的解决方案。Java API 是 Zookeeper 的一个重要组件,提供了丰富的接口让开发者可以轻松地使用 Zookeeper。下面...
4. **数据操作**:Curator 提供了简单的 API 来读写 ZooKeeper 节点的数据,如 `create()`, `setData()`, `getData()` 等。例如,创建节点和设置数据: ```java client.create().creatingParentsIfNeeded().for...
ZooKeeper Java API编程实例分析 ZooKeeper Java API编程是 ZooKeeper 的一个重要组件,它提供了 Java 语言的 API 接口,让开发者可以使用 Java 语言编写 ZooKeeper 应用程序。下面我们将详细分析 ZooKeeper Java ...
**Zookeeper API(Java)入门详解** Zookeeper是一款分布式协调服务,由Apache基金会开发,它为分布式应用提供一致性服务,包括命名服务、配置管理、集群同步、分布式锁等。在Java开发中,我们通常会使用Zookeeper...
在IT行业中,Zookeeper和Java API的结合使用是分布式系统管理的重要组成部分。Zookeeper是由Apache软件基金会开发的一个开源项目,它提供了一种高效且可靠的分布式协调服务,常用于配置管理、命名服务、集群管理和...
zookeeper-api基础java案例.zipzookeeper-api基础java案例.zipzookeeper-api基础java案例.zipzookeeper-api基础java案例.zipzookeeper-api基础java案例.zipzookeeper-api基础java案例.zipzookeeper-api基础java案例....
在本文中,我们将深入理解Zookeeper的基本操作,包括通过shell客户端进行交互,以及使用Java API进行编程,并探讨其在实际应用中的示例。 一、Zookeeper Shell操作 1. 连接Zookeeper客户端:使用`zkCli.sh`命令...
Zookeeper Api(java)入门与应用 Zookeeper 作为一个分布式的服务框架,主要用来解决分布式集群中应用系统的一致性问题,它能提供基于类似于文件系统的目录节点树方式的数据存储,但是 Zookeeper 并不是用来专门存储...
在Java开发中,我们通常使用三种方式来操作Zookeeper:原生API、zkClient和Curator。接下来,我们将详细探讨这三种方式。 **一、Zookeeper原生API** Zookeeper提供了Java API,可以直接与Zookeeper服务器进行交互...
在Java环境中,ZooKeeper提供了一套丰富的API,使得开发者能够方便地进行节点操作和Watch机制的使用。本篇文章将深入探讨如何使用Java API在ZooKeeper中进行节点的操作,并介绍Watch观察者的应用。 1. **ZooKeeper...
它的客户端API是开发者与ZooKeeper交互的主要接口,提供了丰富的功能,包括数据节点的创建、删除、更新、读取,以及监控事件的订阅等。本文将深入探讨ZooKeeper客户端API的使用方法和核心概念。 ### 1. 连接...
2. **Zookeeper Java API**:Apache ZooKeeper提供了Java API供开发者进行编程,用于实现分布式服务管理。在Java项目中,我们通常通过Maven或者Gradle来引入Zookeeper的依赖,如上述代码所示引入的是`org.apache....
Java提供了ZooKeeper的API,使得我们可以方便地进行节点的创建、读取、更新和删除操作。`01_zookeeper介绍和应用场景.docx`、`02_使用java操作zookeeper创建节点.docx`、`03_使用java操作zk创建节点02.docx`这些文档...
ZooKeeper API是开发者与ZooKeeper交互的主要方式,它提供了丰富的Java客户端接口,使得开发者能够方便地进行数据的读写、监控节点变化、创建和删除节点等操作。以下是一些关键的ZooKeeper API知识点: 1. **连接与...
ZooKeeper Java API 是一套用于与ZooKeeper交互的接口,它允许开发者在Java应用程序中实现对ZooKeeper集群的创建、删除、查看、设置和权限管理等操作。ZooKeeper是一个分布式的协调服务,广泛应用于分布式系统中,如...
本文将深入探讨如何使用Java客户端API来对Zookeeper的Znode进行增删改查操作,并讨论同步与异步两种方式的使用。 首先,要使用Java客户端API访问Zookeeper,你需要引入相关的依赖。在Maven项目中,可以在pom.xml...
4. **slf4j-api.jar**:Simple Logging Facade for Java,它提供一个简单的API,使得最终用户可以在部署时插入所需的日志库,比如log4j。SLF4J允许在部署时选择不同的日志实现,提高了灵活性。 5. **slf4j-log4j12....
使用JMX监控Zookeeper状态Java API 在分布式系统中,Zookeeper是经常使用的分布式协调服务,用于维护和管理分布式应用程序的配置信息和状态。为了监控Zookeeper的状态,需要使用监控工具来实时监控Zookeeper的运行...