java操作Zookeeper

浅浅的花香味﹌ 2021-10-16 00:46 340阅读 0赞

# 介绍 #

Zookeeper是一种作用于分布式应用高性能的调度服务。在zookeeper中提供了原生的API可以供我们开发使用，zookeeper官方的API文档网址：http://zookeeper.apache.org/doc/r3.4.11/api/index.html

# 环境 #

创建一个Maven项目

pom.xml添加依赖

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

# 操作 #

### 连接zookeeper ###

public void connectZookeeper(String host) throws Exception{
          ZooKeeper zooKeeper = new ZooKeeper("172.0.0.1:2181", 5000, watcher);
          countDownLatch.await();
          System.out.println("zookeeper connection success");
    }

### 创建节点 ###

private void createNodeSync() throws KeeperException, InterruptedException {
        String path = "/poype_node";
        String nodePath = zooKeeper.create(path, "123".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        System.out.println(nodePath);
    }

### 获取路径下的所有子节点 ###

private void getChildrenSync() throws KeeperException, InterruptedException {
        List<String> childrenNode = zooKeeper.getChildren("/",true);
        for(String child : childrenNode) {
            System.out.println(child);
        }
    }

### 获取节点数据 ###

private void getDataSync() throws KeeperException, InterruptedException {
        Stat stat = new Stat();
        // getData的返回值是该节点的数据值，节点的状态信息会赋值给stat对象
        byte[] data = zooKeeper.getData("/node_1",true, stat);
        System.out.println(new String(data));
        System.out.println(stat);
    }

### 查看节点是否存在 ###

private void existSync() throws KeeperException, InterruptedException {
        Stat stat = zooKeeper.exists("/poype_node2", true);
        System.out.println(stat);
    }

### 修改节点内容 ###

private void setDataSync() throws KeeperException, InterruptedException {
        Stat stat = zooKeeper.setData("/poype_node2", "poype5211314".getBytes(), 1);
        System.out.println(stat);
    }

### 删除节点 ###

private void deleteSync() throws KeeperException, InterruptedException {
        zooKeeper.delete("/node_1", -1);
    }

### 关闭连接 ###

public void closeConnection() throws InterruptedException{
          if (zookeeper != null) {
             zookeeper.close();
          }
       }