Java如何操作Zookeeper

这篇文章主要为大家展示了Java如何操作Zookeeper，内容简而易懂，希望大家可以学习一下，学习完之后肯定会有收获的，下面让小编带大家一起来看看吧。

创新互联公司基于成都重庆香港及美国等地区分布式IDC机房数据中心构建的电信大带宽，联通大带宽，移动大带宽，多线BGP大带宽租用,是为众多客户提供专业服务器托管报价，主机托管价格性价比高，为金融证券行业温江服务器租用，ai人工智能服务器托管提供bgp线路100M独享，G口带宽及机柜租用的专业成都idc公司。

ZooKeeper 是一个典型的分布式数据一致性解决方案，分布式应用程序可以基于 ZooKeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列等功能。

Zookeeper 一个最常用的使用场景就是用于担任服务生产者和服务消费者的注册中心。服务生产者将自己提供的服务注册到Zookeeper中心，服务的消费者在进行服务调用的时候先到Zookeeper中查找服务，获取到服务生产者的详细信息之后，再去调用服务生产者的内容与数据。如下图所示，在 Dubbo架构中 Zookeeper 就担任了注册中心这一角色。

maven依赖


  org.apache.zookeeper
  zookeeper
  3.6.0

程序其它依赖：



  org.apache.logging.log4j
  log4j-core
  2.11.2



  org.apache.logging.log4j
  log4j-1.2-api
  2.11.2



  org.apache.logging.log4j
  log4j-slf4j-impl
  2.11.2



  org.apache.zookeeper
  zookeeper
  3.6.0
  
    
      org.slf4j
      slf4j-log4j12

API操作代码：

package com.zhi.test;

import java.util.List;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.MethodOrderer;
import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestInstance.Lifecycle;
import org.junit.jupiter.api.TestMethodOrder;

/**
 * Zookeeper操作测试
 * 
 * @author 张远志
 * @since 2020年5月3日14:31:28
 *
 */
@TestInstance(Lifecycle.PER_CLASS)
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
public class ZookeeperTest {
  private final Logger logger = LogManager.getLogger(this.getClass());
  private ZooKeeper zooKeeper;
  private final String path = "/test";

  @BeforeAll
  public void init() throws Exception {
    zooKeeper = new ZooKeeper("192.168.59.131:2181", 60000, new Watcher() {
      public void process(WatchedEvent event) {
        logger.info("事件类型：{}，路径：{}", event.getType(), event.getPath());
      }
    });
  }

  /**
   * 添加数据，当路径已经存在时会报错，初始版本号为0。第三个参数是权限控制。 

   * 第四个参数，CreateMode：
   * PERSISTENT：持久化保存
   * 
PERSISTENT_SEQUENTIAL：持久化保存，并且路径附加一个自动增长的序号
   * 
EPHEMERAL：临时数据，客户端断开连接时自动删除数据（dubbo就是采用这种机制）
   * 
EPHEMERAL_SEQUENTIAL：客户端断开连接时自动删除数据，并且路径会附加一个自动增长的序号
   * 
CONTAINER：
   * 
PERSISTENT_WITH_TTL：客户端断开连接时自动删除数据，当节点在指定时间没有被修改且没有子目录时，数据会被删除
   * 
PERSISTENT_SEQUENTIAL_WITH_TTL：客户端断开连接时自动删除数据，路径会附加一个自动增长的序号，且当节点在指定时间没有被修改且没有子目录时，数据会被删除
   */
  @Order(1)
  @Test
  public void create() {
    try {
      String back = zooKeeper.create(path, "这是一个测试".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
      logger.info("添加一条数据成功，实际路径：{}", back);
    } catch (Exception e) {
      logger.error("调用create出错", e);
    }
  }

  /**
   * 判断路径是否存在，不存在时返回null
   */
  @Order(2)
  @Test
  public void exists() {
    try {
      Stat stat = zooKeeper.exists(path, false);
      logger.info("路径为{}的节点{}存在", path, stat == null ? "不" : "");
    } catch (Exception e) {
      logger.error("调用exists出错", e);
    }
  }

  /**
   * 查询数据，路径不存在时会报错
   */
  @Order(3)
  @Test
  public void find() {
    try {
      byte[] bits = zooKeeper.getData(path, false, new Stat()); // 路径不存在时会报错
      String data = new String(bits);
      logger.info("路径{}查询到数据：{}", path, data);
    } catch (Exception e) {
      logger.error("调用getData出错", e);
    }
  }

  /**
   * 获取子目录，结果为空时返回一个长度为0的ArrayList
   */
  @Order(3)
  @Test
  public void children() {
    try {
      List list = zooKeeper.getChildren(path, false);
      logger.info("路径{}的子目录有：{}", path, String.join("、", list.toArray(new String[0])));
    } catch (Exception e) {
      logger.error("调用getChildren出错", e);
    }
  }

  /**
   * 修改数据，路径不存在时会报错，版本号与存储中不一致时也报错
   */
  @Order(4)
  @Test
  public void udpate() {
    try {
      Stat stat = zooKeeper.exists(path, false);
      if (stat != null) {
        stat = zooKeeper.setData(path, "这是一个修改测试".getBytes(), stat.getVersion()); // 版本号为-1时不做版本校验
        logger.info("数据修改成功，原版本号：{}，新版本号：{}", stat.getAversion(), stat.getVersion());
      }
    } catch (Exception e) {
      logger.error("调用setData出错", e);
    }
  }

  /**
   * 删除节点，路径不存在时报错，版本号不一致时也会报错
   */
  @Order(5)
  @Test
  public void delete() {
    try {
      zooKeeper.delete(path, -1); // -1表示不做版本校验
      logger.info("根据path删除数据成功");
    } catch (Exception e) {
      logger.error("调用delete出错", e);
    }
  }

  @AfterAll
  public void destory() throws Exception {
    if (zooKeeper != null) {
      zooKeeper.close();
    }
  }
}

以上就是关于Java如何操作Zookeeper的内容，如果你们有学习到知识或者技能，可以把它分享出去让更多的人看到。

当前名称：Java如何操作Zookeeper
当前URL：http://myzitong.com/article/pchghd.html

Java如何操作Zookeeper

其他资讯