8 ZooKeeper的操作与编程

《8 ZooKeeper的操作与编程》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、ZooKeeper的简介与操作ZooKeeper简介从前面的原理章节中，我们知道分布式程序需要一定的协同功能，以便能够在多个运行的进程之间建立联系•其中一个重要的协同功能就是进行分布式锁，这样就可以在多个应用程序进行共享资源访问的时候起到保护作用ZooKeeper就是一个为分布式应用程序进行协调的服务，这样的话，每一个分布式的应用程序如果需要进行协调的话就可以直接使用ZooKeeper所提供的服务ZooKeeper提供了一系列分布式系统的基本服务或者可以基于ZooKeeper完成分布式系统的基本服务：同步、配置管理、分组和命名ZooKeeper提供了一个易于编程的环境，实现了一个简化的文件

2、系统，提供类似的目录树结构ZooKeeper使用Java编写，支持了Java以及C语言绑定分布式的协调服务coordination非常容易出错，出错之后也很难恢复，例如死锁状态，或者出现资源竞争状态，通过ZooKeeper可以以良好的编程接口将程序员从自己构造协调服务的负担中解放出来ZooKeeper的特性结构简单•ZooKeeper提供了文件系统的树状结构数据备份•数据一致性，快照+WAL(writeaheadlog)有序性•有序的事务编号zxid高效性•所有的server都提供读服务安装过程概述下载并将zookeeper解压缩到任意一个目录修改conf目录下的zoo_sample.cf

3、g为zoo.cfg修改配置参数启动ZooKeeperZooKeeper程序的启动在完成配置之后1,将ZooKeeper拷贝到多个需要执行的对应节点2,注意需要在每个运行的节点中的数据存储目录中创建一个myid文件，在其中写入一个id号分别在多个节点中启动运行多个ZooKeeper服务器的实例ZooKeeper启动完成ZooKeeper的四字命令如同前面一页看到的命令ruok一样，ZooKeeper支持一系列的四个字母的命令，可以询问ZooKeeper的运行状态，用nc工具就可以打印状态，或者如同前一页一样使用telnet工具用echo命令可以直接将命令行输入给nc（尚未试验成功）ZooKe

4、eper四字命令举例ZooKeeper四字命功能描述令conf输出相关服务配置的详细信息。cons列出所有连接到服务器的客户端的完全的连接/会话的详细信息。包括“接受/发送”的包数量、会话id、操作延迟、最后的操作执行等等信息。dump列出未经处理的会话和临时节点。envi输出关于服务环境的详细信息（区别于conf命令）。reqs列出未经处理的请求ruok测试服务是否处于正确状态。如果确实如此，那么服务返回“imok”，否则不做任何相应。stat输出关于性能和连接的客户端的列表。wchs列出服务器watch的详细信息。wchc通过session列出服务器watch的详细信息，它的输出是一个

5、与watch相关的会话的列表。wchp通过路径列出服务器watch的详细信息。它输出一个与session相关的路径。ZooKeeper的命令行工具ZooKeeper命令行工具zkCli.sh–servermaster2181Help命令可以列出支持的命令ZooKeeper的命令操作1使用ls命令来查看当前ZooKeeper中所包含的内容ZooKeeper的操作命令2创建一个新的znode，使用create/mydataIntelData。这个命令创建了一个新的znode节点“mydata”以及与它关联的字符串IntelData。运行get命令获得数据ZooKeeper的命令操作3通过set

6、命令来对mydata所关联的字符串进行设置ZooKeeper的命令操作4删除命令ZooKeeper的编程接口ZooKeeperAPI包含5个包：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

7、实例，与ZooKeeper服务建立起连接，ZooKeeper系统将会分配给此连接回话一个ID值，客户端会周期地向服务器发送心跳来维持会话的连接，并调用ZooKeeperAPI来做相应的处理与命令行提供的功能类似，API也提供类似的功能功能描述create在本地目录树中创建一个节点delete删除一个节点exists测试本地是否存在目标节点get/setdata从目标节点上读取/写数据get/setACL获取/设置目标节点