zookeeper是什么?
zookeeper
我们可以把zookeeper理解为类似Linux的文件系统的东西(注意是文件系统而不是Linux),它是由一个个目录和附着在目录上面的数据组成的(/opt/jdk是目录,在Linux中这个目录里面可以放文件,同样的zookeeper的目录上面也可以放数据,但是数据的大小不要超过1M).在zookeeper中,我们可以创建目录,也可以删除目录,可以查目录里面的数据,也可以往目录里面放数据.
节点(目录)类型
- 临时节点
当客户端与zookeeper连接成功后会产生一个会话，当客户端（我们自己的集群服务器）与zookeeper的会话结束后,临时节点会被删除;临时节点不允许有子节点.我们可以通过这个特性感知哪些集群（服务器）还活着。 - 临时顺序节点
当我们创建创建一个/zk的临时顺序节点的时候，实际创建出来的是一个/zk0000000001的节点，当我们再创建一个/zk的临时顺序节点的时候，实际创建出来的是/zk0000000002的节点，以此类推。顺序节点在分布式锁的时候很有用。 - 永久节点
和临时节点相反，永久节点就算是会话结束也不会消失，只有当我们手动delete的时候才会消失。 - 永久顺序节点
zookeeper能做什么?
看了上面的介绍,你可能会觉得zookeeper就是用来存放数据的.其实zookeeper远远不止这么简单.zookeeper有以下几个作用:
配置管理
几个服务器共用一份配置文件,我们可以把配置文件copy后放到各个服务器中,也可以把参数配置到zookeeper中,让服务器自己来zookeeper中读取,这样的好处是当我们要修改某个参数的配置时,不需要去修改每一个服务器的配置,只需要修改zookeeper的即可.
命名服务
类似于DNS服务,ip又臭又长,很难记住,但是我们可以配置一个简单的域名和这个ip关联起来,利用域名去寻找ip.假如现在有几个服务器提供相同的rmi服务,我们想随机调用某一台机的rmi,而不是指定ip去访问,这时候我们可以用zookeeper注册一个目录(假如目录名为services),然后用各个服务器把自己的ip+端口注册为这个目录的子目录,这时候我们就可以用目录名(services)来找到他的服务器列表,然后随机抽一个服务器进行访问.
分布式锁
如果只有一台机器,我们可以用synchronized来保证高并发下代码的正确执行,但是如果相同的代码部署在多台机器上,我们就无法用synchronized了.这时候我们可以用zookeeper来实现分布式锁.zookeeper的做法是每个任务都会创建一个顺序节点，然后获取顺序节点的列表，对节点进行排序，检查节点顺序是不是最小的，执行任务，删除节点；如果不是最小的，会监听（exist）比它小一级的那个节点是否被删除，当监听的那个节点被删除了，执行任务，删除节点。
集群管理
感知集群中机器的情况，当有机器进来或者退出去的时候，集群能够做出处理。
zookeeper的配置
zookeeper有两个比较重要的配置文件，第一个是安装目录下的conf文件夹里面的zoo.cfg，另一个是安装目录下的data文件夹下的myid。
zoo.cfg(伪集群下的配置)
# 时间单位定量,比如 tickTime = 2000,表示 1tick = 2000ms,zookeeper里面是用tick来做时间单位的
tickTime=2000
# 选举leader的初始延时。由于服务器启动加载数据需要一定的时间（尤其是配置数据非常多），因此在选举 Leader后立即同步数据前需要一定的时间来完成初始化。可以适当放大一点。延时时间为initLimit*tickTime，也即此数值为 tickTime的次数
initLimit=10
# follower和leader的心跳时间,以tick为单位
syncLimit=5
# 存放内存数据结构的snapshot，就是目录树的snapshot
dataDir=/usr/local/server/zookeeper-3.4.10.1/data
# 存放顺序的日志文件(WAL)，每次create，setData等操作时都会记入日志里面
dataLogDir=/usr/local/server/zookeeper-3.4.10.1/logs
# 客户端（集群）连接zookeeper的端口号
clientPort=2181
# 配置zookeeper集群（不是客户端服务器集群）列表，通常是 server.X=ip:A:B,其中，X是myid，A是follower和leader交换信息的端口，B是选举端口
server.0=localhost:2287:3387
server.1=localhost:2288:3388
server.2=localhost:2289:3389
# 客户端的连接数
maxClientCnxns=60
# 每一个小时清理一次日志
autopurge.purgeInterval=1
# 每次清理日志留下3个snapshot
autopurge.snapRetainCount=3
#客户端连zookeeper的时候会设置一个sessionTimeout,如果超过这个时间client和zookeeper没有联系,则把这个session timeout置为过期,如果这个session在zookeeper上面有临时节点,则会被删除.
minSessionTimeout=
maxSessionTimeout=
myid
存放在dataDir指定的目录下，对应server.X中X的数字。在zookeeper选举中起到作用。
zookeeper的命令
启动zookeeper sh zkServer.sh start（zkServer在bin目录下）
关闭zookeeper sh zkServer.sh stop
连接客户端 sh zkCli.sh -server ip:port
命令
在linux中连接客户端成功后，即可用以下命令
create
create /zk/haha null 创建了一个/zk/haha的节点，不带数据
create -e /zk/haha null 创建一个临时节点
create -s /zk/haha null 创建一个顺序节点
get
get /zk/haha 获取某个节点的数据
get /zk/haha
#/zk/haha对应的数据,这里数据为空
null
# 创建该节点的zxid
cZxid = 0x10000001a
# 创建节点的时间
ctime = Fri May 11 22:35:31 CST 2018
# 更新该节点的zxid(与数据有关)
mZxid = 0x10000001a
# 更新该节点的时间
mtime = Fri May 11 22:35:31 CST 2018
# 更新该节点的zxid(与子节点有关)
pZxid = 0x100000128
# 更新子节点的次数
cversion = 78
# 更新数据的次数
dataVersion = 0
#权限更新次数
aclVersion = 0
ephemeralOwner = 0x0
# 数据长度
dataLength = 4
# 子节点的数量
numChildren = 0
ls
ls /zk/haha 查看某个节点的子节点
set
set /zk/haha 2 给/zk/haha的节点设置数据为2
delete
delete /zk/haha 删除节点
java api
maven
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.9</version>
</dependency>
连接zookeeper
//path: path=server + port,zookeeper集群的地址(如果有多个地址用,隔开)
//timeout : 最长尝试连接时间,当超过这个时间会报错,ms计
//new Watcher() : 监控事件, 一次性,
new Zookeeper(String path, int timeout, new Watcher());
关闭zookeeper
zk.close();
添加节点
//path : 节点目录
//data : 节点数据
//ACL : 权限,如果没有权限,我们写 ZooDefs.Ids.OPEN_ACL_UNSAFE
//CreateMode : 节点类型 PERSISTENT:永久节点;PERSISTENT_SEQUENTIAL:永久顺序节点;EPHEMERAL:临时节点;EPHEMERAL_SEQUENTIAL:临时顺序节点
zk.create(String path, String data, ArrayList<ACL> acls, CreateMode createMode)
删除节点
//path : 节点目录
//节点版本号,当版本号一致的时候才删除成功,不如不需要验证写 -1
zk.delete(String path, int version)
修改节点
zk.setData(String path, String data, int version)
查询节点的子节点信息
zk.getChildren(String path, new Wather());
zk.getChildren(String path, boolean flag);
检查节点是否存在
zk.exist(String path, new Wather());
zk.exist(String path, boolean flag);
zookeeper的选举
用zookeeper实现rmi的分布式协调
用zookeeper实现分布式 锁
网友评论