zookeeper_api使用

原生API URL

http://zookeeper.apache.org/doc/r3.4.6/api/org/apache/zookeeper/ZooKeeper.html

构造函数中连接ZooKeeper集合的选项，并具有以下方法：

    connect - 连接到ZooKeeper集合
    create- 创建znode
    exists- 检查znode是否存在及其信息
    getData - 从特定的znode获取数据
    setData - 在特定的znode中设置数据
    getChildren - 获取特定znode中的所有子节点
    delete - 删除特定的znode及其所有子项
    close - 关闭连接

连接到ZooKeeper集合

ZooKeeper(String connectionString, int sessionTimeout, Watcher watcher)
connectionString - ZooKeeper集合主机。
sessionTimeout - 会话超时（以毫秒为单位）。
watcher - 实现“监视器”界面的对象。ZooKeeper集合通过监视器对象返回连接状态。

创建Znode

create(String path, byte[] data, List<ACL> acl, CreateMode createMode)
path - Znode路径。例如，/myapp1，/myapp2，/myapp1/mydata1，myapp2/mydata1/myanothersubdata
data - 要存储在指定znode路径中的数据
acl - 要创建的节点的访问控制列表。ZooKeeper API提供了一个静态接口 ZooDefs.Ids 来获取一些基本的acl列表。例如，ZooDefs.Ids.OPEN_ACL_UNSAFE返回打开znode的acl列表。
createMode - 节点的类型，即临时，顺序或两者。这是一个枚举。

Exists - 检查Znode的存在

exists(String path, boolean watcher)
path- Znode路径
watcher - 布尔值，用于指定是否监视指定的znode

getData方法

getData(String path, Watcher watcher, Stat stat)
path - Znode路径。
watcher - 监视器类型的回调函数。当指定的znode的数据改变时，ZooKeeper集合将通过监视器回调进行通知。这是一次性通知。
stat - 返回znode的元数据。

setData方法

setData(String path, byte[] data, int version)
path- Znode路径
data - 要存储在指定znode路径中的数据。
version- znode的当前版本。每当数据更改时，ZooKeeper会更新znode的版本号。

getChildren方法

getChildren(String path, Watcher watcher)
path - Znode路径。
watcher - 监视器类型的回调函数。当指定的znode被删除或znode下的子节点被创建/删除时，ZooKeeper集合将进行通知。这是一次性通知。

删除Znode

delete(String path, int version)
path - Znode路径。
version - znode的当前版本。