学科分类
目录
Hadoop技术栈

Zookeeper Java API介绍

Zookeeper提供了Java API,可以在Java中调用Zookeeper并进行操作。本节主要是利用Zookeeper Java API创建的Zookeeper对象创建连接会话。然而,由于Zookeeper对象创建会话时是异步操作,所以需要程序等待延迟关闭,并且在实现watcher接口的方法中收集连接会话后返回的信息。下面,我们来学习Zookeeper API。

Zookeeper API共包含五个包,分别为

  • org.apache.zookeeper
  • org.apache.zookeeper.data
  • org.apache.zookeeper.server
  • org.apache.zookeeper.server.quorum
  • org.apache.zookeeper.server.upgrade

其中org.apache.zookeeper包含Zookeeper类,这也是编程时最常用的类文件。Zookeeper类作为Zookeeper客户端库的主要类文件,如果要使用Zookeeper服务,应用程序就需要先创建一个Zookeeper实例对象,一旦客户端与Zookeeper服务建立了连接,Zookeeper系统将会为此连接分配一个会话的ID值,并且客户端会周期性地向服务器发送心跳来保持会话的连接,只要连接正常,客户端就可以调用Zookeeper API进行操作。下面介绍下Zookeeper类提供的常用方法,如表1所示。

表1 Zookeeper常用方法

方法名称 方法描述
create 创建节点
delete 删除节点
exists 判断节点是否存在
get/setData 获取/修改节点数据
getChildren 获取指定节点下的所有子节点列表
点击此处
隐藏目录