本文整理了Java中info.xiancloud.zookeeper.ZkConnection.close()
方法的一些代码示例,展示了ZkConnection.close()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkConnection.close()
方法的具体详情如下:
包路径:info.xiancloud.zookeeper.ZkConnection
类名称:ZkConnection
方法名:close
暂无
代码示例来源:origin: xiancloud/xian
@Override
public void destroy() {
close();
}
}
代码示例来源:origin: xiancloud/xian
@Test
public void setDataWithVersionTest() throws Exception {
ZkConnection.start();
try {
/*ZkConnection.client.create().creatingParentsIfNeeded().forPath("/YY/11");*/
ZkConnection.client.setData().withVersion(-1).forPath("/YY/11", "ss".getBytes());
} finally {
ZkConnection.close();
}
}
}
代码示例来源:origin: xiancloud/xian
@Override
public void execute(UnitRequest msg, Handler<UnitResponse> handler) throws Exception {
/**
* 请设置此变量来删除指定路径下的脏节点
*/
final String PATH = msg.get("basePath", "/xian_runtime_dev/unit");
try {
ZkConnection.start();
for (String s : ZkConnection.client.getChildren().forPath(PATH)) {
String fullPath = PATH.concat("/").concat(s);
String data = new String(ZkConnection.client.getData().forPath(fullPath));
System.out.println(data);
if (StringUtil.isEmpty(data)) {
LOG.debug("实现原理是xian服务注册会在unit和group节点data上写入其定义数据,如果没有定义数据的,那么一定是脏节点");
ZkConnection.client.delete().forPath(fullPath);
}
}
} finally {
ZkConnection.close();
}
handler.handle(UnitResponse.createSuccess());
}
内容来源于网络,如有侵权,请联系作者删除!