重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
ZooKeeper具体的安装流程,如下所示:
站在用户的角度思考问题,与客户深入沟通,找到海口网站设计与海口网站推广的解决方案,凭借多年的经验,让设计与互联网技术结合,创造个性化、用户体验好的作品,建站类型包括:成都做网站、成都网站设计、企业官网、英文网站、手机端网站、网站推广、主机域名、虚拟主机、企业邮箱。业务覆盖海口地区。
首先,由于ZooKeeper是JAVA开发的,所以先要安装JDK,此处我是安装在/usr/local/jdk目录下,设置环境变量即可。
第二,到ZooKeeper官网下载相应的tar包。
http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.12/
解压后。。。
第三,在zookeeper目录下创建data文件夹和conf目录下模仿sample文件,创建zoo.cfg
写入如下信息:
tickTime为2000毫秒, 轮询间隔 ----------------》》》心跳机制
dataDir为刚创建data文件的绝对路径,用来保存zookeeper的数据
clientPort为zookeeper提供给客户的端口号
第四,启动zookerper的服务器。
第五,终端运行zookeeper的客户端。
问号---》查看zookeeper的命令
quit --- 退出
第六,停止ZooKeeper的服务器。
Python与ZooKeeper交互的客户端----Kazoo
2,kazoo的使用。
千万别忘记了,先开启服务器。
1) 客户端的创建,以及节点的创建。
当然,由于现在是为了RPC的调用,就创建如下的节点:
备注:create的第二个参数,必须是二进制的数据。
2)获取节点的数据。
可以看到,第一种方法获取到子节点的数据-----列表的形式,第二种方法获取到某个指定节点的stat状态版本的新信息----元组的形式
3)根据上述,可以通过如下的方式,获取到所有节点的数据:
4)添加监视,指定回调函数。
首先,添加监视。
另外开启一个终端:
此时,查看原先终端,可以看到,on_change函数被执行了。