zk pivottable java_zookeeper节点类型和java客户端创建zk节点
0 znode节点类型:
Znode有两种类型，短暂的(ephemeral)和持久的(persistent)
Znode的类型在创建时确定并且之后不能再修改
短暂znode的客户端会话结束时，zookeeper会将该短暂znode删除，短暂znode不可以有子节点
持久znode不依赖于客户端会话，只有当客户端明确要删除该持久znode时才会被删除
Znode有四种形式的目录节点，PERSISTENT、PERSISTENT_SEQUENTIAL、EPHEMERAL、EPHEMERAL_SEQUENTIAL
1 java代码创建上述4中znonde节点:
//持久的(以下代码只能执行一次) 只能生成节点/pp
//zooKeeper.create("/pp", " ".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//zooKeeper.close(); 关闭客户端后 /pp节点依旧在zk内
//持久有序的(在/pp/下面增加一个节点，可以重复执行，父节点必须以/结尾) 这样会在 /pp/0000000000 /pp/0000000001这种方式不断生成子节点
//zooKeeper.create("/pp/", " ".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
//zooKeeper.close(); 关闭客户端后 /pp节点依旧在zk内
查看有多少子节点: zk.getChildren
//临时的(临时的下面不能有孩子)
zooKeeper.create("/ee", " ".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
//zooKeeper.close(); 关闭客户端后 /ee节点不会在zk内
//临时有序的
for(5)
//zooKeeper.create("/pp/", " ".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
thread.sleep(1000);
}
//zooKeeper.close(); 关闭客户端后 /ee节点和其下面的节点不会在zk内
如下是创建zk各种类型节点代码:
public static void main(String[] args) throws Exception {
ZooKeeper zk = new ZooKeeper("hadoop3:2181",
9999, new Watcher() {
// 监控所有被触发的事件
public void process(WatchedEvent event) {
System.out.println("已经触发了" + event.getType() + "事件！");
}
});
// System.out.println(zk); 执行main函数时 请打开
//System.out.println(zk.getChildren("/", false));
//zk.create("/zmtest2", "15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
/*zk.create("/zmtest3", "15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
Thread.sleep(10000); // 10S内 创建的临时节点/zmtest3 存在 10S后消失
zk.close();*/
/*zk.create("/zmtest2", "15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
zk.close(); 执行两次下 会产生如下结果: 直接在根路径下加上流水号产生 [zmtest20000000008, zmtest20000000007, zookeeper] 这两个的值都是15
*/
/* 在已经创建好永久节点/zmtest2后，循环执行如下方法2次，然后 ls /zmtest2 看到如下结果[0000000000, 0000000001] 这两个节点值也都是15
* zk.create("/zmtest2/", "15".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);
zk.close(); */
//System.out.println(zk.getData("/zmtest",false,null)); // 以字节码打印
}
maven工程见附件
1.1 上面ZooDefs下模式解释:
使用api 中预设的ACL
在创建znode时可以设置该znode的ACL列表。接口org.apache.zookeeper.ZooDefs.Ids中有一些已经设置好的权限常量，例如：
(1)、 OPEN_ACL_UNSAFE ：完全开放。 事实上这里是采用了world验证模式，由于每个zk连接都有world验证模式，所以znode在设置了 OPEN_ACL_UNSAFE 时，是对所有的连接开放。
(2)、 CREATOR_ALL_ACL ：给创建该znode连接所有权限。 事实上这里是采用了auth验证模式，使用sessionID做验证。所以设置了 CREATOR_ALL_ACL 时，创建该znode的连接可以对该znode做任何修改。
(3)、 READ_ACL_UNSAFE ：所有的客户端都可读。 事实上这里是采用了world验证模式，由于每个zk连接都有world验证模式，所以znode在设置了READ_ACL_UNSAFE时，所有的连接都可以读该znode。
2 关于zookeeper 深入学习的连接: 推酷