zookeeper 集群搭建及使用

2016-04-06 09:27:43   最后更新: 2016-04-06 18:59:53   访问数量:1938




上一篇日志中我们介绍了 zookeeper 的基本构成和原理,看上去比较复杂,事实上,zookeeper 的用法非常简单,本篇日志中,我们就来介绍一下 zookeeper 的常用用法

zookeeper 及 paxos 算法基本介绍

 

下面是一个常见的 zookeeper 配置文件:

# The number of milliseconds of each tick tickTime=2000 # The number of ticks that the initial # synchronization phase can take initLimit=5 # The number of ticks that can pass between # sending a request and getting an acknowledgement syncLimit=2 # the directory where the snapshot is stored. # do not use /tmp for storage, /tmp here is just # example sakes. dataDir=/tmp/zookeeper/zk1 #zk log dir logDir=/tmp/zookeeper/zk1/logs # the port at which the clients will connect clientPort=2181 # the maximum number of client connections. # increase this if you need to handle more clients #maxClientCnxns=60 # # Be sure to read the maintenance section of the # administrator guide before turning on autopurge. # # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance # #autopurge.snapRetainCount=3 # Purge task interval in hours # Set to "0" to disable auto purge feature #autopurge.purgeInterval=1 server.1=127.0.0.1:2888:3888 server.2=127.0.0.1:2889:3889 server.3=127.0.0.1:2890:3890

 

 

这里使用了下列配置:

  • tickTime -- zookeeper 服务器之间或客户端与服务器之间的心跳间隔时间,每 tickTime 发一次心跳
  • dataDir -- zookeeper 保存数据的目录,写数据的日志文件也保存在这里,dataDir 需要手动创建,并在目录中创建相应的 myid 文件,文件内容为当前 Server 编号,zookeeper 由此知道自己是配置中的哪个 server
  • clientPort -- 客户端连接 zookeeper 服务的端口,zookeeper 监听在这个端口上接受客户端请求
  • initLimit -- Leader接受Follower初始化连接时最长能忍受多少个心跳时间间隔数。当已经超过 5个心跳的时间(tickTime)长度后 Zookeeper 服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。总的时间长度就是 5*2000=10 秒
  • syncLimit -- 表示Leader与Follower之间发送消息时请求和应答时间长度,最长不能超过多少个tickTime的时间长度,总的时间长度就是2*2000=4秒
  • server.A=B:C:D -- 其中A是一个数字,表示这个是第几号服务器;B 是这个服务器的 ip 地址;C表示的是这个服务器与集群中的Leader服务器交换信息的端口;D表示的是万一集群中的Leader服务器挂了,需要一个端口来重新进行选举,选出一个新的Leader,而这个端口就是用来执行选举时服务器相互通信的端口

 

我们创建另外两个配置文件:

tickTime=2000 initLimit=5 syncLimit=2 dataDir=/tmp/zookeeper/zk2 logDir=/tmp/zookeeper/zk2/logs clientPort=2182 server.1=127.0.0.1:2888:3888 server.2=127.0.0.1:2889:3889 server.3=127.0.0.1:2890:3890

 

 

tickTime=2000 initLimit=5 syncLimit=2 dataDir=/tmp/zookeeper/zk3 logDir=/tmp/zookeeper/zk3/logs clientPort=2183 server.1=127.0.0.1:2888:3888 server.2=127.0.0.1:2889:3889 server.3=127.0.0.1:2890:3890

 

 

然后运行建立三个 dataDir 和 logDir(由于我们的 logDir 都是 dataDir 的子目录,所以用一个命令可以创建全部):

mkdir -p /tmp/zookeeper/zk1/logs /tmp/zookeeper/zk2/logs /tmp/zookeeper/zk3/logs

 

 

启动三个 zkServer:

./bin/zkServer.sh start conf/zk1.cfg ./bin/zkServer.sh start conf/zk2.cfg ./bin/zkServer.sh start conf/zk3.cfg

 

 

此时,通过 status 命令,可以查看节点状态:

./bin/zkServer.sh status conf/zk1.cfg

 

 

如图所示,节点都已经存活,而 zk2 是 Leader,其他两个 Server 是 Follower:

 

 

如下图所示,以 -server 参数运行 bin 目录下的 zkCli 即可连接到指定的 Server:

 

 

zookeeper 是以类似于文件系统的 path 作为单位工作的,他拥有下列指令,在 client 中输入 help 指令可以查看:

zookeeper client 常用指令
指令意义
ls path [watch]查看 path 下包含的内容,如果使用可选参数 watch,则会在节点内容发生变化时通知 client
ls2 path [watch]查看当前节点数据并能看到更新次数等数据
stat path [watch]查看 path 状态,如果使用可选参数 watch,则会在节点状态发生变化时通知 client
printwatches on|off是否开启、关闭 watch 内容变更的打印
delete path [version]删除 path
get path [watch]得到一个节点,包含数据和更新次数等数据
create [-s] [-e] path data acl创建 znode
addauth scheme auth增加权限认证
sync path同步 path
set path data [version]为 path 设置数据
setquota -n|-b val pathquota 用来设置节点个数和空间大小限制,-n 用来限制个数,-b 用来限制大小(znode 字节数)
listquota path列出 quota 限制
delquota [-n|-b] path接触 quota 限制
setAcl path acl访问权限控制,只限制当前 path,不支持递归
getAcl path获取访问权限
redo cmdno重新执行指令
history指令执行历史
close关闭连接
quit退出 client
connect host:port连接 server

 

通过这些指令,就可以模拟各种分布式集群工作了,虽然使用简单,但是将这些简单的指令加以组合,将会实现非常强大的功能,比如著名的消息队列 kafka、nosql 存储引擎 hbase、分布式架构 hadoop 都是使用 zookeeper

 

欢迎关注微信公众号,以技术为主,涉及历史、人文等多领域的学习与感悟,每周三到七篇推文,只有全部原创,只有干货没有鸡汤

 






技术帖      apache      技术分享      集群      分布式      cluster      zookeeper      zk     


京ICP备15018585号