zookeeper java api 创建 新增节点 删除节点 查看节点是否存在
1.准备
首先idea 建一个maven 项目 pom 里面引入
<dependencies>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
</dependency>'
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j</artifactId>
<version>2.10.0</version>
<type>pom</type>
</dependency>
</dependencies>
2 代码
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import java.io.IOException;
import java.util.List;
/**
@AUTHOR lanke
-
@DATE 2018/4/10
*/
public class Master implements Watcher {ZooKeeper zk;
String hostPort;public Master(String hostPort) {
this.hostPort = hostPort;
}void startZk(){
try {
zk = new ZooKeeper(hostPort,15000,this);
} catch (IOException e) {
e.printStackTrace();
}
}
public void process(WatchedEvent watchedEvent) {
System.out.println(watchedEvent);
// createNode(zk); //创建节点
// isExist(zk); //节点是否存在
// delete(zk); //删除节点
// update(zk); //更新节点数据
// getChildrenNode(zk); //获取子节点
}
/**
* 测试创建节点
* @param zk
*/
public static void createNode(ZooKeeper zk){
try {
//创建test节点，值为test,不需权限控制，值持久化
zk.create("/test", "test".getBytes("UTF-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println("/test 创建成功....");
} catch (Exception e) {
System.out.println("/test 创建失败....");
e.printStackTrace();
}
//尝试创建已存在的节点
try {
//创建test节点，值为test,不需权限控制，值持久化
zk.create("/test", "test".getBytes("UTF-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println("第二次 /test 创建成功....");
} catch (Exception e) {
System.out.println("第二次 /test 创建失败....");
e.printStackTrace();
}
//创建创建父节点不存在，就直接建子节点
try {
//创建/app/app01节点，值为test,不需权限控制，值持久化
zk.create("/app/app01", "app01".getBytes("UTF-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println("/app/app01 创建成功....");
} catch (Exception e) {
System.out.println("/app/app01 /test 创建失败....");
e.printStackTrace();
}
}
/**
* 判断节点是否存在
* @param zk
*/
public static void isExist(ZooKeeper zk){
String path = "/test";
try {
Stat stat = zk.exists(path, false);
if(stat == null){
System.out.println("节点 path="+path+"不存在");
}else{
System.out.println("节点 path="+path+"存在,stat=" + stat);
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 删除节点
* @param zk
*/
public static void delete(ZooKeeper zk){
//删除已存在的节点
try {
Stat stat = zk.exists("/test", false);
zk.delete("/test", stat.getVersion());
System.out.println("删除/test成功....");
} catch (Exception e) {
System.out.println("删除/test节点失败...");
e.printStackTrace();
}
//删除不存在的节点
try {
zk.delete("/test/test", 0);
System.out.println("删除/test/test成功.....");
} catch (Exception e) {
System.out.println("删除/test/test失败.....");
e.printStackTrace();
}
}
/**
* 修改节点数据
* @param zk
*/
public static void update(ZooKeeper zk) {
try {
//创建临时节点/test-update,值为update
zk.create("/test-update", "update".getBytes("utf-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
//把值修改为update-2
zk.setData("/test-update", "update-2".getBytes("utf-8"), 0);
String data = new String(zk.getData("/test-update", false, null), "utf-8");
System.out.println("/test-update的值为" + data);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 带权限
*/
public static void auth(){
try {
String connStr = "192.168.0.219:2181";
//创建zk1
ZooKeeper zk1 = new ZooKeeper(connStr,5000,null);
//zk1进行认证
zk1.addAuthInfo("digest", "lan".getBytes("utf-8"));
//zk1创建节点/fei,CREATOR_ALL_ACL进行权限控制
zk1.create("/lan", "lan".getBytes("utf-8"), ZooDefs.Ids.CREATOR_ALL_ACL, CreateMode.PERSISTENT);
//创建zk2
ZooKeeper zk2 = new ZooKeeper(connStr,5000,null);
//zk2读取节点
System.out.println(new String(zk2.getData("/lan", false, null),"utf-8"));
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 获取子节点
* @param zk
*/
public static void getChildrenNode(ZooKeeper zk){
try {
//创建一些临时节点
//注意不能再临时节点下创建子节点
zk.create("/app", "app".getBytes("utf-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//子节点可以是临时的
zk.create("/app/app01", "app01".getBytes("utf-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
zk.create("/app/app02", "app02".getBytes("utf-8"), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
List<String> list = zk.getChildren("/app", false);
System.out.println("/app的子节点有：");
for(String c : list){
System.out.println(c);
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws InterruptedException {
Master m = new Master(args[0]);
m.startZk();
Thread.sleep(60000);
}
}
3 看回调函数process 里面 全部注释的时候 就只是初始打印结果如下
image.png
4 放开createNode(zk);
结果如下：第一次成功之后，再创建节点名称一样的就会报错
image.png
5 调用isexist（zk）
结果如下：
image.png
6 调用delete(zk)
结果如下 第一次成功，第二次就会报错的
7 调用更新数据
结果如下：
image.png
