在项目src 文件夹下创建cn. itcast.zookeeper 包，在这里创建 ZookeeperTest. java 文件。我们通过创建节点、获取节点、修改节点、判断节点是否仔在以及删除节点等方法來操作zookeeper。具体实现代码

在Java中，为了在项目`src`文件夹下创建`cn.itcast.zookeeper`包并添加`ZookeeperTest.java`文件，首先你需要在`src`目录结构中找到合适的路径。如果`src`是一个Java源码目录，通常是按照包名的层次结构来组织的。假设你已经在`src/main/java`或直接在`src`下有`java`目录。

下面是一步一步的创建步骤：

1. **创建包**:
- 打开`src/main/java`（或`java`目录），如果还没有，需要手动创建。
- 创建一个名为`cn`的新目录，然后在其中创建一个名为`itcast`的目录，再在这个目录下创建一个名为`zookeeper`的目录。完整的路径可能是`src/main/java/cn/itcast/zookeeper`。

2. **创建`ZookeeperTest.java`文件**:
- 在`zookeeper`目录下右键单击，选择"New" -> "Java Class"，输入类名`ZookeeperTest`。记得加上`.java`扩展名，如`ZookeeperTest.java`。

以下是`ZookeeperTest.java`的基本框架，用于操作Zookeeper：

package cn.itcast.zookeeper;

import org.apache.zookeeper.*;

public class ZookeeperTest {
    private ZooKeeper zookeeper;
    
    // 初始化Zookeeper连接
    public void initZookeeper(String serverList) throws IOException, InterruptedException {
        zookeeper = new ZooKeeper(serverList, 3000, new Watcher() {
            @Override
            public void process(WatchedEvent event) {
                System.out.println("Watcher triggered: " + event.toString());
            }
        });
    }

    // 创建节点
    public void createNode(String path, String data) throws KeeperException, InterruptedException {
        if (zookeeper.exists(path, false) == null) {
            zookeeper.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
            System.out.println("Created node at " + path);
        } else {
            System.out.println("Node already exists at " + path);
        }
    }

    // 获取节点
    public byte[] getNodeData(String path) throws KeeperException, InterruptedException {
        return zookeeper.getData(path, false, null);
    }

    // 修改节点
    public void updateNode(String path, String newData) throws KeeperException, InterruptedException {
        zookeeper.setData(path, newData.getBytes(), -1);
        System.out.println("Updated node at " + path);
    }

    // 判断节点是否存在
    public boolean checkNodeExists(String path) throws KeeperException, InterruptedException {
        try {
            zookeeper.exists(path, false);
            return true;
        } catch (NoNodeException e) {
            return false;
        }
    }

    // 删除节点
    public void deleteNode(String path) throws KeeperException, InterruptedException {
        zookeeper.delete(path, -1);
        System.out.println("Deleted node at " + path);
    }

    // 关闭Zookeeper连接
    public void close() throws InterruptedException {
        zookeeper.close();
    }

    // 主函数或其他测试方法
    public static void main(String[] args) {
        try {
            ZookeeperTest zookeeperTest = new ZookeeperTest();
            zookeeperTest.initZookeeper("localhost:2181");
            // ... 调用上述方法进行Zookeeper操作
            zookeeperTest.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}