python zookeeeper 学习和操作

Posted 2020-07-29 绽放的四叶草

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的路径