黑马程序员技术交流社区

标题: 【郑州校区】大数据基础加强阶段2之ZooKeeper Java API [打印本页]

---

作者: 我是楠楠    时间: 2018-9-25 14:21
标题: 【郑州校区】大数据基础加强阶段2之ZooKeeper Java API

【郑州校区】大数据基础加强阶段2之ZooKeeper Java API

org.apache.zookeeper.Zookeeper

Zookeeper 是在 Java 中客户端主类，负责建立与 zookeeper 集群的会话， 并提供方法进行操作。

org.apache.zookeeper.Watcher

Watcher 接口表示一个标准的事件处理器，其定义了事件通知相关的逻辑， 包含 KeeperState 和 EventType 两个枚举类，分别代表了通知状态和事件类型， 同时定义了事件的回调方法：process（WatchedEvent event）。

process 方法是 Watcher 接口中的一个回调方法，当 ZooKeeper 向客户端发送一个 Watcher 事件通知时，客户端就会对相应的 process 方法进行回调，从而实现对事件的处理。

5.1 ． 基本使用

建立 java maven 项目,引入 maven pom 坐标。

<dependency>

    <groupId>org.apache.zookeeper</groupId>

    <artifactId>zookeeper</artifactId>

    <version>3.4.9</version>

</dependency>

5.2 ． 更多操作示例

public static void main(String[] args) throws Exception {

        // 初始化 ZooKeeper 实例(zk 地址、会话超时时间，与系统默认一致、watcher)

        ZooKeeper zk = new ZooKeeper("node-21:2181,node-22:2181", 30000, new Watcher() {

            @Override

            public void process(WatchedEvent event) {

                System.out.println("事件类型为：" + event.getType());

                System.out.println("事件发生的路径：" + event.getPath());

                System.out.println("通知状态为：" +event.getState());

            }

        });

    // 创建一个目录节点

zk.create("/testRootPath", "testRootData".getBytes(), Ids.OPEN_ACL_UNSAFE,

   CreateMode.PERSISTENT);  

// 创建一个子目录节点

zk.create("/testRootPath/testChildPathOne", "testChildDataOne".getBytes(),

   Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);  

System.out.println(new String(zk.getData("/testRootPath",false,null)));  

// 取出子目录节点列表

System.out.println(zk.getChildren("/testRootPath",true));  

// 修改子目录节点数据

zk.setData("/testRootPath/testChildPathOne","modifyChildDataOne".getBytes(),-1);  

System.out.println("目录节点状态：["+zk.exists("/testRootPath",true)+"]");  

// 创建另外一个子目录节点

zk.create("/testRootPath/testChildPathTwo", "testChildDataTwo".getBytes(),  

   Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);  

System.out.println(new String(zk.getData("/testRootPath/testChildPathTwo",true,null)));  

// 删除子目录节点

zk.delete("/testRootPath/testChildPathTwo",-1);  

zk.delete("/testRootPath/testChildPathOne",-1);  

// 删除父目录节点

zk.delete("/testRootPath",-1);

zk.close();

}

传智播客·黑马程序员郑州校区地址

河南省郑州市 高新区长椿路11号大学科技园（西区）东门8号楼三层

联系电话 0371-56061160/61/62

来校路线  地铁一号线梧桐街站A口出

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2