adyliu / zkclient Goto Github PK

按照快速指南中的教程：

zkClient.writeData("testPath", "testData".getBytes());

然后读取数据：

byte[] data = zkClient.readData("testPath");

出现的错误：

org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.StreamCorruptedException: invalid type code: 

这个具体怎么回事，找不到原因啊～

ZkClient类中调用deleteRecursive函数删除根目录会出现问题：
like this：
ZkClient zkClient = new ZkClient("localhost:2181");
zkClient.deleteRecursive("/");//will error

修改代码如下也许会解决问题：
public boolean deleteRecursive(String path)
{
if (path.equals("/zookeeper/quota") || path.equals("/zookeeper") || path.equals("/"))
{
return true;
}
List children;
try
{
children = getChildren(path, false);
}
catch (ZkNoNodeException e)
{
return true;
}
String finalPath = path;
for (String subPath : children)
{
if (!path.equals("/"))
{
finalPath = path + "/" + subPath;
}
else
{
finalPath = path + subPath;
}
if (!deleteRecursive(finalPath))
{
return false;
}
}
return delete(path);
}

同个客户端所有的回调都是共享1个线程，多个路径使用同个listener,当多个路径同时有change，这时候listener是怎么处理的？会阻塞么

adyliu您好：
在ZkClient中的retryUntilConnected方法，第一步会判断if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread)，而且将所有关于zk的操作例如readData exist操作等，都是封装在这个retryUntilConnected中的，这样就会导致所有通过watcher通知过来的process方法中，不能去对zookeeper进行读取判断等操作，增加if判断的原因是什么？

我把zkclient用在了storm的topology里面（storm里面的bolt需要监听zookeeper某一个节点的数据变化），但是storm在分发代码的时候需要对象是可序列化的，异常：
Caused by: java.io.NotSerializableException: com.github.zkclient.ZkClient
at backtype.storm.utils.Utils.serialize(Utils.java:70)

So，能否将zkClient可序列化呢？

Just get in touch with zookeeper helper libraries like this one, any compare done v.s. apache curator?

zkclient 缺少当新的路径被建立的时候的通知，因为现在的节点监听是基于具体路径的，但是当新节点建立的时候，我们事先是不知道节点路径的，这个时候需要一个监听能监听到，然后能在具体的回调中处理

sgroschupf 的zkClient是支持授权的api ，好像这个client 去掉了？