ZooKeeper Java 简单应用

下面将介绍怎样使用 Java 直接操作 Zookeeper,具体步骤如下:

(1)添加 Maven 依赖

(2)使用 Zookeeper API 操作节点

添加 Maven 依赖

使用 IDEA 创建一个 Maven 项目,在 pom.xml 中添加如下依赖:

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.13</version>
</dependency>

示例代码

下面是 Java 代码,后续章节将详细介绍各个 API 的作用,这里仅仅演示如何通过 API 简单操作 zookeeper。代码如下:

package com.hxstrive.zookeeper;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

/**
* 第一个 Zookeeper 示例
* @author hxstrive.com
*/
public class ZookeeperSimple {

   public static void main(String[] args) throws Exception {
       // 1.创建 zookeeper 连接
       ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181", 2000, new Watcher() {
           public void process(WatchedEvent watchedEvent) {
               System.out.println("触发了 " + watchedEvent.getType() + " 事件");
           }
       });

       // 2.创建节点
       String path = zooKeeper.create("/hello", "hello world".getBytes(),
               ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
       System.out.println("节点路径:" + path);

       // 3.获取节点的值
       byte[] bytes = zooKeeper.getData("/hello", false, new Stat());
       System.out.println(new String(bytes));
   }

}

运行示例,输出如下:

触发了 None 事件
节点路径:/hello
hello world

查看 zookeeper 节点信息,如下图:

ZooKeeper Java 简单应用

说说我的看法
全部评论(
没有评论
关于
本网站属于个人的非赢利性网站,转载的文章遵循原作者的版权声明,如果原文没有版权声明,请来信告知:hxstrive@outlook.com
公众号