很多大型系统基本都需要一个无单点问题的分布式框架,zookeeper便满足这一需求。这次的博客,我们先进行一个最基本的安装、部署、连接。
1、首先下载zookeeper,解压,我这里选择最新的稳定版3.4.8,然后我们使用单机模拟集群,可以专门建立一个文件夹,用来放置你的zookeeper,比如:
/Users/zk_chs/something/hadoop/zookeeper-3.4.8-001 /Users/zk_chs/something/hadoop/zookeeper-3.4.8-002 /Users/zk_chs/something/hadoop/zookeeper-3.4.8-003
2、接下来,配置每个zookeeper的cfg文件,这里需要更改conf/zoo_sample.cfg为zoo.cfg,需要更改的内容为:
zookeeper-3.4.8-001/conf/zoo.cfg =============before============ dataDir=/tmp/zookeeper # the port at which the clients will connect clientPort=2181 =============bofore============ =============now=============== dataDir=/Users/zk_chs/something/hadoop/tmp/zk-001/data dataLogDir=/Users/zk_chs/something/hadoop/tmp/zk-001/log # the port at which the clients will connect clientPort=2181 server.1=localhost:2287:3387 server.2=localhost:2288:3388 server.3=localhost:2289:3389 =============now================
clientPort:客户端连接端口,在我们的模拟集群环境中,每个zookeeper服务不能重复。
而server.1=localhost:2287:3387中,2287表示leader通信端口,3387表示leader选举端口。
dataDir表示数据存储目录、dataLogDir表示日志存储目录,需要我们先手动创建好。
之后,再在每个dataDir中分别创建一个myid文件,文件中只有一个数字,即server Id。比如,我们的server.1对应的myid文件内容便是1
另外2个zookeeper如下配置:
zookeeper-3.4.8-002/conf/zoo.cfg =============before============ dataDir=/tmp/zookeeper # the port at which the clients will connect clientPort=2182 =============bofore============ =============now=============== dataDir=/Users/zk_chs/something/hadoop/tmp/zk-002/data dataLogDir=/Users/zk_chs/something/hadoop/tmp/zk-002/log # the port at which the clients will connect clientPort=2182 server.1=localhost:2287:3387 server.2=localhost:2288:3388 server.3=localhost:2289:3389 =============now================
zookeeper-3.4.8-003/conf/zoo.cfg =============before============ dataDir=/tmp/zookeeper # the port at which the clients will connect clientPort=2183 =============bofore============ =============now=============== dataDir=/Users/zk_chs/something/hadoop/tmp/zk-003/data dataLogDir=/Users/zk_chs/something/hadoop/tmp/zk-003/log # the port at which the clients will connect clientPort=2183 server.1=localhost:2287:3387 server.2=localhost:2288:3388 server.3=localhost:2289:3389 =============now================
3、接下来,通过bin/zkServer.sh进行启动:
/Users/zk_chs/something/hadoop/zookeeper-3.4.8-001/bin/zkServer.sh start /Users/zk_chs/something/hadoop/zookeeper-3.4.8-002/bin/zkServer.sh start /Users/zk_chs/something/hadoop/zookeeper-3.4.8-003/bin/zkServer.sh start
使用jps查看java进程:
837 QuorumPeerMain
824 QuorumPeerMain
835 QuorumPeerMain
如果启动成功,这些便是能看到的zookeeper进程了,
还可以使用zkCli.sh进行客户端连接:
/Users/zk_chs/something/hadoop/zookeeper-3.4.8-002/bin/zkCli.sh -server localhost:2183
成功后显示:
[zk: localhost:2183(CONNECTED) 0]
这样以来我们便能使用ls ,create ,delete ,get, set来测试了,使用方式与linux大同小异,另外,rmr可以进行递归删除。
4、使用java连接zookeeper:
个人建议使用开源的zkClient来进行连接,
<dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.8</version> </dependency>
接下来使用zkClient进行zookeeper集群的连接:
public class TestZkClient { private static ZkClient zkClient = new ZkClient("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"); private static final String node = "/zk_chs"; public static void main(String[] args) throws InterruptedException { testZkClient(); } private static void testZkClient (){ if ( !zkClient.exists(node) ){ zkClient.createPersistent(node, "this is first node"); } System.out.println((String) zkClient.readData(node)); } }
连接zookeeper时,使用单个地址也是可以的,我们在这里使用","对地址进行分隔,是为了容错。
我们还定义了一个"/zk_chs"节点,关于节点的更多内容后续讲解。
上述程序输出:
this is first node
使用zookeeper还可以对节点数据变化进行监听,对上述程序进行扩展:
public class TestZkClient { private static ZkClient zkClient = new ZkClient("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"); private static final String node = "/zk_chs"; public static void main(String[] args) throws InterruptedException { testZkClient(); subscribeDataChange(); zkClient.writeData(node, "new data"); zkClient.delete(node); Thread.sleep(1000); } private static void testZkClient (){ if ( !zkClient.exists(node) ){ zkClient.createPersistent(node, "this is first node"); } System.out.println((String) zkClient.readData(node)); } private static void subscribeDataChange (){ zkClient.subscribeDataChanges(node, new IZkDataListener() { @Override public void handleDataChange(String dataPath, Object data) throws Exception { System.out.println("node data changed: " + dataPath + ", data: " + data); } @Override public void handleDataDeleted(String dataPath) throws Exception { System.out.println("node data deleted: " + dataPath); } }); } }
最后输出:
this is first node
node data changed: /zk_chs, data: new data
node data deleted: /zk_chs
这次我们对zookeeper先做一个基本的了解,后续再介绍更多的内容。
相关推荐
Umi-OCR-main.zip
基于springboot+Web的毕业设计选题系统源码数据库文档.zip
基于springboot校外兼职教师考勤管理系统源码数据库文档.zip
58商铺全新UI试客试用平台网站源码
基于springboot大学生就业信息管理系统源码数据库文档.zip
基于SpringBoot的口腔诊所系统源码数据库文档.zip
数据存放网盘,txt文件内包含下载链接及提取码,永久有效。失效会第一时间进行补充。样例数据及详细介绍参见文章:https://blog.csdn.net/T0620514/article/details/143956923
3-240P2162218.zip
网络安全 基于Qt创建的Linux系统下的浏览器.zip
C++ 类和对象:多态-练习题目2(制作咖啡和茶叶)
基于springboot+J2EE在线项目管理与任务分配中的应用源码数据库文档.zip
简介本项目提供了一个在51单片机上运行的简单操作系统,旨在帮助学习者深入理解操作系统的基本原理和任务调度机制。该操作系统通过汇编和C语言编写,实现了任务调度、中断处理等核心功能,并提供了详细的源代码和注释,方便学习和实践。
本文将深度卷积神经网络(CNN)设计实现一个复杂结构的生成模型,旨在通过多阶段的编码器-解码器结构,能够有效地将灰度图像转换为彩色图像。最后,本文将实现一个简单的Web应用,用户可以通过上传灰度图像,应用会使用预训练的Caffe模型对其进行颜色化,并将结果返回给用户。 1.模型设计:模型由多个卷积层、ReLU激活函数和批归一化层组成,通过前向传播函数将输入的灰度图像(L通道)转换为彩色图像(ab通道)。如果指定了 pretrained=True,则会自动下载并加载预训练的模型权重。 2. 系统通过Flask框架提供了一个Web应用,用户可以上传灰度图像,系统会自动将其转换为彩色图像,并在网页上显示结果。整个过程包括文件验证、图像处理、颜色化预测和结果展示,具有较高的实用性和用户体验。
一个JAVA图形化的、联网的五子棋游戏.zip javaweb
KWDB 是一款面向 【AIoT 场景】的【分布式多模数据库】,支持在同一实例同时建立时序库和关系库并融合处理多模数据,具备千万级设备接入、百万级数据秒级写入、亿级数据秒级读取等时序数据高效处理能力,具有稳定安全、高可用、易运维等特点。
页面数量:7页 网页主题:网站模板、酒店网站模板、官方网站模板 网页页面:首页、关于我们、相关服务、服务详情、在线博客、博客详情、在线留言 页面实现元素:加载动画、滚动加载、主题切换、导航栏 、轮播图、图文列表、图片切换、 文字列表、 按钮悬停、图片悬停、表单 实现技术:HTML、CSS 、JQuery 源码样式及js文件均分开存放,所有内容仅供初学者学习参考
内容概要:本文档提供了详细的 Neo4j 安装与配置指南,涵盖 Windows、Linux 和 Mac 系统的安装步骤。具体包括下载、安装、启动服务、修改配置文件(如端口配置、远程访问和内存限制)、设置管理员密码以及基本的 Cypher 查询语言使用方法。同时,还提供了一些常见问题及其解决方案。 适合人群:数据库管理员、软件开发人员、系统管理员。 使用场景及目标:①帮助初学者快速掌握 Neo4j 的安装与配置;②适用于需要搭建和使用图数据库的项目;③为已有用户解决常见问题。 其他说明:本文档不仅包含了基础的安装和配置流程,还提供了实际操作中可能遇到的问题及其解决方法,有助于提高使用者的实际操作能力。
基于SpringBoot+Vue的软件产品展示销售系统源码数据库文档.zip
《书戴嵩画牛》教学课件.pptx
20届智能车 【项目资源】:包含前端、后端、移动开发、人工智能、物联网、信息化管理、数据库、硬件开发、大数据、课程资源,毕业设计等各种技术项目的源码。包括C++、Java、python、web、C#、EDA等项目的源码。 【适用人群】:适用于希望学习不同技术领域的初学者或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。 【附加价值】:项目具有较高的学习借鉴价值,也可直接拿来修改复刻。对于有一定基础或热衷于研究的人来说,可以在这些基础代码上进行修改和扩展,实现其他功能。 【沟通交流】:有任何使用上的问题,欢迎随时与博主沟通,博主会及时解答。鼓励下载和使用,并欢迎大家互相学习,共同进步。