ZooKeeper入门教程一：简介与核心概念

简介

ZooKeeper是一个分布式的解决方案，它可以用来管理和协调分布式应用程序。ZooKeeper可以用于实现诸如分布式锁、服务发现和集群管理等功能。ZooKeeper的设计目标是提供一个高性能、高可靠性、具备严格顺序性、支持分布式部署的专用协调服务。

核心概念

ZNode

ZNode是ZooKeeper的数据节点，它是ZooKeeper数据模型中最小的创建单元。每个ZNode节点都存储了一个以字节数组形式表示的数据内容，并且可以包含多个子ZNode节点。

Watch

Watch是ZooKeeper实现分布式通知的机制。客户端可以在ZNode上注册Watch事件，当ZNode的状态或数据发生变化时，ZooKeeper会将通知发送给客户端。Watch通知是一次性的，即一旦客户端收到了Watch通知，ZooKeeper将不会对Watch事件再次进行通知，因此客户端需要重新注册Watch事件。

节点类型

ZooKeeper中有三种类型的节点：

• 持久节点（PERSISTENT）：创建后即存在，直到手动删除为止。
• 持久顺序节点（PERSISTENT_SEQUENTIAL）：节点创建后随机分配一个编号作为节点名，即使节点本身被删除，编号也不会变化。
• 临时节点（EPHEMERAL）：临时性节点，当客户端连接断开时，节点被删除。
• 临时顺序节点（EPHEMERAL_SEQUENTIAL）：临时性顺序节点，节点的创建和删除都具有顺序号。

示例1

在此示例中，我们将创建一个名称为“/test”的ZNode，并向其添加一些数据。

import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;

public class ZooKeeperDemo {
   private static final String CONNECT_STRING = "localhost:2181";
   private static final int SESSION_TIMEOUT = 5000;

   public static void main(String[] args) throws Exception {
      ZooKeeper zk = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, null);

      // 创建一个持久节点
      zk.create("/test", "data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

      // 检查节点是否存在，并输出节点数据
      System.out.println(new String(zk.getData("/test", false, null)));

      // 关闭ZooKeeper连接
      zk.close();
   }
}

示例2

在此示例中，我们将向名称为“/test”的ZNode注册一个Watch事件，并在其中添加一些数据。

import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;

public class ZooKeeperDemo {
   private static final String CONNECT_STRING = "localhost:2181";
   private static final int SESSION_TIMEOUT = 5000;

   public static void main(String[] args) throws Exception {
      ZooKeeper zk = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, new Watcher() {
         @Override
         public void process(WatchedEvent event) {
            System.out.println("Event type: " + event.getType());
         }
      });

      // 创建一个持久节点
      zk.create("/test", "data".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

      // 注册Watch事件
      byte[] data = zk.getData("/test", new Watcher() {
         @Override
         public void process(WatchedEvent event) {
            System.out.println("Event type: " + event.getType());
         }
      }, null);

      // 输出节点数据
      System.out.println(new String(data));

      // 关闭ZooKeeper连接
      zk.close();
   }
}