zookeeper windows 入门安装和测试-白红宇

zookeeper windows 入门安装和测试

阅读量：5160 次

发布时间：2019-06-13

本文共 4241 字，大约阅读时间需要 14 分钟。

一、序言

以下是我对zookeeper 的一些理解：

zookeeper 作为一个服务注册信息存储的管理工具，好吧，这样说得很抽象，我们举个“栗子”。

栗子1号：

假设我是一家KTV的老板，我同时拥有5家KTV，我肯定得时刻监视我KTV 的情况吧，是不是有人打架，或者发生火灾什么的，这时候我会给设置一个视频监控，然后每一家都连接到我的视频监控里面，那么我就可以在家里看到所有KTV 的情况了，如果某一家出现问题，我就能及时发现，并且做出反应。

这个视频监控就相当于zookeeper,每一家的连接，就相当于KTV 的信息。

二、安装过程

2.1 http://mirrors.hust.edu.cn/apache/zookeeper/ 下载，我的版本是 3.4.6(stable) 稳定

2.2 解压到 F:\zookeeper-3.4.6

3.3 到目录conf 下创建 zoo.cfg 文件，默认就是加载这个文件，文件内容我直接copy 的sample里面的

Java代码

#zoo.cfg 的内容

# 心跳检查的时间 2秒

tickTime=2000

# 初始化时连接到服务器端的间隔次数，总时间10*2=20秒

initLimit=10

# ZK Leader 和follower 之间通讯的次数，总时间5*2=10秒

syncLimit=5

# 存储内存中数据库快照的位置，如果不设置参数，更新事务日志将被存储到默认位置。

dataDir=F:\\zk\\tmp\\zookeeper

# 错误日志的存放位置

dataLogDir=F:\\zk\\logs\\zookeeper

# ZK 服务器端的监听端口

clientPort=2181

上面的说明介绍：http://zookeeper.apache.org/doc/current/zookeeperStarted.html

然后 cd 到bin 目录下执行zkServer.cmd 就启动成功了。

注意：dataDir 和 dataLogDir 目录不会自动创建，得手动创建才能启动。

可以用netstat -ano|findstr "2181" 看看是否OK。

也可以用JPS 查看启动的JAVA 进程的情况，会出现这样

Java代码

C:\windows\system32>jps

8068

10040 QuorumPeerMain // 这东西是zk的东西，源码有介绍

10556 Jps

也可以用自带客户端命令： zkCli.cmd -server 127.0.0.1:2181

关于JPS的东西，可以自己去JAVA_HOME\bin 目录下去看，里面很多命令。

四、JAVA 操作zookeeper :

上面安装挺简单的，我们来实际操作下：

4.1 导入依赖：

Java代码

<dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

<version>3.4.6</version>

</dependency>

4.2 JAVA 实现：这里我们简单实现上面的栗子

Java代码

// 根节点

public static final String ROOT = "/root-ktv";

public static void main(String[] args) throws Exception {

// 创建一个与服务器的连接

ZooKeeper zk = new ZooKeeper("localhost:2181", 30000, new Watcher() {

// 监控所有被触发的事件

public void process(WatchedEvent event) {

System.out.println("状态:" + event.getState()+":"+event.getType()+":"+event.getWrapper()+":"+event.getPath());

}

});

// 创建一个总的目录ktv，并不控制权限，这里需要用持久化节点，不然下面的节点创建容易出错

zk.create(ROOT, "root-ktv".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

// 然后杭州开一个KTV , PERSISTENT_SEQUENTIAL 类型会自动加上 0000000000 自增的后缀

zk.create(ROOT+"/杭州KTV", "杭州KTV".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL);

// 也可以在北京开一个, EPHEMERAL session 过期了就会自动删除

zk.create(ROOT+"/北京KTV", "北京KTV".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 同理，我可以在北京开多个，EPHEMERAL_SEQUENTIAL session 过期自动删除，也会加数字的后缀

zk.create(ROOT+"/北京KTV-分店", "北京KTV-分店".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);

// 我们也可以来看看一共监视了多少家的ktv

List<String> ktvs = zk.getChildren(ROOT, true);

System.out.println(Arrays.toString(ktvs.toArray()));

for(String node : ktvs){

// 删除节点

zk.delete(ROOT+"/"+node,-1);

}

zk.delete(ROOT, -1);

zk.close();

}

zookeeper 的结构图和其他的一些功能，可参考： http://www.blogjava.net/shenh062326/archive/2011/10/29/zookeeper_yuling.html

三、zookeeper 伪集群

上面栗子我们看到，如果我们的监控室也停电了，那不是就监测不到KTV情况了？一般情况下，zk 也是作为分布式部署了，也就是有多台监控，由于监控多了，肯定要有一定为准(比如直播会有一些延迟)，就要涉及到选举的算法，这里暂时不介绍，先搭建一个伪集群，因为机器不够，只能再一台机器上模拟搭建,整个过程无非是将上面的一些配置copy 几份，然后配置不同的地址和端口就行。

3.1 我们将F:\zookeeper-3.4.6\conf\下的zoo.cfg 改成zoo1.cfg,内容改为：

Java代码