百度360必应搜狗淘宝本站头条
shell 字符串比较my.cnfword空格下划线不显示applicationcontextawaremaven镜像
当前位置：网站首页 > 技术资源 > 正文

手把手教你:5分钟搞定Zookeeper安装及应用，详细教程

lipiwang 2025-05-30 15:53 6 浏览 0 评论

下载

下载zookeeper-3.4.12.tar.gz，在目录“/opt”创建文件夹“zookeeper”，将下载的文件放入其中并解压缩，最后文件的路径为：

/opt/zookeeper/zookeeper-3.4.12

再创建一个文件夹：

/opt/zookeeper/zookeeper-3.4.12_dataDir

单机模式安装

1.配置

conf/zoo_sample.cfg

并重命名为：

conf/zoo.cfg

配置该文件，在里面添加内容：

tickTime=2000
dataDir=dataDir=/opt/zookeeper/zookeeper-3.4.12_dataDir	
clientPort=2181

2.启动

运行：

./bin/zkServer.sh  start

结果：

./bin/zkServer.sh  start
ZooKeeper JMX enabled by default
Using config: /opt/zookeeper/zookeeper-3.4.12/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

3.查看状态

运行：

./bin/zkServer.sh  status

结果：

./bin/zkServer.sh  status
ZooKeeper JMX enabled by default
Using config: /opt/zookeeper/zookeeper-3.4.12/bin/../conf/zoo.cfg
Mode: standalone

根据状态能看出是单机运行。

4.测试连接

运行：

./bin/zkCli.sh

结果：

./bin/zkCli.sh
Connecting to localhost:2181
2018-08-02 14:23:10,984 [myid:] - INFO  [main:Environment@100] - Client environment:zookeeper.version=3.4.12-e5259e437540f349646870ea94dc2658c4e44b3b, built on 03/27/2018 03:55 GMT
2018-08-02 14:23:10,988 [myid:] - INFO  [main:Environment@100] - Client environment:host.name=<NA>
2018-08-02 14:23:10,988 [myid:] - INFO  [main:Environment@100] - Client environment:java.version=1.8.0_162
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.vendor=Oracle Corporation
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.home=/opt/java/jdk1.8.0_162/jre
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.class.path=/opt/zookeeper/zookeeper-3.4.12/bin/../build/classes:/opt/zookeeper/zookeeper-3.4.12/bin/../build/lib/*.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/slf4j-log4j12-1.7.25.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/slf4j-api-1.7.25.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/netty-3.10.6.Final.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/log4j-1.2.17.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/jline-0.9.94.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../lib/audience-annotations-0.5.0.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../zookeeper-3.4.12.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../src/java/lib/*.jar:/opt/zookeeper/zookeeper-3.4.12/bin/../conf:.:/opt/java/jdk1.8.0_162/bin/dt.jar:/opt/java/jdk1.8.0_162/lib/tools.jar
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.io.tmpdir=/tmp
2018-08-02 14:23:10,990 [myid:] - INFO  [main:Environment@100] - Client environment:java.compiler=<NA>
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:os.name=Linux
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:os.arch=amd64
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:os.version=4.4.0-93-generic
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:user.name=root
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:user.home=/root
2018-08-02 14:23:10,991 [myid:] - INFO  [main:Environment@100] - Client environment:user.dir=/opt/zookeeper/zookeeper-3.4.12
2018-08-02 14:23:10,993 [myid:] - INFO  [main:ZooKeeper@441] - Initiating client connection, connectString=localhost:2181 sessionTimeout=30000 watcher=org.apache.zookeeper.ZooKeeperMain$MyWatcher@277050dc
Welcome to ZooKeeper!
2018-08-02 14:23:11,016 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1028] - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
JLine support is enabled
2018-08-02 14:23:11,134 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@878] - Socket connection established to localhost/127.0.0.1:2181, initiating session
2018-08-02 14:23:11,146 [myid:] - INFO  [main-SendThread(localhost:2181):ClientCnxn$SendThread@1302] - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x10008fcefa30001, negotiated timeout = 30000
WATCHER::
WatchedEvent state:SyncConnected type:None path:null
[zk: localhost:2181(CONNECTED) 0]

说明连接成功，并且介入到了Zookeeper的文件系统中。

5.常用命令

5.1.使用 ls 命令来查看当前 ZooKeeper 中所包含的内容

[zk: localhost:2181(CONNECTED) 0] ls /
[zookeeper]

5.2.创建一个新的 znode ，使用 create /zkPro myData

[zk: localhost:2181(CONNECTED) 1] create /zkPro myData
Created /zkPro

5.3.再次使用 ls 命令来查看现在 zookeeper 中所包含的内容：

[zk: localhost:2181(CONNECTED) 2] ls /
[zookeeper, zkPro]

5.4.下面我们运行 get 命令来确认第二步中所创建的 znode 是否包含我们所创建的字符串：

[zk: localhost:2181(CONNECTED) 3] get /zkPro
myData
cZxid = 0xf
ctime = Thu Aug 02 14:32:01 CST 2018
mZxid = 0xf
mtime = Thu Aug 02 14:32:01 CST 2018
pZxid = 0xf
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 6
numChildren = 0

5.5.下面我们通过 set 命令来对 zk 所关联的字符串进行设置：

[zk: localhost:2181(CONNECTED) 4] set /zkPro myData2
cZxid = 0xf
ctime = Thu Aug 02 14:32:01 CST 2018
mZxid = 0x10
mtime = Thu Aug 02 14:38:40 CST 2018
pZxid = 0xf
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 7
numChildren = 0

5.6.使用 get 命令再次查看：

[zk: localhost:2181(CONNECTED) 5] get /zkPro
myData2
cZxid = 0xf
ctime = Thu Aug 02 14:32:01 CST 2018
mZxid = 0x10
mtime = Thu Aug 02 14:38:40 CST 2018
pZxid = 0xf
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 7
numChildren = 0

能够看到字符串“myData”被改为了“myData2”。

5.7.下面我们将刚才创建的 znode 删除

[zk: localhost:2181(CONNECTED) 6] delete /zkPro

5.8.再次使用 ls 命令查看

[zk: localhost:2181(CONNECTED) 7] ls /
[zookeeper]

能够看到名为“/zkPro”的znode被删除了。

6.使用Java API操作zookeeper

现在我们来做一个实验测试一下Zookeeper服务器的功能。

我们要做的是在zookeeper里增加一个znode目录节点，并且把配置信息存储在里面，接着写一段Java代码作为client来连接Zookeeper的server上，查看server目前的目录文件情况；然后再打开一个终端，连接到Zookeeper的server上，改变Zookeeper的目录文件情况，这时候Java代码作为client端会输出server端目录文件结构的改变 。

6.1.创建一个znode，并且保存一个配置信息

[zk: localhost:2181(CONNECTED) 7] create /username dongdong
[zookeeper]

然后查看“/username”的配置信息：

[zk: localhost:2181(CONNECTED) 7] ls /
[zookeeper]

6.2.使用Java制作一个client

6.2.1.Maven部分

client端创建一个maven项目：

<!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
<dependency>
	<groupId>org.apache.zookeeper</groupId>
	<artifactId>zookeeper</artifactId>
	<version>3.4.12</version>
	<!-- <type>pom</type> -->
</dependency>

这里注意，在maven库中复制的结构里面有：

<type>pom</type>

部分，这里要将其注释掉，否则项目中不会加入：

zookeeper-3.4.12.jar

这个jar包，代码中的类也就无法继承：

org.apache.zookeeper.Watcher

这个监听器的接口。

6.2.2.Java代码部分

使用Java代码制作的client端如下：

package com.yhd.project.zookeepertest;
import java.util.concurrent.CountDownLatch;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.data.Stat;
import org.apache.zookeeper.ZooKeeper;
/**
 * 分布式配置中心demo
 * 
 * @author admin
 *
 */
public class ZooKeeperProSync implements Watcher {
	private static CountDownLatch connectedSemaphore = new CountDownLatch(1);
	private static ZooKeeper zk = null;
	private static Stat stat = new Stat();
	
	public static void main(String[] args) throws Exception {
		//Zookeeper配置数据存放路径
		String path = "/username";
		//连接Zookeeper并且注册一个默认的监听器，注明服务器的IP和端口
		zk = new ZooKeeper("*.*.*.*:2181", 5000, new ZooKeeperProSync());
		
		//等待zk连接成功的通知
		connectedSemaphore.await();
		//获取path目录节点的配置数据，并注册默认的监听器
		System.out.println(new String(zk.getData(path, true, stat)));
		
		Thread.sleep(Integer.MAX_VALUE);
	}
	
	public void process(WatchedEvent event) {
				if (KeeperState.SyncConnected == event.getState()) {	//zk连接成功通知事件
			if ( EventType.None == event.getType() && null == event.getPath() ) {
				connectedSemaphore.countDown();
			} else if (event.getType() == EventType.NodeDataChanged) {	//zk目录节点数据变化通知事件
				try {
					System.out.println("配置已修改，新值为：" + 
							new String(zk.getData(event.getPath(), true, stat)));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		} else {
		}
	}
}

6.3.运行Java制作的client

运行java，结果如下：

log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).

log4j:WARN Please initialize the log4j system properly.

log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

dongdong

因为之前在：

/username

这个znode下创建了：

dongdong

这个字符串，此处运行client，输出了这个字符串。

6.4.使用终端连接Zookeeper的server，改变znode的配置

  • 1.连接server

使用终端连接server，可以在Zookeeper的服务器上使用终端输入：

./bin/zkCli.sh

来连接server。

  • 2.修改原有目录结构

先查看一下现有结构：

[zk: localhost:2181(CONNECTED) 0] ls /
[zookeeper, username]

然后将原有的字符串“dongdong”修改为“dongdong123”。

[zk: localhost:2181(CONNECTED) 1] set /username dongdong123		//修改
cZxid = 0x14
ctime = Thu Aug 02 14:56:38 CST 2018
mZxid = 0x1c
mtime = Thu Aug 02 22:01:10 CST 2018
pZxid = 0x14
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 11
numChildren = 0
[zk: localhost:2181(CONNECTED) 2]
  • 3.在client上查看变化

现在是有2个client：Java代码制作的client，终端命令行的client。

在之前将“dongdong”修改为“dongdong123”的同时，Java代码的client端就会输出：

log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).

log4j:WARN Please initialize the log4j system properly.

log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

dongdong

配置已修改，新值为：dongdong123

说明我们设置的监听器是生效了的。另外在终端命令行查看一下znode的信息：

[zk: localhost:2181(CONNECTED) 2] get /username
dongdong123
cZxid = 0x14
ctime = Thu Aug 02 14:56:38 CST 2018
mZxid = 0x1c
mtime = Thu Aug 02 22:01:10 CST 2018
pZxid = 0x14
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 11
numChildren = 0

也能够看出信息变为“dongdong123”了，说明测试成功！

码字不易，如果觉得本篇文章对你有用的话，请关注作者，后续会有更多的干货分享，请持续关注！

相关推荐

《每日电讯报》研发数字工具，教你更有效率地报道新闻

为鼓励新闻编辑部持续创新，《每日电讯报》正在尝试有战略地研发数字工具。网站的数字媒体主任马尔科姆o科尔斯（MalcolmColes）表示，《每日电讯报》正试图去“创建一些可持续资产”，以便于让记者们...

html5学得好不好，看掌握多少标签

html5你了解了多少？如果你还是入门阶段的话，或者还是一知半解的话，那么我们专门为你们收集的html5常用的标签大全对你就很有帮助了，你需要了解了html5有哪些标签你才能够更好的。驾驭html5...

前端分享-少年了解过iframe么（我想了解少年）

iframe就像是HTML的「内嵌画布」，允许在页面中加载独立网页，如同在画布上叠加另一幅动态画卷。核心特性包括：独立上下文：每个iframe都拥有独立的DOM/CSS/JS环境（类似浏...

做SEO要知道什么是AJAX(人能看到但搜索引擎看不到的内容)

一个明显的，人能看到但搜索引擎不能看到的内容是AJAX。那么什么是AJAX呢？其实，了解过的基本上也都清楚，AJAX不是新的编程语言,而是一种使用现有标准的新方法。AJAX最大的优点是在不重新加...

介绍最前沿的人工智能创新，‘无反向传播’神经网络训练方法?

图像由GoogleImageFX生成前言：本文整理自NoProp原始论文与实践代码，并结合多个公开实现细节进行了全流程复现。对神经网络训练机制的探索仍在不断演进，如果你也在研究反向传播之...

说说我们对HTML6的期许（对html的看法）

HTML5概述HTML5是HTML语言最受欢迎的版本之一，它支持音频和视频、离线存储、移动端、和标签属性等等。还提供了article,section,header这样的标签来帮助开发者更好...

浏览器中在线预览pdf文件，pdf.mjs插件实现web预览pdf

背景：本来只是淘宝上卖卖袜子，想着扩展一下业务，准备做同名“来家居”海外袜子馆外贸项目，碰到pdf在线预览的需求，就找了pdf.js插件进行实践后把此方法记录下来，可以通过多种方法来实现，每种方法都有...

SVG 在前端的7种使用方法，你还知道哪几种?

本文简介点赞+关注+收藏=学会了技术一直在演变，在网页中使用SVG的方法也层出不穷。每个时期都有对应的最优解。所以我打算把我知道的7种SVG的使用方法列举出来，有备无患~如果你还...

HTML5常用标签大全（html5em标签）

HTML前端开发最终取决于掌握标签的多少HTML大概有七八百个标签楼主这里给大家总结了下HTML常用标签标签描述<!--...-->定义注释。<!DOCTYPE>定义文档类型...

&quot;伪君子Snoop Dogg!&quot;... WHAT?| MetroDaily 24/7

TUE.01-新作品-虽说年纪大了会有点糊涂，但是最近SnoopDogg的这波操作实在是让粉丝们有点迷，甚至有人表示没想到他是这样的"伪君子"......而这一切都源于他近日在IG上Po出的一...

史努比snoopy卡通手机壁纸屏保（史努比壁纸无水印）

...

莎夏·班克斯盼望表哥Snoop Dogg为其作出场曲

NXT女子冠军莎夏·班克斯(SashaBanks)近日接受了迈阿密先驱报采访，访谈纪要如下：关于她出众的形象：“我一向喜欢与众不同。为了能让人眼前一亮，我的装束总是非常前卫、非常抢眼，这样才能让观众...

喜欢Snoop!全球第一间「史努比博物馆」海外分馆在东京!

1950年起，由美國漫畫家CharlesM.Schulz創作的作品《Snoopy》史努比，其鮮明的可愛角色與幽默的劇情內容，至今仍成為許多大朋友與小朋友心中的最愛。為了紀念作者所設立的全球首...

Vetements 推出 Snoop Dogg 肖像「天价」T-Shirt

Vetements的CEOGuramGvasalia早前才透露品牌经营策略的秘密–Vetements如何成为人人热议的话题品牌。但似乎他仍有更多需要解释的东西–这个法国奢侈品牌最新...

狗爷Snoop Dogg的《I Wanna Thank Me》巡回演唱会旧金山站

西海岸匪帮说唱歌手SnoopDogg在《IWannaThankMe》巡回演唱会旧金山站表演（图片来自ICphoto）西海岸匪帮说唱歌手SnoopDogg（图片来自ICphoto）西海...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表