java - 错误 org.apache.zookeeper.ClientCnxn - 调用观察者时出错

Question

我是动物园管理员的新手。我编写了简单的程序来创建持久节点。它的工作，但一旦执行完成就会给出异常。我试图在谷歌上搜索，但没有令人满意的答案。任何人都可以给我任何建议。

public class ZkProg {
    public static void main(String[] args) throws IOException, KeeperException, InterruptedException
    {
        ZooKeeper zk=new ZooKeeper("localhost",1281, null);
        zk.create("/zookeeper/Names",new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        //zk.delete("/zookeeper/Names",-1);
        zk.close();
    }
}

Answer 1

我也记录了这个错误。这是因为 Zookeeper 观察者为空。在对构造函数的调用中，第三个参数是一个观察者：

ZooKeeper zk=new ZooKeeper("localhost",1281, null);

似乎 Zookeeper ClientCnxn 尝试在观察者上调用进程，即使它为空。但是，它会捕获异常并仅记录错误并继续前进。

Answer 2

如果不想看事件，可以自己写“StubWatcher”。

创建一个继承自该方法并用空主体Watcher实现该方法的类。process

那应该这样做。