Zookeeper（44）如何在Zookeeper中创建节点？网站首页 学无止境

Zookeeper（44）如何在Zookeeper中创建节点？

辞暮尔尔-烟火年年 2025-08-07 12:01:04

简介Zookeeper（44）如何在Zookeeper中创建节点？

在 Apache Zookeeper 中创建节点可以通过 Zookeeper 的命令行客户端或使用 Zookeeper 的 Java API 来实现。以下是详细的步骤和代码示例，涵盖如何使用这些方法在 Zookeeper 中创建节点。

使用命令行客户端创建节点

启动 Zookeeper 客户端

首先，启动 Zookeeper 客户端工具 zkCli.sh。

cd /path/to/zookeeper
bin/zkCli.sh -server localhost:2181

创建节点

连接到 Zookeeper 服务器后，可以使用 create 命令创建一个新节点。例如，创建一个名为 /example 的节点，并设置其数据为 “Hello, Zookeeper!”。

create /example "Hello, Zookeeper!"

验证节点创建

使用 get 命令查看节点数据，验证节点是否已成功创建。

get /example

示例输出

[zk: localhost:2181(CONNECTED) 0] create /example "Hello, Zookeeper!"
Created /example
[zk: localhost:2181(CONNECTED) 1] get /example
Hello, Zookeeper!
cZxid = 0x100000000
ctime = Thu Jan 01 00:00:00 UTC 1970
mZxid = 0x100000000
mtime = Thu Jan 01 00:00:00 UTC 1970
pZxid = 0x100000000
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 16
numChildren = 0

使用 Java API 创建节点

以下是一个使用 Zookeeper 的 Java API 创建节点的详细示例。

添加 Maven 依赖

在 pom.xml 中添加 Zookeeper 的依赖：

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

示例代码

以下是一个使用 Java API 创建 Zookeeper 节点的示例代码：

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

public class ZookeeperCreateNodeExample {
    private static final String ZK_ADDRESS = "localhost:2181";
    private static final int SESSION_TIMEOUT = 3000;

    public static void main(String[] args) {
        try {
            // 创建 ZooKeeper 实例
            ZooKeeper zooKeeper = new ZooKeeper(ZK_ADDRESS, SESSION_TIMEOUT, new Watcher() {
                @Override
                public void process(WatchedEvent event) {
                    System.out.println("Received event: " + event);
                }
            });

            // 创建节点
            String path = "/example";
            String data = "Hello, Zookeeper!";
            createNode(zooKeeper, path, data);

            // 验证节点创建
            String nodeData = new String(zooKeeper.getData(path, false, null));
            System.out.println("Data of node " + path + ": " + nodeData);

            // 关闭连接
            zooKeeper.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void createNode(ZooKeeper zooKeeper, String path, String data) throws Exception {
        // 创建节点
        String createdPath = zooKeeper.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        System.out.println("Created node: " + createdPath);
    }
}

代码说明

ZooKeeper 类：用于与 Zookeeper 服务进行交互。
create 方法：用于创建节点。
- path：节点路径。
- data：节点数据。
- ZooDefs.Ids.OPEN_ACL_UNSAFE：节点的 ACL（访问控制列表）。
- CreateMode.PERSISTENT：节点的创建模式（持久节点）。
getData 方法：用于获取节点数据。

使用 Python 客户端创建节点

如果你更喜欢使用 Python，可以使用 kazoo 库来与 Zookeeper 交互。以下是一个使用 Python 创建节点的示例。

安装 Kazoo

使用 pip 安装 Kazoo 库：

pip install kazoo

示例代码

以下是使用 Kazoo 库创建 Zookeeper 节点的示例代码：

from kazoo.client import KazooClient

# 连接到 Zookeeper 服务器
zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()

# 创建节点
path = "/example"
data = b"Hello, Zookeeper!"
zk.create(path, data)

# 验证节点创建
node_data, stat = zk.get(path)
print(f"Data of node {path}: {node_data.decode('utf-8')}")

# 关闭连接
zk.stop()
zk.close()

总结

使用命令行客户端：
- 启动客户端：bin/zkCli.sh -server localhost:2181
- 创建节点：create /example "Hello, Zookeeper!"
- 验证节点创建：get /example
使用 Java API：
- 添加 Maven 依赖。
- 使用 ZooKeeper 类和 create 方法创建节点。
- 通过 getData 方法验证节点数据。
使用 Python 客户端：
- 安装 Kazoo 库：pip install kazoo
- 使用 KazooClient 类创建节点并验证节点数据。