python zookeeeper 学习和操作

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

时间: 2024-10-15 20:28:53

python zookeeeper 学习和操作的相关文章

python基础学习——文件操作的其他方法

1.closed 判断文件是否关闭,关闭则返回True 2.encoding,文件打开的编码方式 3.flush刷新:将内存数据刷新到硬盘里 4.tell:当前光标所在位置 只要不是read方法,读取的是字符.其余的文件内光标移动都是以字节为单位 f=open("肖战哥哥","r",encoding="utf-8",newline="") #读取文件中真正的换行符号 print(f.tell()) f.readline() p

python学习之操作mysql

欢迎点击个人博客 http://www.iwangzheng.com/ 刚开始学python,所以很多代码都需要在ipython里尝试一下.今天记录的是最基本的操作mysql数据库. 写数据库连接操作的时候,仿佛回到了当年在前两家公司写asp.net的感觉. 1.首先在mysql数据库里新建个数据库 create database db_02 default charset utf8; create table user (id int auto_increment primary key,us

Python 3 学习的第六天——文件操作

Python 学习的第六天 写此博客 是为了激励自己,并且将自己的心得以及遇到的问题与人分享 一.课堂笔记 1.一切皆文件  对文件的操作一般都三个过程:打开.操作.关闭. f = open ('小文件','r',encoding = 'utf8') # r 为读模式 w 为写模式 整体为得到文件的操作句柄 data = f.read() print(data) f.close() 打开文件,得到文件的操作句柄 通过文件操作句柄对文件进行操作 关闭文件 2.read方法 read(5) 取出来的

【python系统学习07】一张图看懂字典并学会操作

点击跳转 - 原文地址 数据类型 - 字典(dict) 目录: [python系统学习07]一张图看懂字典并学会操作 原文地址:https://www.cnblogs.com/padding1015/p/12232571.html

Python学习-list操作

Python列表(list)操作: 序列是Python中最基本的数据结构.序列中的每个元素都分配一个数字 - 它的位置,或索引,第一个索引是0,第二个索引是1,依此类推. Python有6个序列的内置类型,但最常见的是列表和元组. 序列都可以进行的操作包括索引,切片,加,乘,检查成员. 此外,Python已经内置确定序列的长度以及确定最大和最小的元素的方法. 列表是最常用的Python数据类型,它可以作为一个方括号内的逗号分隔值出现. 列表的数据项不需要具有相同的类型 列表创建与更新: 1 #列

python的数据类型及操作

简述python的几种简单的数据类型及使用方式 字符串 字符串是不可变数据类型,拥有多种内置方法可以操作. 创建字符串就是给变量分配一个字符串的值即可.通常用引号创建字符串. tell = 'my name is Jeff' tell1 = "my name is Jeff" tell2 = '''my name is Jeff, I'm oldboy .''' 字符串切片 tell = 'my name is Jeff' print(tell[0]) print(tell[:7])

Python中的切片操作

Python中的切片操作功能十分强大,通常我们利用切片来进行提取信息,进行相关的操作,下面就是一些切片的列子,一起来看看吧,希望对大家学习python有所帮助. 列如我们从range函数1-100中取7的倍数,函数及结果如下所示: >>> for i in range(1,100)[6::7]: print i 7 14 21 28 35 42 49 56 63 70 77 84 91 98 取一个list或tuple的部分元素是非常常见的操作.比如,一个list如下: >>

Python Click 学习笔记(转)

原文链接:Python Click 学习笔记 Click 是 Flask 的团队 pallets 开发的优秀开源项目,它为命令行工具的开发封装了大量方法,使开发者只需要专注于功能实现.恰好我最近在开发的一个小工具需要在命令行环境下操作,就写个学习笔记. 国际惯例,先来一段 "Hello World" 程序(假定已经安装了 Click 包). # hello.py import click @click.command() @click.option('--count', default

python基础学习05(核心编程第二版)部分

# -*- coding: utf-8 -*- # ==================== #File: python #Author: python #Date: 2014 #==================== __author__ = 'Administrator' #dict{键:值} #哈希 #注:字典是无顺序的,所以你懂的 #创建与赋值 dict1={} dict2={'name':'apply','avg':24,'sex':'man'} print dict1,dict2