乐鱼电竞

教育行业A股IPO第一股（股票代码 003032）

全国咨询/投诉热线：400-618-4000

学好Zookeeper Java API是大数据基础加强的必修

更新时间:2018年11月16日15时25分 来源:乐鱼播客 浏览次数:

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();
}

作者：乐鱼播客云计算大数据培训学院
首发：http://cloud.itcast.cn/
0 分享到：
和我们在线交谈！
【网站地图】【sitemap】