1.Zookeeper介绍
ZooKeeper 是一个开源的分布式协调框架，是Apache Hadoop 的一个子项目，主要用来解决分布式集群中应用系统的一致性问题。Zookeeper 的设计目标是将那些复杂目容易出错的分布式一致性服务封装起来，构成一高效可靠的原语集，并以一系列简单易用的接口提供给用户使用。
Zookeeper本质上是一个分布式的小文件存储系统(Zookeeper=文件系统+监听机制)。提供基于类似于文件系统的目录树式的数据存储，并且可以对树中的节点进行有效管理，从而用来维护和监控存储的数据的状态变化。通过监控这些数据状态的变化，从而可以达到基于数据的集群管理、统一命名服务、分布式配置管理、分布式消息队列、分布式锁、分布式协调等功能。
Zookeeper从设计模式角度来理解:是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper 就将负责通知已经在Zookeeper上注册的那些观察者做出相应的反应。
2.Zookeeper快速开始
2.1 Zookeeper安装
下载地址: https://zookeeper.apache.org/releases.html
运行环境: jdk8
1)修改配置文件
解压安装包后进入conf目录，复制zoo sample.cfg，修改为zoo.cfg
2)启动zookeeper server
#可以通过 bin/zkServer.sh 来查看都支持哪些参数
#默认加载配置路径conf/zoo.cfg
bin/zkServer.sh start
bin/zkServer.sh start conf/my_zoo.cfg
# 查看zookeeper状态
bin/zkServer.sh status
3)启动zookeeper client连接Zookeeper server
2.3GUI工具
Zookeeper图形化工具: Zoolnspector
Zookeeper图形化丁具: 开源的prettyZoo
Zookeeper图形化工具: 收费的ZooKeeperAssistant
3.ZooKeeper数据结构
ZooKeeper 数据模型的结构与Unix 文件系统很类似，整体上可以看作是一棵树，每个节点称做一个ZNode。
ZooKeeper的数据模型是层次模型，层次模型常见于文件系统。层次模型和key-value模型是两种主流的数据模型。ZooKeeper使用文件系统模型主要基于以下两点考虑:
1.文件系统的树形结构便于表达数据之间的层次关系
2.文件系统的树形结构便于为不同的应用分配独立的命名空间( namespace)
ZooKeeper的次模型称作Data Tree，Data Tree的每个节点叫作Znode。不同于文件系统，每人节点都可以保存数据，每一个ZNode 默认能够存储1MB 的数据，每个ZNode 都可以通过其路径唯-标识，每个节点都有一个版本(version)，版本从0开始计数。
3.1节点分类
zookeeper存在几种不同的节点类型，他们具有不同的生命周期:
一个znode可以使持久性的，也可以是临时性的
1.持久节点(PERSISTENT): 这样的znode在创建之后即使发生ZooKeeper集群宕机或者client宕机也不会丢失.
2.**临时节点(EPHEMERAL):**dlient宕机或者dlient在指定的timeout时间内没有给ZooKeeper集群发消息，这样的znode就会消失。
如果上面两种znode具备顺序性，又有以下两种znode：
3.**持顺序节点(PERSISTENT SEQUENTIAL)**: znode除了具备持久性znode的特点之外，znode的名字具备顺序性.
4.**临时顺序节点(EPHEMERAL SEQUENTIAL)**: node除了具备临时性znode的特点之外，zorde的名字具备顺序性.
zookeeper主要用到的是以上4种节点
5**.Container节点(3.5.3版本新增):**Container容器节点，当容器中没有任何子节点，该容器节点会被zk定期删除(定时任务默认60s 检查一次)。和持久节点的区别是 ZK 服务端启动后，会有一个单独的线程去扫描所有的容器节点，当发现容器节点的子节点数量为0时，会自动删除该节点。可以用于leader 或者锁的场景中。
6.**TTL节点: **带过期时间节点，默认禁用，需要在00.cig中添加 extendedTypesEnabledetrue 开启。
**注意:**TTL不能用于临时节点
节点状态信息
类似于树状结构，节点下面是可以存储一些信息和属性的。可以通过stat命令来进行查看。
** cZxid:**Znode创建的事务id.
** ctime:**节点创建时的时间戳.
** mZxid: **Znode被修改的事务id，即每次对znode的修改都会更新mZxid.
对于zk来说，每次的变化都会产生一个唯一的事务id,zxid (Zookeeper Transaction ld) ，通过zxid，可以确定更新操作的先后顺序。例如，如果zxid1小于zxid2，说明zxid1操作先于zxid2发生，zxid对于整个zk都是唯一的，即使操作的是不同的znode。
** pZxid:**表示该节点的子节点列表最后一次修改的事务1D，添加子节点或删除子节点就会影响子节点列表，但是修改子节点的数据内容则不影响该ID注意: 只有子节点列表变更了才会变更pzxid，子节点内容变更不会影响pzxid)。
**mtime: **节点最新一次更新发生时的时间戳
** cversion: **子节点的版本号。当znode的子节点有变化时，cversion 的值就会增加1。
**dataVersion:**数据版本号，每次对节点进行set操作，dataVersion的值都会增加1即使设置的是相同的数据)，可有效避免了数据更新时出现的先后顺序问题。
** ephemeral0wner：**如果该节点为临时节点ephemeralOwner值表示与该节点绑定的session id。如果不是ephemeral0wner值为0(持久节点)。
在dlient和server通信之前,首先需要建立连接,该连接称为session。连接建立后,如果发生连接超时、授权失败,或者显式关闭连接连接便处于closed状态此时session结束
** dataLength :**数据的长度
**numChildren:**子节点的数量(只统计直接子节点的数量)
3.2监听机制详解
watch机制，顾名思义是一个监听机制。Zokeeper中的watch机制，必须客户端先去服务端注册监听，这样事件发送才会触发监听，通知给客户端。
监听的对象是事件，支持的事件类型如下:
None: 连接建立事件
NodeCreated:节点创建
NodeDeleted: 节点删除
NodeDataChanged: 节点数据变化
NodeChildrenChanged: 子节点列表变化
DataWatchRemoved: 节点监听被移除
ChildWatchRemoved: 子节点监听被移除
** 永久性Watch**
在被触发之后，仍然保留，可以继续监听ZNode上的变更，是Zookeeper 3.6.0版本新增的功能。
** addWatch的作用是针对指定节点添加事件监听，支持两种模式**
PERSISTENT，持久化订阅，针对当前节点的修改和删除事件，以及当前节点的子节点的删除和新增事件。
**PERSISTENT RECURSIVE，持久化递归订阅(默认)，**在PERSISTENT的基础上，增加了子节点修改的事件发，以及子节点的子节点的数据变化都会触发相关事件(满足递归订阅特性)
示例:协同服务
设计一个master-worker的组成员管理系统，要求系统中只能有一个master,master能实时获取系统中worker的情况保证组里面只有一个master的设计思路。
master监控worker状态的设计思路
** 示例:条件更新**
设想用znode /c实现一个counter，使用set命令来实现自增1操作。条件更新场景:
1.客户端1把/c更新到版本1，实现/c的自增1。
2客户端2把/c更新到版本2，实现/c的自增1。
3.客户端1不知道(C已经被客户端2 更新过了，还用过时的版本1是去更新/，更新失败。如果客户端1使用的是无条件更新，C就会更新为2，没有实现自增1。
使用条件更新可以避免出现客户端基于过期的数据进行数据更新的操作。
** 3.4应用场景详解**
** ** ZooKeeper适用于存储和协同相关的关键数据，不适合用于大数据量存储.有了上述众多节点特性，使得zookeeper 能开发不出不同的经典应用场景，比如:
** 注册中心
数据发布/订阅(常用于实现配置中心)
负载均衡
命名服务
分布式协调/通知
集群管理
Master选举
分布式锁
分布式队列**
统一命名服务
在分布式环境下，经常需要对应用/服务进行统一命名，便于识别。
例:IP不容易记住，而域名容易记住
利用 Zookeeper 顺序节点的特性，制作分布式的序列号生成器，或者叫 id 生成器。(分布式环境下使用作为数据库 id，另外一种是UUID(缺点:没有规律))，ZooKeeper 可以生成有顺序的容易理解的同时支持分布式环境的编号.
数据发布/订阅
** **数据发布订阅的一个常见的场景是配置中心，发布者把数据发布到 ZooKeeper 的一个或一系列的节点上，供订阅者进行数据订阅，达到动态获取数据的目的。
配置信息一般有几个特点
1.数据量小的KV
2.数据内容在运行时会发生动态变化
3.集群机器共享，配置一致
ZooKeeper采用的是推拉结合的方式
1.推服务端会推给注册了监控节点的客户端Watcher 事件通知
2.拉: 客户端获得通知后，然后主动到服务端拉取最新的数据
统一集群管理
分布式环境中，实时掌握每个节点的状态是必要的，可根据节点实时状态做出一些调整.
ZooKeeper可以实现实时监控节点状态变化:
可将节点信息写入ZooKeeper上的一个ZNode
监听这个ZNode可获取它的实时状态变化。
** 负载均衡**
在Zookeeper中记录每台服务器的访问数，让访问数最少的服务器去处理最新的客户端请求
** Master-Worker架构**
master-work是一个广泛使用的分布式架构master-work架构中有一个master负责监控worker的状态，并为worker分配任务。
在任何时刻，系统中最多只能有一个master，不可以出现两个master的情况，多个master共存会导致脑。
系统中除了处于active状态的master还有一个backup master，如果active master失败了，backup master可以很快的进入active状态
master实时监控worker的状态，能够及时收到worker成员变化的通知。master在收到worker成员变化的时候，通常重新进行任务的重新分配。
**3.5 ACL权限控制 **
zookeeper 的 ACL（Access Control List，访问控制表）权限在生产环境是特别重要的，ACL 权限可以针对节点设置相关读写等权限，保障数据安全性。
**ACL 构成 **
zookeeper 的 acl 通过 **[scheme:id:permissions] **来构成权限列表。
** scheme**：授权的模式，代表采用的某种权限机制，包括 world、auth、digest、ip、super 几种。
** id**：授权对象，代表允许访问的用户。如果我们选择采用 IP 方式，使用的授权对象可以是一个 IP 地址或 IP 地址 段；而如果使用 Digest 或 Super 方式，则对应于一个用户名。如果是 World 模式，是授权系统中所有的用户。
** permissions**：授权的权限，权限组合字符串，由 cdrwa 组成，其中每个字母代表支持不同权限， 创建权限 create(c)、删除权限 delete(d)、读权限 read(r)、写权限 write(w)、管理权限admin(a)。
**测试 **
取消节点的读权限后，读取/name节点没有权限
取消节点删除子节点的权限
**auth授权模式 **
创建用户
addauth digest fox:123456
设置权限
setAcl /name auth:fox:123456:cdrwa
# 加密
echo -n fox:123456 | openssl dgst -binary -sha1 | openssl base64
setAcl /name auth:fox:ZsWwgmtnTnx1usRF1voHFJAYGQU=:cdrwa
退出客户端，重新连接之后获取/name会没权限，需要添加授权用户。
digest授权模式
#设置权限
setAcl /tuling/fox digest:fox:ZsWwgmtnTnx1usRF1voHFJAYGQU=:cdrwa
**IP授权模式 **
setAcl /node-ip ip:192.168.109.128:cdwra
create /node-ip data ip:192.168.109.128:cdwra
多个指定IP可以通过逗号分隔， 如 setAcl /node-ip ip:IP1:rw,ip:IP2:a
**Super 超级管理员模式 **
这是一种特殊的Digest模式， 在Super模式下超级管理员用户可以对Zookeeper上的节点进行任何的操作。 需要在启动脚本上通过添加JVM 参数开启：
# DigestAuthenticationProvider中定义
-Dzookeeper.DigestAuthenticationProvider.superDigest=admin:<base64encoded(SHA1(123456))
**可插拔身份验证接口 **
ZooKeeper提供了一种权限扩展机制来让用户实现自己的权限控制方式。
要想实现自定义的权限控制机制，需要继承接口AuthenticationProvider，用户通过该接口实现自定义的权限控制。
public interface AuthenticationProvider {
// 返回标识插件的字符串
String getScheme();
// 将用户和验证信息关联起来
KeeperException.Code handleAuthentication(ServerCnxn cnxn, byte authData[]);
// 验证id格式
boolean isValid(String id);
// 将认证信息与ACL进行匹配看是否命中
boolean matches(String id, String aclExpr);
// 是否授权
boolean isAuthenticated();
}
**4. Zookeeper集群架构 **
**4.1 集群角色 **
**Leader： 领导者 **
事务请求（写操作）的唯一调度者和处理者，保证集群事务处理的顺序性；集群内部各个服务器的 调度者。对于create、setData、delete等有写操作的请求，则要统一转发给leader处理，leader需要 决定编号、执行操作，这个过程称为事务。
**Follower: 跟随者 **
处理客户端非事务（读操作）请求（可以直接响应），转发事务请求给Leader；参与集群Leader选举 投票。
**Observer: 观察者 **
对于非事务请求可以独立处理（读操作），对于事务性请求会转发给leader处理。Observer节点接收来自leader的inform信息，更新自己的本地存储，不参与提交和选举投票。通常在不影响集群事务处理能力的前提下提升集群的非事务处理能力。
#配置一个ID为3的观察者节点：
server.3=192.168.0.3:2888:3888:observer
**Observer应用场景： **
提升集群的读性能。因为Observer和不参与提交和选举的投票过程，所以可以通过往集群里面添加observer节 点来提高整个集群的读性能。
跨数据中心部署。 比如需要部署一个北京和香港两地都可以使用的zookeeper集群服务，并且要求北京和香港客 户的读请求延迟都很低。解决方案就是把香港的节点都设置为observer。
4.2 集群架构
leader节点可以处理读写请求，follower只可以处理读请求。follower在接到写请求时会把写请求转发 给leader来处理。
**Zookeeper数据一致性保证： **
** 全局可线性化(Linearizable )写入**∶先到达leader的写请求会被先处理，leader决定写请求的执行顺序。
** 客户端FIFO顺序**∶来自给定客户端的请求按照发送顺序执行。
**4.3 三节点Zookeeper集群搭建 **
环境准备：三台虚拟机
192.168.65.163
192.168.65.184
192.168.65.186
条件有限也可以在一台虚拟机上搭建zookeeper伪集群
**1) 修改zoo.cfg配置，添加server节点配置 **
# 修改数据存储目录
dataDir=/data/zookeeper
#三台虚拟机 zoo.cfg 文件末尾添加配置
server.1=192.168.65.163:2888:3888
server.2=192.168.65.184:2888:3888
server.3=192.168.65.186:2888:3888
server.A=B:C:D
A 是一个数字，表示这个是第几号服务器； 集群模式下配置一个文件 myid，这个文件在 dataDir
目录下，这个文件里面有一个数据 就是 A 的值，Zookeeper 启动时读取此文件，拿到里面的数
据与 zoo.cfg 里面的配置信息比较从而判断到底是哪个server。
B 是这个服务器的地址；
C 是这个服务器Follower与集群中的Leader服务器交换信息的端口；
D 是万一集群中的Leader服务器挂了，需要一个端口来重新进行选举，选出一个新的Leader，而
这个端口就是用来执行选举时服务器相互通信的端口。
**2）创建 myid 文件，配置服务器编号 **
在dataDir对应目录下创建 myid 文件，内容为对应ip的zookeeper服务器编号
cd /data/zookeeper
# 在文件中添加与 server 对应的编号（注意：上下不要有空行，左右不要有空格）
vim myid
注意：添加 myid 文件，一定要在 Linux 里面创建，在 notepad++里面很可能乱码
**3）启动zookeeper server集群 **
启动前需要关闭防火墙(生产环境需要打开对应端口)
# 分别启动三个节点的zookeeper server
bin/zkServer.sh start
# 查看集群状态
bin/zkServer.sh status
**常见问题： **
如果服务启动出现下面异常：
原因：
1. zoo.cfg配置错误
2. 防火墙没关
#centos7
# 检查防火墙状态
systemctl status firewalld
#关闭防火墙
systemctl stop firewalld
systemctl disable firewalld
4.4 Zookeeper四字命令使用
用户可以使用Zookeeper四字命令获取 zookeeper 服务的当前状态及相关信息。用户在客户端可以通 过 nc（netcat） 向 zookeeper 提交相应的命令。
安装 nc 命令：
# centos
yum install nc
四字命令格式：
echo [command] | nc [ip] [port]
ZooKeeper 常用四字命令主要如下：
https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_4lw
**开启四字命令 **
方法1： 在zoo.cfg 文件里加入配置项让这些指令放行
#开启四字命令
4lw.commands.whitelist=*
方法2：在zk的启动脚本zkServer.sh中新增放行指令
#添加JVM环境变量-Dzookeeper.4lw.commands.whitelist=*
ZOOMAIN="-Dzookeeper.4lw.commands.whitelist=* ${ZOOMAIN}"
**stat 命令 **
stat 命令用于查看 zk 的状态信息，实例如下：
echo stat | nc 192.168.65.186 2181
**ruok 命令 **
ruok 命令用于查看当前 zkserver 是否启动，若返回 imok 表示正常。
echo ruok | nc 192.168.65.186 2181
**4.5 Zookeeper选举原理 **
ZooKeeper的Leader选举过程是基于投票和对比规则的，确保集群中选出一个具有最高优先级的服务 器作为Leader来处理客户端请求。以服务启动期间选举为例：
**投票对比规则如下： **
首先比较epoch，选取具有最大epoch的服务器。epoch用于区分不同的选举轮次，每次重新选举时都会增加 epoch。
如果epoch相同，则比较zxid（事务ID），选取事务ID最大的服务器。zxid表示最后一次提交的事务ID。
如果zxid也相同，则比较myid（服务器ID），选取服务器ID最大的服务器。
/**
* Check if a pair (server id, zxid) succeeds our
* current vote.
*
*/
protected boolean totalOrderPredicate(long newId, long newZxid, long newEpoch, long
curId, long curZxid, long curEpoch) {
LOG.debug(
"id: {}, proposed id: {}, zxid: 0x{}, proposed zxid: 0x{}",
newId,
curId,
Long.toHexString(newZxid),
Long.toHexString(curZxid));
if (self.getQuorumVerifier().getWeight(newId) == 0) {
return false;
}
/*
* We return true if one of the following three cases hold:
* 1- New epoch is higher
* 2- New epoch is the same as current epoch, but new zxid is higher
* 3- New epoch is the same as current epoch, new zxid is the same
* as current zxid, but server id is higher.
*/
return ((newEpoch > curEpoch)
|| ((newEpoch == curEpoch)
&& ((newZxid > curZxid)
|| ((newZxid == curZxid)
&& (newId > curId)))));
}
**zxid的数据结构 **
根据这个工具类，可以得出zxid的数据结构的一些信息。
1. zxid是一个64位的整数，由高32位的epoch和低32位的counter组成。
2. epoch表示ZooKeeper服务器的逻辑时期（logical epoch），它是一个相对时间的概念，用于区分不同的 Leader选举周期。
3. counter是一个在每个时期（epoch）内递增的计数器，用于标识事务的顺序。
public class ZxidUtils {
public static long getEpochFromZxid(long zxid) {
return zxid >> 32L;
}
public static long getCounterFromZxid(long zxid) {
return zxid & 0xffffffffL;
}
public static long makeZxid(long epoch, long counter) {
return (epoch << 32L) | (counter & 0xffffffffL);
}
public static String zxidToString(long zxid) {
return Long.toHexString(zxid);
}
}
版权归原作者 长情知热爱 所有， 如有侵权，请联系我们删除。