标签：
1.zookeeeper介绍
ZooKeeper是一个为分布式应用所设计的分布的、开源的协调服务，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，简化分布式应用协调及其管理的难度，提供高性能的分布式服务。ZooKeeper本身可以以Standalone模式安装运行，不过它的长处在于通过分布式ZooKeeper集群（一个Leader，多个Follower），基于一定的策略来保证ZooKeeper集群的稳定性和可用性，从而实现分布式应用的可靠性。ZooKeeper是作为分布式协调服务，是不需要依赖于Hadoop的环境，也可以为其他的分布式环境提供服务。
2.安装伪集群 zookeeeper
所谓 “伪分布式集群” 就是在，在一台PC中，启动多个ZooKeeper的实例。“完全分布式集群” 是每台PC，启动一个ZooKeeper实例。
（1）下载zookeeeper 并解压
在官网http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.8/zookeeper-3.4.8.tar.gz下载zookeeeper，解压三次，并更名目录。
（2）修改配置文件conf/zoo.cfg
在每个zookeeeper-x 中conf 下更名文件（mv和cp都可以），cp conf/zoo_sample.cfg conf/zoo.cfg
修改：dataDir,clientPort
增加：集群的实例，server.X，”X”表示每个目录中的myid的值
vim /usr/local/zookeeper/zookeeper-1/conf/zoo.cfg
vim /usr/local/zookeeper/zookeeper-2/conf/zoo.cfg
vim /usr/local/zookeeper/zookeeper-3/conf/zoo.cfg
注意：因为是在同一台机器上面，所以clientport不能相同
3.启动zookeeeper 服务
分别在 /usr/local/zookeeper/zookeeper-x/bin/ 下，./zkServer start
要是QuorumPeerMain，才是成功启动的
查看节点状态，在/usr/local/zookeeper/zookeeper-x/bin/ 下，./zkServer status
由于zookeeeper集群的稳定性，必须要启动两个以上的服务，zookeeeper才能成功启动
4.安装 zkpython
在官网下载，解压安装即可
https://pypi.python.org/packages/14/38/a761465ab0a154405c11f7e5d6e81edf6e84584e114e152fddd340f7d6d3/zkpython-0.4.2.tar.gz
若import zookeeeper无错误，就表示成功安装
5.zookeeeper命令行操作
我们通过客户端连接ZooKeeper的集群，我们可以任意的zookeeper是进行连接。
集群已连接，下面我们要使用一下，ZooKeeper的命令行操作。
命令行操作（通过help打印命令行帮助）
ZooKeeper的结构，很像是目录结构，我们看到了像ls这样熟悉的命令。
6.python连接和操作zookeeeper
这时可以新开一个shell页面，在python中再初始化一个连接，可以获取前面set的数据“hello"
创建节点说明：
zookeeper.create(self.handle, path, data, [acl2], flags) zk创建节点的api，flags可以为EPHEMERAL SEQUENCE 或0，如果设置为EPHEMERAL ，这个节点只会短暂存在，即过期就好被删除，过期的时间为session的时间，SEQUENCE a unique monotonically increasing sequence number is appended to the path name ，可能是排序的意思。
zookeeper.create(handler,"/zkpython_create_node","mydata1",[{"perms":0x1f,"scheme":"world","id":"anyone"}]),0);
第一个参数就是我们刚才建立的链接,第二个参数是创建的节点的路径,第三个是创建的节点的数据,第四个是acl(zookeeper中的访问控制列表),第五个是创建的节点的类型(0表示持久化的,1表示持久化+序号,2表示瞬时的,3表示瞬时加序号型的)
acl的描述为什么是这样的,首先第一个参数是perms,这个代表了控制这个节点的权限,具体值参考如下:
int READ = 1 << 0;
int WRITE = 1 << 1;
int CREATE = 1 << 2;
int DELETE = 1 << 3;
int ADMIN = 1 << 4;
也就是说,这是一个数字,而我们例子中为什么是1f呢?实际上就是 READ | WRITE | CREATE | DELETE | ADMIN的结果。后面还有两个参数,实际上现在java和c的api中定义的值只有两种,除了例子中的还有一种是 "scheme":"auth","id":""组合的,但是实际上,官方的文档中是有四种的。
监听器说明：
我们先要定义一个watch方法,比如这里的myWatch方法,之后在调用get方法的时候,把这个watch传递进去就可以了。
各个参数的意思：
handler:就是我们创建连接之后的返回值,我试了下,发现好像指的是连接的一个索引值,以0开始
type:事件类型,-1表示没有事件发生,1表示创建节点,2表示节点删除,3表示节点数据被改变,4表示子节点发生变化
state:客户端的状态,0:断开连接状态,3:正常连接的状态,4认证失败,-112:过期啦
path:这个状态就不用解释了,znode的路径
标签：
原文地址：http://www.cnblogs.com/clover-siyecao/p/5607211.html
