专栏首页品茗ITWeb基础配置篇(十一): Zookeeper的安装配置及使用

Web基础配置篇(十一): Zookeeper的安装配置及使用

Web基础配置篇(十一): Zookeeper的安装配置及使用

一、概述

ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。

ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效、功能稳定的系统提供给用户。

在JavaWeb的开发中,我们用到Zookeeper的地方大概就是注册中心和配置中心了,比如dubbo工具、Springcloud都支持Zookeeper。当然,Zookeeper是hadoop项目的基础工具;Zookeeper也可以作为分布式锁实现的重要桥梁。由此观之,Zookeeper扮演着一个很重要的角色。

重要不重要不是说出来的,你用的上,它就是重要的。我们这篇只讲安装。

**如果大家正在寻找一个java的学习环境,或者在开发中遇到困难,可以<a

href="https://jq.qq.com/?_wv=1027&k=52sgH1J"

target="_blank">

加入我们的java学习圈,点击即可加入

</a>

,共同学习,节约学习时间,减少很多在学习中遇到的难题。**

二、Zookeeper单机版

2.1 下载Zookeeper

然后选择可以下载的版本。

  • 比如我在这里下在http://mirror.bit.edu.cn/apache/zookeeper/
  • 我本来想下载zookeeper-3.5.5的,可是zookeeper-3.5.5下载下来就提示文件损坏,换了好几个镜像地址都不行,无奈放弃3.5.5,下载了3.4.14版本。
  • 下载完成后,解压文件(window下用winrar/其他解压工具,linux下tar命令)并进入文件夹的bin目录下:

如图所示:

在这里插入图片描述

windows和linux公用同一个下载文件,但是启动文件不一样。

2.2 Windows启动Zookeeper

配置

将Zookeeper的conf目录下的zoo_sample.cfg文件,复制为zoo.cfg;可以打开看下,里面有个一个端口配置。

修改zoo.cfg文件,添加下data目录和log目录:

dataDir=E:/DevSoft/zookeeper/zookeeper-3.4.14/data
dataLogDir=E:/DevSoft/zookeeper/zookeeper-3.4.14/log

启动

打开powershell或者cmd,首先进入到Zookeeper的bin目录下,输入命令.\zkServer.cmd

然后它就运行起来了。这是我见过的最爽快的工具了。

然后运行.\zkCli.cmd,测试下刚刚安装的zookeeper。

2.3 Linux启动Zookeeper

配置

将Zookeeper的conf目录下的zoo_sample.cfg文件,复制为zoo.cfg;

修改zoo.cfg文件,添加下data目录和log目录:

dataDir=E:/DevSoft/zookeeper/zookeeper-3.4.14/data
dataLogDir=E:/DevSoft/zookeeper/zookeeper-3.4.14/log

启动

然后进入到Zookeeper的bin目录下,输入命令sh zkServer.sh start

然后它就运行起来了。

然后运行sh zkCli.sh,测试下刚刚安装的zookeeper。

三、Zookeeper集群

在Zookeeper集群中,若超过半数以上服务节点不可用,才会造成整个服务不可用,所以其集群节点数一般都是至少3个节点以上的奇数个。

所以我这里起三个节点做测试,分别是:

windwos节点一个、 Docker容器内Centos节点两个。

3.1 配置

按照上面单机版的配置,在data目录下,新建myid文件。windows节点填入1;两个centos节点分别为2、3。

在conf目录下的zoo.cfg文件里,添加:

server.1=10.247.62.91:2888:3888
server.2=192.168.99.100:2888:3888
server.3=192.168.99.100:2889:3889

这里,写法是server.id=host:port1:port2

其中id为一个数字,表示zk进程的id,这个id也是dataDir目录下myid文件的内容。

host是该zk进程所在的IP地址,port1表示follower和leader交换消息所使用的端口,port2表示选举leader所使用的端口。后面端口是任意写的。

10.247.62.91是windows的机器id。192.168.99.100是docker容器ip。

3.2 启动

到bin目录下,每个都启动即可。

3.3 测试

使用命令./zkCli.sh -server localhost登录任意一台机器,然后创建一个节点,再查询其他server是否存在该节点信息。

创建节点:create /test 123

查看节点:ls /。如果/下面存在test,表示正常。

创建顺序节点 自动累加:create -s /test2 123

四、Zookeeper可视化管理工具

zookeeper本身是没有管理工具的,但是zkui是一个很广泛使用的可视化管理工具。

下面讲一下如何使用zkui:

首先下载zkui或者使用已经编译好的jar包。

4.1 zkui的jar包

4.1.1 下载已编译的jar包

我用jdk8编译好了一个jar包,上传到csdn上了,不要问我为啥要收积分,我也不想啊,csdn改不了积分。

https://download.csdn.net/download/feiyangtianyao/11447614

因为要积分,所以我上传到了百度云,分享一下给大家:

链接:https://pan.baidu.com/s/1mfWMW_2IvDGtReqV2ONslg

提取码:9k54

解压zip文件,里面有jar包和config文件。

4.1.2 自己编译

https://github.com/DeemOpen/zkui下载zkui的代码。

在这里插入图片描述

下载完成后,使用maven打包即可。

maven命令:mvn clean install,或者使用eclipse等ide打包都行。

它是用assembly打包的,打包完成后有两个jar包,选择jar-with-dependencies的那个jar包,也就是比较大的那个jar包,它就是可运行的jar包,名字太长了改为zkui.jar。

4.2 运行

将config.cfg复制到jar文件所在目录,和jar包平级,然后修改配置文件中的zookeeper地址(如果是本地,无需修改)。

zkServer=localhost:2181

运行jar包:

java -jar zkui.jar

4.3 访问

测试,http://localhost:9090 ,如能看到如下页面则代表zookeeper安装运行正常。

在这里插入图片描述

使用用户名密码admin/manager登录即可。用户名密码配置在config.cfg文件的userSet= 中。

五、Zookeeper常用命令

4.1 增加节点

创建普通节点:create /test test

创建临时节点(断开重连之后,临时节点自动消失):create -e /test1 test1

4.2 查询节点

查询节点数据: get /test

查看根节点下子节点:ls /

查看services节点:ls /services; SpringCloud注册节点就在该节点下。

4.3 修改节点

查询节点数据: get /test

修改节点数据:set /test 456

根据版本号更新 dataVersion 乐观锁 修改节点数据:set /test 789 1;更新完成后,再执行一遍,将提示version No is not valid : /test,将版本号换为2:set /test 789 2执行就可以了。

4.4 删除节点

删除节点: delete /test

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • SpringBoot入门建站全系列(二十二)异步任务执行的几种方式

    异步调用是相对于同步调用而言的,同步调用是指程序按预定顺序一步步执行,每一步必须等到上一步执行完后才能执行,异步调用则无需等待上一步程序执行完即可执行。

    品茗IT
  • SpringBoot入门建站全系列(二十二)异步任务执行的几种方式

    异步调用是相对于同步调用而言的,同步调用是指程序按预定顺序一步步执行,每一步必须等到上一步执行完后才能执行,异步调用则无需等待上一步程序执行完即可执行。

    品茗IT
  • Spring序列化布尔类型错误

    反例:定义为基本数据类型 Boolean isDeleted;的属性,它的方法也是isDeleted(),RPC框架在反向解析的时候,“以为”对应的属性名称是d...

    品茗IT
  • 解决spark streaming重复提交第三方jar包问题

    背景: 由于spark streaming每次提交都需要上传大量jar包到hdfs,为节约HDFS资源,现只存一份来解决这个问题

    shengjk1
  • Python打包成库供别的模块调用

    2.新建test_package包并创建info1类以及print_hello方法

    py3study
  • 重拾Kotlin(2)-包、类型别名、修饰符

    Kotlin 文件都能以一条 package 语句开头,而文件中定义的所有声明(类、函数和属性)都会被放到这个包中。如果其他文件中定义的声明也有相同的包,这个文...

    叶应是叶
  • 科普常识:常见音频参数解析

            如果在计算机加上相应的音频卡—就是我们经常说的声卡,我们可以把所有的声音录制下来,声音的声学特性如音的高低等都可以用计算机硬盘文件的方式储存下来...

    朵朵花儿
  • [个人翻译]Redis 集群教程(中)

    官方原文地址:https://redis.io/topics/cluster-tutorial 水平有限,如果您在阅读过程中发现有翻译的不合理的地方,请留言,我...

    lpxxn
  • Redis Cluster搭建高可用Redis服务器集群

    Redis Cluster是Redis官方提供的分布式解决方案,在3.0版本后推出的,有效地解决了Redis分布式的需求,当一个节点挂了可以快速的切换到另一个节...

    java架构师
  • python设计模式之单例模式

    简单理解:单例即为单个实例,也就是每次实例化创建对象时获得的都是同一个对象,当然同一个对象的属性都是相同的,方法也是相同的,地址也是相同的,这样给我们带来的好处...

    py3study

扫码关注云+社区

领取腾讯云代金券