ZooKeeper is a centralized service for maintaining configuration information, naming, providing distributed synchronization, and providing group services. All of these kinds of services are used in some form or another by distributed applications. Each time they are implemented there is a lot of work that goes into fixing the bugs and race conditions that are inevitable. Because of the difficulty of implementing these kinds of services, applications initially usually skimp on them, which make them brittle in the presence of change and difficult to manage. Even when done correctly, different implementations of these services lead to management complexity when the applications are deployed. 

ZooKeeper用于维护配置信息、命名、提供分布式同步和提供组服务的集中服务。所有这些类型的服务都以某种形式被分布式应用程序使用。每次实现，都会有大量的工作来修复不可避免的错误和竞争条件。由于实现这些服务的困难，应用程序最初通常会忽略这些服务，这使得它们变得脆弱和难以管理。即使这些服务得到了正确的实施，这些服务的不同实现也会导致管理的复杂性

zookeeper由雅虎研究院开发，由雅虎研究院开发 Google Chubby实现开源，后来托管 Apache,于2010年11月正式成为apache的顶级项目

在大数据生态系统中，许多组件被命名为一些动物或昆虫，如hadoop大象，hive就是蜂巢，zookeeper即管理员，顾名思义，即使管理大数据生态系统各组件的管理员，如下所示：

[外链图片存储失败，源站可能有防盗链机制，建议保存图片直接上传(img-HyFodBZ7-1657433838494)(assets/zookeeper-1.png)]

zookeepepr是经典分布式数据一致性解决方案致力于为分布式应用程序提供高性能、高可用性和严格顺序访问控制的分布式协调存储服务。

zooKeeper致力于为分布式应用提供高性能、高可用性、严格顺序访问控制的分布式协调服务

1. 高性能
   • zookeeper存储全量数据内存直接服务于客户端的所有非事务请求，特别是阅读应用场景
2. 高可用
   • zookeeper一般集群提供外部服务，一般3~5台机可以形成可用的台机 Zookeeper当集群结束时，每台机器将在内存中保持当前的服务器状态，并保持每台机器之间的通信。只要集群中一半以上的机器能够正常工作，整个集群就能够正常提供外部服务
3. 严格顺序访问
   • 对客户端的每个更新请求，Zookeeper全球唯一的递增编号将被分配，反映了所有事务操作的顺序

zookeeper数据结点可视为树状结构（或目录），树中的每个结点称为znode (即zookeeper node)，一个znode由多个子结点组成。zookeeper结点在结构上呈树状；

使用路径path来定位某个znode，比如/ns-1/itcast/mysqml/schemal1/table1，此处ns-1，itcast、mysql、schemal1、table1根结点、2级结点、3级结点以及4级结点；其中ns-1是itcast的父结点，itcast是ns-1的子结点，itcast是mysql的父结点…以此类推

znode，间距文件和目录两种特点，即像文件一样维护着数据、元信息、ACL、时间戳等数据结构，又像目录一样可以作为路径标识的一部分

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Kg7fbtk7-1657433838498)(assets/zookeeper-4.png)]

那么如何描述一个znode呢？一个znode大体上分为3个部分：

• 结点的数据：即znode data (结点path，结点data)的关系就像是Java map 中的 key value 关系
• 结点的子结点children
• 结点的状态stat：用来描述当前结点的创建、修改记录，包括cZxid、ctime等

在zookeeper shell 中使用 get 命令查看指定路径结点的data、stat信息

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-omwEyzAm-1657433838499)(assets/zookeeper-5.png)]

属性说明：

结点的各个属性如下。其中重要的概念是Zxid(Zookeeper Transaction ID)，Zookeeper结点的每一次更改都具有唯一的Zxid，如果Zxid-1 小于 Zxid-2 ，则Zxid-1 的更改发生在 Zxid-2 更改之前

https://zookeeper.apache.org/doc/r3.4.14/zookeeperProgrammers.html#sc_zkDataModel_znodes

• cZxid数据结点创建时的事务ID——针对于zookeeper数据结点的管理：我们对结点数据的一些写操作都会导致zookeeper自动地为我们去开启一个事务，并且自动地去为每一个事务维护一个事务ID
• ctime数据结点创建时的时间
• mZxid数据结点最后一次更新时的事务ID
• mtime数据结点最后一次更新时的时间
• pZxid数据节点最后一次修改此znode子节点更改的zxid
• cversion子结点的更改次数
• dataVersion结点数据的更改次数
• aclVersion结点的ACL更改次数——类似linux的权限列表，维护的是当前结点的权限列表被修改的次数
• ephemeralOwner如果结点是临时结点，则表示创建该结点的会话的SessionID；如果是持久结点，该属性值为0
• dataLength数据内容的长度
• numChildren数据结点当前的子结点个数

结点类型

zookeeper中的结点有两种，分别为临时结点和永久结点。结点的类型在创建时被确定，并且不能改变

• 临时节点：
  • 该节点的生命周期依赖于创建它们的会话。一旦会话( Session）结束，临时节点将被自动删除，当然可以也可以手动删除。虽然每个临时的 Znode都会绑定到一个客户端会话，但他们对所有的客户端还是可见的。另外，Zookeeper的临时节点不允许拥有子节点
• 持久化结点：
  • 该结点的生命周期不依赖于会话，并且只有在客户端显示执行删除操作的时候，它们才能被删除

测试系统环境centos7.3

zookeeper:zookeeper-3.4.10.tar.gz

jdk:jdk-8u131-linux-x64.tar.gz

http://archive.apache.org/dist/zookeeper/

1. 在centos 中使用 root用户创建 zookeeper用户，用户名:zookeeper 密码:zookeeper

   • useradd zookeeper
     passwd zookeeper
     su zookeeper
     

2. zookeeper底层依赖于jdk，zookeeper用户登录后，根目录下先进行jdk 的安装，jdk使用 jdk-8u131-linux-x64.tar.gz

   • tar -zxf tar.gz
     

3. 配置jdk 环境变量

   • vi /etc/profile
     JAVA_HOME=/home/zookeeper/jdk1.8.0_131
     export JAVA_HOME
     
     PATH=$JAVA_HOME/bin:$PATH
     export PATH
     
     souce /etc/profile
     

4. 检测jdk安装

   • java -version // 如果反馈了Java信息，则成功

5. zookeeper 上传解压

   • tar -zxf tar.gz

6. 为zookeeper准备配置文件

   • # 进入conf目录
     cd /home/zookeeper/zookeeper-3.4.10/conf
     # 复制配置文件
     cp zoo_sampe.cfg zoo.cfg
     # zookeeper 根目录下创建data目录
     mkdir data
     # vi 配置文件中的dataDir
     # 此路径用于存储zookeeper中数据的内存快照、及事务日志文件，虽然zookeeper是使用内存的，但是需要持久化一些数据来保证数据的安全，和redis一样
     dataDir=/home/zookeeper/zookeeper-3.4.10/data
     

7. 启动zookeeper

   • # 进入zookeeper的bin目录
     cd /home/zookeeper/zookeeper-3.4.10/bin
     # 启动zookeeper
     ./zkServer.sh start
     
     # 启动: zkServer.sh start
     # 停止: zkServer.sh stop
     # 查看状态：zkServer.sh status
     
     # 进入zookeeper 内部
     ./zkCli.sh
     

zookeeper——getting started——https://zookeeper.apache.org/doc/r3.4.14/zookeeperStarted.html#sc_FileManagement

查询

get /hadoop 查看结点的数据和属性 stat /hadoop 查看结点的属性

创建

创建结点并写入数据：

create [-s] [-e] path data # 其中 -s 为有序结点，-e 临时结点（默认是持久结点）

create /hadoop "123456"  # 此时，如果quit退出后再./ZkCient.sh 登入
                         # 再用输入 get /hadoop 获取，结点依然存在(永久结点)
				       
create -s /a "a"         # 创建一个持久化有序结点，创建的时候可以观察到返回的数据带上了一个id 
create -s /b "b"         # 返回的值，id递增了

create -s -e /aa "aa"    # 依然还会返回自增的id，quit后再进来，继续创建，id依然是往后推的

create /aa/xx            # 继续创建结点，可以看到pZxid变化了

更新

更新结点的命令是set，可以直接进行修改，如下：

set path [version]

set /hadoop "345"        # 修改结点值

set /hadoop "hadoop-x" 1 # 也可以基于版本号进行更改，类似于乐观锁，当传入版本号(dataVersion)
                         # 和当前结点的数据版本号不一致时，zookeeper会拒绝本次修改

删除

删除结点的语法如下：

delete path [version] 和 set 方法相似，也可以传入版本号

delete /hadoop           # 删除结点
delete /hadoop 1         # 乐观锁机制，与set 方法一致

要想删除某个结点及其所有后代结点，可以使用递归删除，命令为 rmr path

查看结点列表

ls /hadoop               # 可以查看结点的列表
ls2 /hadoop              # 可以查看结点的列表以及目标结点的信息

ls /                     # 根节点

监听器get path [watch] | stat path [watch]

https://zookeeper.apache.org/doc/r3.4.14/zookeeperProgrammers.html#sc_ZooKeeperAccessControl

zookeeper 类似文件系统，client可以创建结点、更新结点、删除结点，那么如何做到结点的权限控制呢？

zookeeper的 access control list 访问控制列表可以做到这一点

acl权限控制，使用scheme：id：permission 来标识，主要涵盖3个方面：

https://zookeeper.apache.org/doc/r3.4.14/zookeeperProgrammers.html#sc_BuiltinACLSchemes

• 权限模式(scheme)：授权的策略
• 授权对象(id)：授权的对象
• 权限(permission)：授予的权限

其特性如下：

• zookeeper的权限控制是基于每个znode结点的，需要对每个结点设置权限

• 每个znode 支持多种权限控制方案和多个权限

• 子结点不会继承父结点的权限，客户端无权访问某结点，但可能可以访问它的子结点：

  例如setAcl /test2 ip:192.168.133.133:crwda // 将结点权限设置为Ip：192.168.133.133 的客户端可以对节点进行
  增删改查和管理权限

权限模式

• 采用何种方式授权

• 方案	描述
  world	只有一个用户：anyone，代表登录zookeeper所有人(默认)
  ip	对客户端使用IP地址认证
  auth	使用已添加认证的用户认证
  digest	使用"用户名：密码"方式认证

授权对象

• 给谁授予权限
• 授权对象ID是指，权限赋予的实体，例如：IP地址或用户

授权的权限

• 授予什么权限

• create、delete、read、writer、admin也就是 增、删、查、改、管理权限，这5种权限简写为 c d r w a，注意：
  这五种权限中，有的权限并不是对结点自身操作的例如：delete是指对子结点的删除权限

  可以试图删除父结点，但是子结点必须删除干净，所以delete的权限也是很有用的

• 权限	ACL简写	描述
  create	c	可以创建子结点
  delete	d	可以删除子结点(仅下一级结点)
  read	r	可以读取结点数据以及显示子结点列表
  write	w	可以设置结点数据
  admin	a	可以设置结点访问控制权限列表

授权的相关命令

• 命令	使用方式	描述
  getAcl	getAcl	读取ACL权限
  setAcl	setAcl	设置ACL权限
  addauth	addauth	添加认证用户

./zkServer.sh -server 192.168.133.133 可以远程登录

world权限模式

• getAcl /node // 读取权限信息
• setAcl /node world:anyone:drwa // 设置权限(禁用创建子结点的权限)

ip模式

./zkServer.sh -server 192.168.133.133 可以远程登录

• setAcl /hadoop ip:192.168.133.133:drwa
• 如果在两台不同的虚拟机中，另一台用远程连接的模式，进行上面这条命令，那么只会有一台被授权
• 需要两台虚拟机一起授权的话需要用逗号将授权列表隔开：setAcl /hadoop ip:192.168.133.133:cdrwa,ip:192.168.133.132:cdrwa

auth认证用户模式

addauth digest :

setAcl auth::

• create /hadoop "hadoop"           # 初始化测试用的结点
  addauth digest itcast:123456      # 添加认证用户
  setAcl /hadoop auth:itcast:cdrwa  # 设置认证用户
  quit                              # 退出后再./zkCli.sh 进入
  get /hadoop                       # 这个时候就没有权限了，需要再次认证
  addauth digest itcast:123456      # 认证，密码错了的话 zookeeper 不会报错，但是不能认证
  get /hadoop
  

Digest授权模式

setAcl digest:::

• 这里的密码是经过SHA1以及BASE64处理的密文，在shell 中可以通过以下命令计算：

  • echo -n <user>:<password> | openssl dgst -binary -sha1 | openssl base64
    

  • # 计算密码
    echo -n itcast:12345 | openssl dgst -binary -sha1 | openssl base64
    # 获取密码，设置权限列表
    setAcl /hadoop digest:itcast:qUFSHxJjItUW/93UHFXFVGlvryY=:cdrwa
    # 现在想要get /hadoop 需要登录了
    addauth digest itcast:12345
    get /hadoop
    

多种授权模式

仅需逗号隔开

•  setAcl /hadoop ip:192.168.133.132:cdrwa,auth:hadoop:cdrwa,digest:itcast:673OfZhUE8JEFMcu0l64qI8e5ek=:cdrwa
  

• zookeeper的权限管理模式有一种叫做super，该模式提供一个超管，可以方便的访问任何权限的节点

  假设这个超管是supper:admin，需要为超管生产密码的密文

  echo -n super:admin | openssl dgst -binary -sha1 | openssl base64
  

• 那么打开zookeeper目录下/bin/zkServer.sh服务器脚本文件，找到如下一行：

   /nohup # 快速查找，可以看到如下
   nohup "$JAVA" "-Dzookeeper.log.dir=${ZOO_LOG_DIR}" "-Dzookeeper.root.logger=${ZOO_LOG4J_PROP}"
  

• 这个就算脚本中启动zookeeper的命令，默认只有以上两个配置项，我们需要添加一个超管的配置项

  "-Dzookeeper.DigestAuthenticationProvider.superDigest=super:xQJmxLMiHGwaqBvst5y6rkB6HQs="
  

• 修改后命令变成如下

  nohup "$JAVA" "-Dzookeeper.log.dir=${ZOO_LOG_DIR}" "-Dzookeeper.root.logger=${ZOO_LOG4J_PROP}" "-Dzookeeper.DigestAuthenticationProvider.superDigest=super:xQJmxLMiHGwaqBvst5y6rkB6HQs="
  

• # 重起后，现在随便对任意节点添加权限限制
  setAcl /hadoop ip:192.168.1.1:cdrwa # 这个ip并非本机
  # 现在当前用户没有权限了
  getAcl /hadoop
  # 登录超管
  addauth digest super:admin
  # 强行操作节点
  get /hadoop
  

<dependency>
            <groupId>com.101tecgroupId>
            <artifactId>zkclientartifactId>
            <exclusions>
                <exclusion>
                    <artifactId>zookeeperartifactId>
                    <groupId>org.apache.zookeepergroupId>
                exclusion>
                <exclusion>
                    <artifactId>log4jartifactId>
                    <groupId>log4jgroupId>
                exclusion>
                <exclusion>
                    <artifactId>slf4j-log4j12artifactId>
                    <groupId>org.slf4jgroupId>
                exclusion>
                <exclusion>
                    <artifactId>slf4j-apiartifactId>
                    <groupId>org.slf4jgroupId>
                exclusion>
            exclusions>
            <version>0.9version>
        dependency>
        <dependency>
            <artifactId>zookeeperartifactId>
            <exclusions>
                <exclusion>
                    <artifactId>log4jartifactId>
                    <groupId>log4jgroupId>
                exclusion>
                <exclusion>
                    <artifactId>slf4j-log4j12artifactId>
                    <groupId>org.slf4jgroupId>
                exclusion>
            exclusions>
            <groupId>org.apache.zookeepergroupId>
            <version>3.4.10version>
        dependency>

zonde 是 zookeeper 集合的核心组件， zookeeper API 提供了一小组使用 zookeeper 集群来操作znode 的所有细节

客户端应该遵循以下步骤，与zookeeper服务器进行清晰和干净的交互

• 连接到zookeeper服务器。zookeeper服务器为客户端分配会话ID
• 定期向服务器发送心跳。否则，zookeeper 服务器将过期会话ID，客户端需要重新连接
• 只要会话Id处于活动状态，就可以获取/设置znode
• 所有任务完成后，断开与zookeeper服务器连接，如果客户端长时间不活动，则zookeeper服务器将自动断开客户端

这部分，官网的解释十分稀少https://zookeeper.apache.org/doc/r3.4.14/zookeeperStarted.html#sc_ConnectingToZooKeeper

[zkshell: 0] help
ZooKeeper host:port cmd args
    get path [watch]
    ls path [watch]
    set path data [version]
    delquota [-n|-b] path
    quit
    printwatches on|off
    create path data acl
    stat path [watch]
    listquota path
    history
    setAcl path acl
    getAcl path
    sync path
    redo cmdno
    addauth scheme auth
    delete path [version]
    deleteall path
    setquota -n|-b val path

Zookeeper(String connectionString, int sessionTimeout, watcher watcher)

• connectionString - zookeeper 主机
• sessionTimeout - 会话超时
• watcher - 实现"监听器" 对象。zookeeper集合通过监视器对象返回连接状态

public static void main(String[] args) throws IOException, InterruptedException { 
        
        CountDownLatch countDownLatch = new CountDownLatch(1);

        ZooKeeper zookeeper = new ZooKeeper("192.168.133.133:2181", 5000, (WatchedEvent x) -> { 
        
            if (x.getState() == Watcher.Event.KeeperState.SyncConnected) { 
        
                System.out.println("连接成功");
                countDownLatch.countDown();
            }
        });
        countDownLatch.await();
        System.out.println(zookeeper.getSessionId());
        zookeeper.close();
    }

• // 同步
  create(String path, byte[] data, List<ACL> acl, CreateMode createMode)
  // 异步
  create(String path, byte[] data, List<ACL> acl, CreateMode createMode,
        AsynCallback.StringCallback callBack, Object ctx)
  

• 参数	解释
  path	znode 路径
  data	数据
  acl	要创建的节点的访问控制列表。zookeeper API 提供了一个静态接口 ZooDefs.Ids 来获取一些基本的acl列表。例如，ZooDefs.Ids.OPEN_ACL_UNSAFE返回打开znode的acl列表
  createMode	节点的类型，这是一个枚举
  callBack	异步回调接口
  ctx	传递上下文参数

示例：