本文整理了Java中com.github.zkclient.ZkClient.readData()
方法的一些代码示例,展示了ZkClient.readData()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.readData()
方法的具体详情如下:
包路径:com.github.zkclient.ZkClient
类名称:ZkClient
方法名:readData
暂无
代码示例来源:origin: adyliu/jafka
public static String readDataMaybyNull(ZkClient zkClient, String path) {
return Utils.fromBytes(zkClient.readData(path, true));
}
代码示例来源:origin: adyliu/jafka
public static String readData(ZkClient zkClient, String path) {
return Utils.fromBytes(zkClient.readData(path));
}
代码示例来源:origin: adyliu/jafka
public static String readDataMaybeNull(ZkClient zkClient, String path) {
return Utils.fromBytes(zkClient.readData(path, true));
}
代码示例来源:origin: com.github.adyliu/zkclient
public byte[] readData(String path, boolean returnNullIfPathNotExists) {
byte[] data = null;
try {
data = readData(path, null);
} catch (ZkNoNodeException e) {
if (!returnNullIfPathNotExists) {
throw e;
}
}
return data;
}
代码示例来源:origin: adyliu/zkclient
public byte[] readData(String path, boolean returnNullIfPathNotExists) {
byte[] data = null;
try {
data = readData(path, null);
} catch (ZkNoNodeException e) {
if (!returnNullIfPathNotExists) {
throw e;
}
}
return data;
}
代码示例来源:origin: adyliu/zkclient
public byte[] readData(String path) {
return readData(path, false);
}
代码示例来源:origin: com.github.adyliu/zkclient
public byte[] readData(String path) {
return readData(path, false);
}
代码示例来源:origin: com.github.adyliu/zkclient
public int countChildren(String path) {
try {
Stat stat = new Stat();
this.readData(path, stat);
return stat.getNumChildren();
//return getChildren(path).size();
} catch (ZkNoNodeException e) {
return -1;
}
}
代码示例来源:origin: adyliu/zkclient
public int countChildren(String path) {
try {
Stat stat = new Stat();
this.readData(path, stat);
return stat.getNumChildren();
//return getChildren(path).size();
} catch (ZkNoNodeException e) {
return -1;
}
}
代码示例来源:origin: com.github.adyliu/zkclient
public byte[] readData(String path, Stat stat) {
return readData(path, stat, hasListeners(path));
}
代码示例来源:origin: adyliu/zkclient
public byte[] readData(String path, Stat stat) {
return readData(path, stat, hasListeners(path));
}
代码示例来源:origin: com.github.adyliu/zkclient
public void cas(String path, DataUpdater updater) {
Stat stat = new Stat();
boolean retry;
do {
retry = false;
try {
byte[] oldData = readData(path, stat);
byte[] newData = updater.update(oldData);
writeData(path, newData, stat.getVersion());
} catch (ZkBadVersionException e) {
retry = true;
}
} while (retry);
}
代码示例来源:origin: adyliu/zkclient
public void cas(String path, DataUpdater updater) {
Stat stat = new Stat();
boolean retry;
do {
retry = false;
try {
byte[] oldData = readData(path, stat);
byte[] newData = updater.update(oldData);
writeData(path, newData, stat.getVersion());
} catch (ZkBadVersionException e) {
retry = true;
}
} while (retry);
}
代码示例来源:origin: adyliu/zkclient
@Override
public void run() throws Exception {
// reinstall watch
exists(path, true);
try {
byte[] data = readData(path, null, true);
listener.handleDataChange(path, data);
} catch (ZkNoNodeException e) {
listener.handleDataDeleted(path);
}
}
});
代码示例来源:origin: com.github.adyliu/zkclient
@Override
public void run() throws Exception {
// reinstall watch
exists(path, true);
try {
byte[] data = readData(path, null, true);
listener.handleDataChange(path, data);
} catch (ZkNoNodeException e) {
listener.handleDataDeleted(path);
}
}
});
内容来源于网络,如有侵权,请联系作者删除!