Zookeeper环境搭建和基本使用回顾

• 通过⽹络进⾏信息共享

这就像现实中，开发 leader 在会上把任务传达下去，组员通过听 leader 命令或者看 leader 的邮件知道⾃⼰要⼲什么。当任务分配有变化时， leader 会单ᇿ告诉组员，或者再次召开会议。信息通过⼈与⼈之间 的直接沟通，完成传递。

• 通过共享存储

这就好⽐开发 leader 按照约定的时间和路径，把任务分配表放到了 svn 上，组员每天去 svn 上拉取最新的任务分配表，然后⼲活。其中 svn 就是共享存储。更好⼀点的做法是，当 svn ⽂件版本更新时，触发邮件 通知，每个组员再去拉取最新的任务分配表。这样做更好，因为每次更新，组员都能第⼀时间得到消 息，从⽽让⾃⼰⼿中的任务分配表永远是最新的。此种⽅式依赖于中央存储。整个过程如下图所示：

 ZooKeeper如何解决分布式系统⾯临的问题

实际上，通过 ZooKeeper 实现分布式协同的原理，和项⽬组通过 SVN 同步⼯作任务的例⼦是⼀样的。ZooKeeper 就像是 svn ，存储了任务的分配、完成情况等共享信息。每个分布式应⽤的节点就是组员， 订阅这些共享信息。当主节点（组 leader ），对某个从节点的分⼯信息作出改变时，相关订阅的从节点 得到 zookeeper 的通知，取得⾃⼰最新的任务分配。完成⼯作后，把完成情况存储到 zookeeper 。主节 点订阅了该任务的完成情况信息，所以将得到 zookeeper 的完⼯的通知。参考下图，是不是和前⾯项⽬ 组通过 svn 分配⼯作的例⼦⼀模⼀样？仅仅是把 svn 和邮件系统合⼆为⼀，以 ZooKeeper 代替。

 

　          · CREATE ：创建⼦节点的权限。

　　　　 · READ ：获取节点数据和⼦节点列表的权限。

　　　　 · WRITE ：更新节点数据的权限。

　　　　 · DELETE ：删除⼦节点的权限。

　　　　 · ADMIN ：设置节点 ACL 的权限。

二. Zookeeper环境搭建

（一）单机模式

Zookeeper只运⾏在⼀台服务器上，适合测试环境；

Zookeeper本地模式安装_舞鹤白沙编码日志-CSDN博客_zookeeper本地模式安装

（二）伪集群模式：

• dataDir和dataLogDir：

• server.X和myid：

mkdir zkcluster

tar -zxvf zookeeper-3.4.14.tar.gz -C /zkcluster

mv zookeeper-3.4.14 zookeeper01

cp -r zookeeper01/ zookeeper02

cp -r zookeeper01/ zookeeper03

mkdir data

cd data

mkdir logs

cd conf

mv zoo_sample.cfg zoo.cfg

clientPort=2181

dataDir=/zkcluster/zookeeper01/data

dataLogDir=/zkcluster/zookeeper01/data/logs

clientPort=2182

dataDir=/zkcluster/zookeeper02/data

dataLogDir=/zkcluster/zookeeper02/data/logs

clientPort=2183

dataDir=/zkcluster/zookeeper03/data

dataLogDir=/zkcluster/zookeeper03/data/logs

server.1=10.211.55.4:2881:3881

server.2=10.211.55.4:2882:3882

server.3=10.211.55.4:2883:3883

#server. 服务器 ID= 服务器 IP 地址：服务器之间通信端⼝：服务器之间投票选举端⼝

（三）集群模式：

三. Zookeeper基本使⽤

（一）ZooKeeper系统模型

1. ZooKeeper数据模型Znode

3. 事务ID

4. ZNode 的状态信息

• cZxid 就是 Create ZXID，表示节点被创建时的事务ID。
• ctime 就是 Create Time，表示节点创建时间。
• mZxid 就是 Modified ZXID，表示节点最后⼀次被修改时的事务ID。
• mtime 就是 Modified Time，表示节点最后⼀次被修改的时间。
• pZxid 表示该节点的⼦节点列表最后⼀次被修改时的事务 ID。只有⼦节点列表变更才会更新 pZxid，⼦节点内容变更不会更新。
• cversion 表示⼦节点的版本号。
• dataVersion 表示内容版本号。
• aclVersion 标识acl版本
• ephemeralOwner 表示创建该临时节点时的会话 sessionID，如果是持久性节点那么值为 0
• dataLength 表示数据⻓度。
• numChildren 表示直系⼦节点数。

5. Watcher--数据变更通知

Zookeeper 使⽤ Watcher 机制实现分布式数据的发布 / 订阅功能

⼀个典型的发布 / 订阅模型系统定义了⼀种 ⼀对多的订阅关系，能够让多个订阅者同时监听某⼀个主题对象，当这个主题对象⾃身状态变化时，会通知所有订阅者，使它们能够做出相应的处理。

在 ZooKeeper 中，引⼊了 Watcher 机制来实现这种分布式的通知功能。 ZooKeeper 允许客户端向服务端注册⼀个 Watcher 监听，当服务端的⼀些指定事件触发了这个 Watcher ，那么就会向指定客户端发 送⼀个事件通知来实现分布式的通知功能。

整个 Watcher 注册与通知过程如图所示。

 

Zookeeper 的 Watcher 机制主要包括 客户端线程、客户端 WatcherManager 、 Zookeeper 服务器 三部分。

8. 授权对象：ID

（二）ZooKeeper命令⾏操作

./zkcli.sh 连接本地的 zookeeper 服务器

./zkCli.sh -server ip:port 连接指定的服务器

1. 创建节点

使⽤create命令，可以创建⼀个Zookeeper节点， 如

create [-s][-e] path data acl

其中， -s 或 -e 分别指定节点特性，顺序或临时节点，若不指定，则创建持久节点； acl ⽤来进⾏权限控制。

临时节点在客户端会话结束后，就会⾃动删除，下⾯使⽤ quit 命令退出客户端

 

再次使⽤客户端连接服务端，并使⽤ ls / 命令查看根⽬录下的节点

可以看到根⽬录下已经不存在 zk-temp 临时节点了

③ 创建永久节点

使⽤ create /zk-permanent 123 命令创建 zk-permanent 永久节点

 

可以看到根⽬录下已经不存在 zk-temp 临时节点了

③ 创建永久节点

使⽤ create /zk-permanent 123 命令创建 zk-permanent 永久节点

可以看到永久节点不同于顺序节点，不会⾃动在后⾯添加⼀串数字

2. 读取节点

与读取相关的命令有 ls 命令和 get 命令

ls命令可以列出Zookeeper指定节点下的所有⼦节点，但只能查看指定节点下的第⼀级的所有⼦节点； 

ls path

其中， path 表示的是指定数据节点的节点路径

若获取根节点下⾯的所有⼦节点，使⽤ ls / 命令即可

 

若想获取 /zk-permanent 的数据内容和属性，可使⽤如下命令： get /zk-permanent

 

从上⾯的输出信息中，我们可以看到，第⼀⾏是节点 /zk-permanent 的数据内容，其他⼏⾏则是创建该节点的事务 ID （ cZxid ）、最后⼀次更新该节点的事务 ID （ mZxid ）和最后⼀次更新该节点的时间 （ mtime ）等属性信息

3. 更新节点

使⽤set命令，可以更新指定节点的数据内容，⽤法如下

set path data [version]

其中， data 就是要更新的新内容， version 表示数据版本，在 zookeeper 中，节点的数据是有版本概

念的，这个参数⽤于指定本次更新操作是基于 Znode 的哪⼀个数据版本进⾏的，如将 /zk-permanent 节点的数据更新为 456 ，可以使⽤如下命令： set /zk-permanent 456

现在dataVersion已经变为1了，表示进⾏了更新

4. 删除节点

使⽤delete命令可以删除Zookeeper上的指定节点，⽤法如下

delete path [version]

 其中version也是表示数据版本，使⽤delete /zk-permanent 命令即可删除/zk-permanent节点

（三）Zookeeper的api使⽤

（1 ） org.apache.zookeeper

（2 ） org.apache.zookeeper.data

（3 ） org.apache.zookeeper.server

（4 ） org.apache.zookeeper.server.quorum

（5 ） org.apache.zookeeper.server.upgrade

<dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.6.0</version>
        </dependency>

（四）Zookeeper-开源客户端

1. ZkClient

<dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.2</version>
        </dependency>

2. Curator客户端

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>

RetryPolicy retryPolicy = new ExponentialBackoffRetry ( 1000 , 3 );

CuratorFramework client =

CuratorFrameworkFactory . newClient ( "127.0.0.1:2181" , retryPolicy );

client . start ();

RetryPolicy retryPolicy = new ExponentialBackoffRetry ( 1000 , 3 );

CuratorFramework client = CuratorFrameworkFactory . newClient ( "127.0.0.1:2181" ,

5000 , 1000 , retryPolicy );

client . start ();

package com.lagou.curator;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class CreateSession {

    // 创建会话
    public static void main(String[] args) {


        //不使用fluent编程风格

        RetryPolicy exponentialBackoffRetry = new ExponentialBackoffRetry(1000, 3);
        CuratorFramework curatorFramework = CuratorFrameworkFactory.newClient("192.168.200.128:2181", exponentialBackoffRetry);
        curatorFramework.start();
        System.out.println( "会话被建立了");

        // 使用fluent编程风格
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("192.168.200.128:2181") //server地址
                .sessionTimeoutMs(50000)               // 会话超时时间
                .connectionTimeoutMs(30000)           // 连接超时时间
                .retryPolicy(exponentialBackoffRetry) // 重试策略
                .namespace("base")  // 独立的命名空间： /base
                .build();

        client.start();

        System.out.println("会话2创建了");
    }


}