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 深入学习的连接: 推酷