帮我用java写一个zookeeper客户端，实现对zookeeper服务端的增删改查，并监听zookeeper中节点的变化同步到另一个zookeeper中，不要使用Curator

好的，以下是一个使用 Java 原生 ZooKeeper 客户端实现对 ZooKeeper 服务端的增删改查，并监听节点变化同步到另一个 ZooKeeper 的示例代码：

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;
import java.util.List;

public class ZooKeeperClient implements Watcher {
    private static final String ZK1_ADDRESS = "zookeeper1:2181";
    private static final String ZK2_ADDRESS = "zookeeper2:2181";
    private static final String ZK1_PATH = "/path/to/zookeeper1";
    private static final String ZK2_PATH = "/path/to/zookeeper2";

    private ZooKeeper zk1;
    private ZooKeeper zk2;

    public ZooKeeperClient() throws IOException {
        // 连接到 zookeeper1 和 zookeeper2
        zk1 = new ZooKeeper(ZK1_ADDRESS, 5000, this);
        zk2 = new ZooKeeper(ZK2_ADDRESS, 5000, this);
    }

    public void createNode(String path, byte[] data) throws KeeperException, InterruptedException {
        // 在 zookeeper1 创建节点，并将对应的数据同步到 zookeeper2
        zk1.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        zk2.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }

    public byte[] getNodeData(String path) throws KeeperException, InterruptedException {
        // 从 zookeeper1 获取节点的数据
        return zk1.getData(path, false, null);
    }

    public void updateNode(String path, byte[] data) throws KeeperException, InterruptedException {
        // 更新 zookeeper1 中节点的数据，并将更新后的数据同步到 zookeeper2
        zk1.setData(path, data, -1);
        zk2.setData(path, data, -1);
    }

    public void deleteNode(String path) throws KeeperException, InterruptedException {
        // 删除 zookeeper1 中的节点，并删除相应的节点在 zookeeper2
        zk1.delete(path, -1);
        zk2.delete(path, -1);
    }

    public List<String> getChildren(String path) throws KeeperException, InterruptedException {
        // 获取 zookeeper1 中节点的子节点列表
        return zk1.getChildren(path, false);
    }

    @Override
    public void process(WatchedEvent event) {
        // 监听节点变化，并将变化后的数据同步到 zookeeper2
        if (event.getType() == Event.EventType.NodeDataChanged) {
            String path = event.getPath();
            try {
                byte[] data = zk1.getData(path, false, null);
                zk2.setData(path, data, -1);
            } catch (KeeperException | InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void close() throws InterruptedException {
        // 关闭客户端连接
        zk1.close();
        zk2.close();
    }

    public static void main(String[] args) throws Exception {
        ZooKeeperClient client = new ZooKeeperClient();

        // 创建节点并设置数据
        client.createNode(ZK1_PATH, "Hello, ZooKeeper!".getBytes());

        // 获取节点数据
        byte[] data = client.getNodeData(ZK1_PATH);
        System.out.println("Node data: " + new String(data));

        // 更新节点数据
        client.updateNode(ZK1_PATH, "Hello, Updated ZooKeeper!".getBytes());

        // 再次获取节点数据
        data = client.getNodeData(ZK1_PATH);
        System.out.println("Updated node data: " + new String(data));

        // 删除节点
        client.deleteNode(ZK1_PATH);

        // 获取子节点列表
        List<String> children = client.getChildren("/");
        System.out.println("Children nodes: " + children);

        // 保持程序运行
        Thread.sleep(Long.MAX_VALUE);

        client.close();
    }
}

上述代码中，我们使用了 Java 原生 ZooKeeper 客户端来实现对 ZooKeeper 服务端的增删改查操作。创建了一个 `ZooKeeperClient` 类，其中包含了对应的方法用于实现对 ZooKeeper 的操作。同时，该类实现了 `Watcher` 接口，用于监听节点变化并将变化后的数据同步到另一个 ZooKeeper。

在 `main` 方法中，我们创建了一个 `ZooKeeperClient` 对象，然后调用相应的方法进行增删改查操作。同时，我们也可以看到在监听器中的 `process` 方法中处理了节点数据变化的逻辑。

注意：这只是一个简单示例，实际应用中需要根据情况处理更多的异常和错误情况。

希望这能帮助到你！如果有任何问题，请随时提问。