Zookeeper：API（一）
ZooKeeper对Java和c有一个官方的应用编程接口绑定。ZooKeeper社区为大多数语言提供了非官方的应用编程接口(.NET, python等)。使用ZooKeeper API，应用程序可以连接、交互、操作数据、协调，最后从ZooKeeper集成中断开。
ZooKeeper应用程序接口有一套丰富的特性，以简单安全的方式获得ZooKeeper集成的所有功能。ZooKeeper应用程序接口提供同步和异步方法。
ZooKeeper集成和ZooKeeper应用程序接口在每个方面都是完全互补的，这对开发人员非常有利。让我们在本章讨论Java绑定。
基础的ZooKeeper API
与ZooKeeper集成交互的应用程序被称为ZooKeeper客户端。
znode是ZooKeeper集成的核心组件，ZooKeeper应用编程接口提供了一套小的方法来操作Znode与ZooKeeper集成的所有细节。
客户端应按照下面给出的步骤与ZooKeeper进行互动。
-连接到ZooKeeper。ZooKeeper集合为客户端分配一个会话标识。
-定期向服务器发送心跳。否则，ZooKeeper集成会使会话标识过期，客户端需要重新连接。
-只要会话标识处于活动状态，就获取/设置znodes。
-所有任务完成后，断开与ZooKeeper的连接。如果客户端长时间不活动，那么ZooKeeper集成将自动断开客户端。
Java绑定
让我们理解本章中最重要的一组ZooKeeper API。ZooKeeper API的核心部分是ZooKeeper类。它在构造器中提供了连接ZooKeeper的选项，并提供以下方法：
connect：连接到ZooKeeper
create：创建znode
exists：检查znode是否存在及其信息
getData ：从特定的znode获取数据
setData：在特定的znode中设置数据
getChildren：获取特定znode中所有可用的子节点
delete：获取特定的znode及其所有子节点
close：关闭连接
连接到ZooKeeper
ZooKeeper类通过其构造函数提供连接功能，构造函数如下
ZooKeeper(String connectionString, int sessionTimeout, Watcher watcher)
其中，
connectionString：ZooKeeper服务器地址.
sessionTimeout：会话超时(毫秒).
watcher：实现“观察器”接口的对象。ZooKeeper集成通过观察器对象返回连接状态。
让我们创建一个新的助手类ZooKeeperConnection，并添加一个方法connect。connect方法创建一个ZooKeeper对象，连接到ZooKeeper，然后返回该对象。
这里CountDownLatch用于停止(等待)主进程，直到客户端与ZooKeeper集成连接。
ZooKeeper集成通过观察者回调来回复连接状态。一旦客户端连接到ZooKeeper集成，将调用观察器回调，观察器回调调用CountDownLatch的倒计时方法来释放锁，在主进程中等待。
下面是与ZooKeeper连接的完整代码。
//Coding: ZooKeeperConnection.java
// import java classes
import java.io.IOException;
import java.util.concurrent.CountDownLatch;
// import zookeeper classes
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.AsyncCallback.StatCallback;
import org.apache.zookeeper.KeeperException.Code;
import org.apache.zookeeper.data.Stat;
public class ZooKeeperConnection {
// declare zookeeper instance to access ZooKeeper ensemble
private ZooKeeper zoo;
final CountDownLatch connectedSignal = new CountDownLatch(1);
// Method to connect zookeeper ensemble.
public ZooKeeper connect(String host) throws IOException,InterruptedException {
zoo = new ZooKeeper(host,5000,new Watcher() {
public void process(WatchedEvent we) {
if (we.getState() == KeeperState.SyncConnected) {
connectedSignal.countDown();
}
}
});
connectedSignal.await();
return zoo;
}
// Method to disconnect from zookeeper server
public void close() throws InterruptedException {
zoo.close();
}
}保存上述代码，它将在下一节中用于连接ZooKeeper集成。
创建Znode
ZooKeeper类提供了在ZooKeeper集成中创建新znode的创建方法。create方法如下
create(String path, byte[] data, List<ACL> acl, CreateMode createMode)
其中，
path：Znode路径. 例如, /myapp1, /myapp2, /myapp1/mydata1, myapp2/mydata1/myanothersubdata
data：要存储在指定znode路径中的数据
acl：要创建的节点的访问控制列表。ZooKeeper应用程序接口提供了一个静态接口动物园定义。获取一些基本acl列表的id。例如，动物园定义。返回打开的代码的ACL列表。
createMode：节点类型，短暂的、连续的或两者都有。这是一个枚举。
让我们创建一个新的Java应用程序来检查ZooKeeper应用程序接口的创建功能。创建一个文件ZKCreate.java。在主方法中，创建 ZooKeeperConnection类型的对象，并调用connect方法连接到ZooKeeper集成。
连接方法将返回ZooKeeper对象zk。现在，用自定义路径和数据调用zk对象的创建方法。
创建znode的完整程序代码如下
//Coding: ZKCreate.java
import java.io.IOException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
public class ZKCreate {
// create static instance for zookeeper class.
private static ZooKeeper zk;
// create static instance for ZooKeeperConnection class.
private static ZooKeeperConnection conn;
// Method to create znode in zookeeper ensemble
public static void create(String path, byte[] data) throws
KeeperException,InterruptedException {
zk.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT);
}
public static void main(String[] args) {
// znode path
String path = "/MyFirstZnode"; // Assign path to znode
// data in byte array
byte[] data = "My first zookeeper app”.getBytes(); // Declare data
try {
conn = new ZooKeeperConnection();
zk = conn.connect("localhost");
create(path, data); // Create the data to the specified path
conn.close();
} catch (Exception e) {
System.out.println(e.getMessage()); //Catch error message
}
}
}一旦应用程序被编译和执行，将在ZooKeeper集成中创建一个具有指定数据的znode。您可以使用ZooKeeper CLI zkCli.sh进行检查。
cd /path/to/zookeeper bin/zkCli.sh >>> get /MyFirstZnode