作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了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());
}
本文整理了Java中info.xiancloud.zookeeper.ZkConnection类的一些代码示例,展示了ZkConnection类的具体用法。这些代码示例主要来源于Github/Stac
本文整理了Java中info.xiancloud.zookeeper.ZkConnection.start()方法的一些代码示例,展示了ZkConnection.start()的具体用法。这些代码示例
本文整理了Java中info.xiancloud.zookeeper.ZkConnection.close()方法的一些代码示例,展示了ZkConnection.close()的具体用法。这些代码示例
我是一名优秀的程序员,十分优秀!