本文整理了Java中com.alibaba.wasp.zookeeper.ZKUtil.getDataAndWatch()
方法的一些代码示例,展示了ZKUtil.getDataAndWatch()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKUtil.getDataAndWatch()
方法的具体详情如下:
包路径:com.alibaba.wasp.zookeeper.ZKUtil
类名称:ZKUtil
方法名:getDataAndWatch
[英]Get the data at the specified znode and set a watch. Returns the data and sets a watch if the node exists. Returns null and no watch is set if the node does not exist or there is an exception.
[中]在指定的znode获取数据并设置一个手表。如果节点存在,则返回数据并设置监视。返回null,如果节点不存在或存在异常,则不设置监视。
代码示例来源:origin: alibaba/wasp
/**
* Gets the current data in the unassigned node for the specified entityGroup
* name or fully-qualified path.
*
* <p>
* Returns null if the entityGroup does not currently have a node.
*
* <p>
* Sets a watch on the node if the node exists.
*
* @param zkw zk reference
* @param pathOrEntityGroupName fully-specified path or entityGroup name
* @return znode content
* @throws org.apache.zookeeper.KeeperException if unexpected zookeeper exception
*/
public static byte[] getData(ZooKeeperWatcher zkw, String pathOrEntityGroupName)
throws KeeperException {
String node = getPath(zkw, pathOrEntityGroupName);
return ZKUtil.getDataAndWatch(zkw, node);
}
代码示例来源:origin: alibaba/wasp
/**
* Gets the data of the node.
*
* <p>
* If the node is currently available, the most up-to-date known version of
* the data is returned. If the node is not currently available, null is
* returned.
* @param refresh whether to refresh the data by calling ZK directly.
* @return data of the node, null if unavailable
*/
public synchronized byte[] getData(boolean refresh) {
if (refresh) {
try {
this.data = ZKUtil.getDataAndWatch(watcher, node);
} catch (KeeperException e) {
abortable.abort("Unexpected exception handling getData", e);
}
}
return this.data;
}
代码示例来源:origin: alibaba/wasp
/**
* Gets the current data in the unassigned node for the specified entityGroup
* name or fully-qualified path.
*
* <p>
* Returns null if the entityGroup does not currently have a node.
*
* <p>
* Sets a watch on the node if the node exists.
*
* @param zkw zk reference
* @param pathOrEntityGroupName fully-specified path or entityGroup name
* @param stat object to populate the version.
* @return znode content
* @throws org.apache.zookeeper.KeeperException if unexpected zookeeper exception
*/
public static byte[] getDataAndWatch(ZooKeeperWatcher zkw,
String pathOrEntityGroupName, Stat stat) throws KeeperException {
String node = getPath(zkw, pathOrEntityGroupName);
return ZKUtil.getDataAndWatch(zkw, node, stat);
}
代码示例来源:origin: alibaba/wasp
@Override
public synchronized void nodeCreated(String path) {
if (!path.equals(node))
return;
try {
byte[] data = ZKUtil.getDataAndWatch(watcher, node);
if (data != null) {
this.data = data;
notifyAll();
} else {
nodeDeleted(path);
}
} catch (KeeperException e) {
abortable.abort("Unexpected exception handling nodeCreated event", e);
}
}
代码示例来源:origin: alibaba/wasp
try {
this.data = ZKUtil.getDataAndWatch(watcher, node);
} catch (KeeperException e) {
try {
this.data = ZKUtil.getDataAndWatch(watcher, node);
} catch (KeeperException e) {
LOG.warn("Unexpected exception handling blockUntilAvailable", e);
代码示例来源:origin: alibaba/wasp
try {
if (ZKUtil.watchAndCheckExists(watcher, node)) {
byte[] data = ZKUtil.getDataAndWatch(watcher, node);
if (data != null) {
this.data = data;
代码示例来源:origin: alibaba/wasp
byte[] bytes = ZKUtil.getDataAndWatch(this.watcher,
this.watcher.getMasterAddressZNode());
if (bytes == null) {
代码示例来源:origin: alibaba/wasp
existingBytes = ZKUtil.getDataAndWatch(zkw, node);
} catch (KeeperException.NoNodeException nne) {
return false;
代码示例来源:origin: alibaba/wasp
String nodeName = ZKAssign.getNodeName(zkw, entityGroup
.getEntityGroupInfo().getEncodedName());
ZKUtil.getDataAndWatch(zkw, nodeName, stat);
内容来源于网络,如有侵权,请联系作者删除!