本文整理了Java中com.github.zkclient.ZkClient.writeData()
方法的一些代码示例,展示了ZkClient.writeData()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.writeData()
方法的具体详情如下:
包路径:com.github.zkclient.ZkClient
类名称:ZkClient
方法名:writeData
暂无
代码示例来源:origin: adyliu/jafka
public static void updatePersistentPath(ZkClient zkClient, String path, String data) {
try {
zkClient.writeData(path, Utils.getBytes(data));
} catch (ZkNoNodeException e) {
createParentPath(zkClient, path);
try {
zkClient.createPersistent(path, Utils.getBytes(data));
} catch (ZkNodeExistsException e2) {
zkClient.writeData(path, Utils.getBytes(data));
}
}
}
代码示例来源:origin: com.github.adyliu/zkclient
public Stat writeData(String path, byte[] object) {
return writeData(path, object, -1);
}
代码示例来源:origin: adyliu/zkclient
public Stat writeData(String path, byte[] object) {
return writeData(path, object, -1);
}
代码示例来源: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);
}
内容来源于网络,如有侵权,请联系作者删除!