使用zkClient连接zookeeper服务
2016-07-19 15:41
447 查看
直接上代码:
package com.sdp.zookeeper;
import java.util.List;
import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;
public class Main {
public static void main(String[] args) {
ZkClient zkClient = new ZkClient("127.0.0.1:2181");//建立连接
// zkClient.exists('/root'); //判断目录是否存在
zkClient.create("/root","mydata", CreateMode.PERSISTENT);//创建目录并写入数据
String data=zkClient.readData("/root");
System.out.println(data);
zkClient.delete("/root");//删除目录
// zkClient.deleteRecursive("/root");//递归删除节目录
}
}
别忘记引入zkClient的jar包。以gradle为例:
dependencies {
compile group: 'com.101tec', name: 'zkclient', version: '0.9'
}
package com.sdp.zookeeper;
import java.util.List;
import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;
public class Main {
public static void main(String[] args) {
ZkClient zkClient = new ZkClient("127.0.0.1:2181");//建立连接
// zkClient.exists('/root'); //判断目录是否存在
zkClient.create("/root","mydata", CreateMode.PERSISTENT);//创建目录并写入数据
String data=zkClient.readData("/root");
System.out.println(data);
zkClient.delete("/root");//删除目录
// zkClient.deleteRecursive("/root");//递归删除节目录
}
}
别忘记引入zkClient的jar包。以gradle为例:
dependencies {
compile group: 'com.101tec', name: 'zkclient', version: '0.9'
}
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- c++11 + SDL2 + ffmpeg +OpenAL + java = Android播放器
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序
- 二叉查找树