ZNode 学习指南
1. ZNode 基本概念
- 什么是 ZNode：ZNode 是 Zookeeper 中的数据节点。它类似于文件系统中的文件和目录，ZNode 既可以保存数据又可以作为其他 ZNode 的父节点。
- ZNode 的路径：每个 ZNode 在 Zookeeper 命名空间中都有一个唯一的路径，如
/app1/config。
2. ZNode 类型
- 持久节点 (Persistent ZNode)：当创建持久节点时，即使客户端断开连接或会话结束，节点也会一直存在，直到被明确删除。
- 临时节点 (Ephemeral ZNode)：临时节点在创建客户端会话断开或会话过期时自动删除。
- 顺序节点 (Sequential ZNode)：当创建顺序节点时，Zookeeper 会在节点名称末尾附加一个递增的数字，确保节点名称的唯一性。
- 持久顺序节点和临时顺序节点：持久顺序节点和临时顺序节点分别是持久节点和临时节点的顺序变体。
3. ZNode 的操作
- 创建 ZNode：使用
create 命令可以创建 ZNode，可以指定节点类型（持久、临时、顺序）。 - 读取 ZNode 数据：使用
get 命令可以读取 ZNode 的数据和状态。 - 更新 ZNode 数据：使用
set 命令可以更新 ZNode 的数据。 - 删除 ZNode：使用
delete 命令可以删除指定的 ZNode。
4. ZNode 版本控制
- 数据版本：每个 ZNode 都有一个版本号，每次更新节点数据时，版本号递增。
- 条件更新：可以使用版本号确保数据的一致性，只有在当前版本号与指定版本号匹配时，更新才会成功。
5. Watcher 机制
- Watcher 简介：Watcher 是一种触发器，可以在 ZNode 的数据或状态变化时通知客户端。Watchers 是一次性的，一旦触发，必须重新设置。
- 设置 Watcher：在读取或获取 ZNode 数据时，可以设置 Watcher。例如，使用
getData 命令时可以设置 Watcher。 - Watcher 通知：当 ZNode 数据或状态发生变化时，Zookeeper 会向设置了 Watcher 的客户端发送通知。
6. ZNode 的 ACL（访问控制列表）
- ACL 概述：ZNode 可以通过 ACL 进行访问控制，ACL 由一组权限组成，如读取、写入、创建、删除、管理。
- 设置 ACL：在创建 ZNode 时可以设置 ACL，也可以通过
setACL 命令修改 ACL。 - 检查 ACL：通过
getACL 命令可以查看 ZNode 的 ACL 配置。
示例操作
创建持久节点
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs.Ids;public class CreateZNode {private static ZooKeeper zk;private static ZookeeperConnection conn;public static void create(String path, byte[] data) throws Exception {zk.create(path, data, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);}public static void main(String[] args) throws Exception {String path = "/sampleZNode";byte[] data = "Sample Data".getBytes();conn = new ZookeeperConnection();zk = conn.connect("localhost");create(path, data);conn.close();}
}
获取 ZNode 数据
import org.apache.zookeeper.ZooKeeper;public class GetZNodeData {private static ZooKeeper zk;private static ZookeeperConnection conn;public static byte[] getData(String path) throws Exception {return zk.getData(path, false, null);}public static void main(String[] args) throws Exception {String path = "/sampleZNode";conn = new ZookeeperConnection();zk = conn.connect("localhost");byte[] data = getData(path);System.out.println(new String(data));conn.close();}
}
更新 ZNode 数据
import org.apache.zookeeper.ZooKeeper;public class UpdateZNodeData {private static ZooKeeper zk;private static
