说明
ZooKeeper官方网址
ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。
ZooKeeper的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。
ZooKeeper包含一个简单的原语集，提供Java和C的接口。
ZooKeeper代码版本中，提供了分布式独享锁、选举、队列的接口。其中分布锁和队列有Java和C两个版本，选举只有Java版本。
作用
Zookeeper 从设计模式角度来看，是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper 就将负责通知已经在 Zookeeper 上注册的那些观察者做出相应的反应，从而实现集群中类似 Master/Slave 管理模式，关于 Zookeeper 的详细架构等内部细节可以阅读 Zookeeper 的源码
- 统一命名服务（Name Service）
- 配置管理（Configuration Management）
- 集群管理（Group Membership）
- 共享锁（Locks）
- 队列管理
特性
- 顺序性：
从同一客户端发出的请求，严格按照发送顺序进入Zookeeper，队列先入先出特性 - 原子性：
所有请求的响应结果在整个分布式集群环境中具有原子性 - 单一性：
无论客户端连接到那个Zookeeper服务器，每个客户端所看到的服务端数据模型是一致的，不可能出现两种不同的数据状态。 - 可靠性：
一旦服务器数据状态发生了变化，就立即存储起来，触发此时有另一个请求对其进行了变更，否则数据一定是可靠的。 - 实时性：
一个请求被成功处理后，客户端立刻获取服务端的最新数据状态。
安装与配置
简单起见，只部署了单机模式。
从官网获取稳定的版本，我这里使用的是zookeeper-3.4.9
- 在conf目录下，以生成zoo.cfg文件
# The number of milliseconds of each tick
# 这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
dataDir=E:\\data\\zookeeper\\data
dataLogDir=E:\\data\\zookeeper\\log
# 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
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
主要是设置数据路径，Log路径
- 启动
运行bin/zkServer.cmd
客户端连接
public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
// 创建一个与服务器的连接
ZooKeeper zk = new ZooKeeper("192.168.139.42:2181",3000,
new Watcher() {
// 监控所有被触发的事件
public void process(WatchedEvent event) {
System.out.println("已经触发了" + event.getType() + "事件！");
}
});
// 创建一个目录节点
zk.create("/testRootPath", "我的的测试结果".getBytes(), Ids.OPEN_ACL_UNSAFE,
CreateMode.PERSISTENT);
// 创建一个子目录节点
zk.create("/testRootPath/testChildPathOne", "这个数据是什么东西".getBytes(),
Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
System.out.println(new String(zk.getData("/testRootPath",false,null)));
// 取出子目录节点列表
System.out.println(zk.getChildren("/testRootPath",true));
// 修改子目录节点数据
zk.setData("/testRootPath/testChildPathOne","modifyChildDataOne".getBytes(),-1);
System.out.println("目录节点状态：["+zk.exists("/testRootPath",true)+"]");
// 创建另外一个子目录节点
zk.create("/testRootPath/testChildPathTwo", "testChildDataTwo".getBytes(),
Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
System.out.println(new String(zk.getData("/testRootPath/testChildPathTwo",true,null)));
// 删除子目录节点
zk.delete("/testRootPath/testChildPathTwo",-1);
zk.delete("/testRootPath/testChildPathOne",-1);
// 删除父目录节点
zk.delete("/testRootPath",-1);
// 关闭连接
zk.close();
}
需要依赖lib目录下的jar包
树状模型
ZooKeeper内部拥有一个树状的内存模型，类似于文件系统，有若干个目录，每个目录下有若干文件。
我们先看看下面几个概念
- ZNode：
在ZooKeeper中目录和文件统称为ZNode，每个ZNode有对应的目录及其包含的数据。 - Session
当客户端与服务端建立连接后，服务端将为客户端创建一个Session，客户端对ZNode的所有操作都在这个Session中完成 - 节点类型
ZNode节点有几种类型，每种类型在会话结束后会有不同的逻辑
Presistent（持久节点）：会话结束后，该节点不会被删除
Persistent Sequential（持久顺序节点）：会话结束后，该节点不会被删除，节点名中带自增后缀
Ephemeral（临时节点）：当会话结束后，该节点将会被删除
Ephemeral Sequential（临时顺序节点）：当会话结束后，该节点将会被删除，节点名中带有自增后缀
