大数据编程技术基础实验六:ZooKeeper实验——进程协作

本文涉及的产品
云原生网关 MSE Higress,422元/月
云原生大数据计算服务 MaxCompute,5000CU*H 100GB 3个月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 大数据基础实验六,使用ZooKeeper了解并实践进程协作的操作。

一、前言

在实验开始之前,首先祝大家国庆节快乐,希望大家都能愉快的度过国庆假期,而我也就昨天休息了一天跟室友们出去吃了一顿饭,我们的国庆只有三天,真羡慕国庆七天并且还能出去玩的人,太命苦了,大学四年已过去三年一次像样的国庆都没有,只能默默的锻炼和学习安抚我的心灵。

好啦,回归正题,在前面一期实验中,我们刚学会了ZooKeeper的部署与启动,本期我们就来用ZooKeeper实战一下,学习一下ZooKeeper如何实现多个线程间的协作。

二、实验目的与要求

  1. 掌握Java代码如何连接ZooKeeper集群及通过代码读写ZooKeeper集群的目录下的数据,掌握ZooKeeper如何实现多个线程间的协作。
  2. 用Java代码实现两个线程,一个向ZooKeeper中某一目录中写入数据,另一线程监听此目录,若目录下数据有更新则将目录中数据读取并显示出来。

三、实验原理

  1. 通过ZooKeeper实现不同物理机器上的进程间通信。
  2. 场景使用:客户端A需要向客户端B发送一条消息msg1。
  3. 实现方法:客户端A把msg1发送给ZooKeeper集群,然后由客户端B自行去ZooKeeper集群读取msg1。

四、实验步骤

本实验主要完成多线程通过ZooKeeper完成彼此间的协作问题,实验过程包含启动集群、编写代码、客户端提交代码三个步骤。

1、启动ZooKeeper集群

启动ZooKeeper集群。具体步骤可以参考我前面一期博客内容:

大数据技术基础实验五:Zookeeper实验——部署ZooKeeper

2、导入jar包

我们在本地打开我们的开发工具Eclipse,然后创建我们的ZooKeeperTest项目,它是一个java项目。

image-20221002103907923.png

创建完项目之后,我们需要从服务器上ZooKeeper安装包的lib目录下,将如下jar包导入到开发工具,我们需要用到Xftp工具连接到服务器,然后直接进行拖拽到本地项目下的lib包内即可。

首先连接主机:

image-20221002104954878.png

我们需要导入的jar包有:

jline-0.9.94.jar

log4j-1.2.16.jar

netty-3.7.0.Final.jar

slf4j-api-1.6.1.jar

slf4j-log4j12-1.6.1.jar

zookeeper-3.4.6.jar

找到虚拟机内的ZooKeeper安装包的lib目录,它在/usr/cstor/zookeeper/lib,然后将lib下的这些jar包导入到我们本地的项目lib目录内:

image-20221002105233796.png

一共有六个jar包,最后一个zookeeper-3.4.6.jar它在这个目录/usr/cstor/zookeeper/lib的上一级里面:

image-20221002105608121.png

然后我们需要将这六个jar导入到我们的项目中,我们右键每一个jar包然后进行如下选择即可导入成功:

image-20221002110104609.png

3、编写java代码

然后我们创建两个java类:

image-20221002110334193.png

然后分别写入java代码。

向/testZk目录写数据线程代码实现:

publicclassWriteMsgextendsThread {
@Overridepublicvoidrun() {
try {
ZooKeeperzk=newZooKeeper("slave1:2181", 500000, null);
Stringcontent=Long.toString(newDate().getTime());
// 修改节点/testZk下的数据,第三个参数为版本,如果是-1,那会无视被修改的数据版本,直接改掉zk.setData("/testZk", content.getBytes(), -1);
// 关闭sessionzk.close();
      } catch (Exceptione) {
e.printStackTrace();
    }
  }
}

监听/testZk目录若数据改变则读取数据并显示线程代码实现:

publicclassReadMsg {
publicstaticvoidmain(String[] args) throwsException {
finalZooKeeperzk=newZooKeeper("slave1:2181", 500000, null);
//定义watch Watcherwacher=newWatcher() {
publicvoidprocess(WatchedEventevent) {
//监听到数据变化取出数据if(EventType.NodeDataChanged==event.getType()){
byte[] bb;
try {
bb=zk.getData("/testZk", null, null);
System.out.println("/testZk的数据: "+newString(bb));
         } catch (Exceptione) {
e.printStackTrace();
         }
       }
     }
   };
//设置watch zk.exists("/testZk", wacher);
//更新/testZk目录信息,触发wacthwhile(true)
   {
Thread.sleep(2000);
newWriteMsg().start();
//watch一次生效就会删除需重新设置 zk.exists("/testZk", wacher);
   }
  }
}

4、做成jar包

和之前打包类似,但这次我们需要改成可执行的jar文件:

image-20221002144042248.png

image-20221002144108676.png

打包成功之后,我们再次使用Xftp工具将打包好的jar包放到root目录下面,因为我们要在/testZk目录写数据线程,但在上一期实验中我们最后删除了这个目录,所以我们需要重新启动客户端,然后创建/testZk目录,然后退出。

这里启动客户端和创建目录我就不再演示,不会的朋友可以移步到上一期博客。

然后我们执行如下命令即可执行代码:

java -jar /root/ZooKeeperTest.jar

image-20221002144352842.png

这里我们成功打印了日志信息,打印日志信息为ZooKeeper接收线程监控到/testZk目录信息有变化时,读取该目录的内容。

但是这里一直抛出这样的错误:

2022-10-0214:34:08,511 ERROR [org.apache.zookeeper.ClientCnxn] - Error while calling watcher
java.lang.NullPointerException
        at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:522)
        at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:498)

根据我上网查询过后,目前还是没有解决这个异常,我也不太懂这个是什么原因,如果有知道的大佬可以告诉我一下,谢谢,我也准备问一下我们的老师,看他是怎么解决的,如果解决了后续我再将解决办法加进来。

五、最后我想说

本期ZooKeeper实验就到这里结束了,马上我们将开始HBase的实验了,还请大家敬请关注,谢谢!

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
10月前
|
Linux Shell 调度
操作系统实验一:进程和线程(1)
实验内容 一、进程的创建 编写一段源程序,使用系统调用fork()创建子进程,当此程序运行时,在系统中有父进程和子进程在并发执行。观察屏幕上的显示结果,并分析原因(源代码:forkpid.c)。
253 0
|
10月前
|
存储 网络协议 Java
深入理解Linux网络——内核与用户进程协作之同步阻塞方案(BIO)
在上一部分中讲述了网络包是如何从网卡送到协议栈的(详见深入理解Linux网络——内核是如何接收到网络包的),接下来内核还有一项重要的工作,就是在协议栈接收处理完输入包后要通知到用户进程,如何用户进程接收到并处理这些数据。
|
3月前
|
存储 人工智能 算法
为什么局域网协作工具是大数据时代的必需品?
本文深入解析了局域网文档协同编辑的技术原理与优势,涵盖分布式系统架构、实时同步技术、操作变换及冲突自由的副本数据类型等核心概念。同时,探讨了其在信息安全要求高的组织、远程与现场混合团队、教育与科研团队等场景的应用,以及国内外技术方案对比和市场未来趋势。
|
5月前
|
消息中间件 监控 Ubuntu
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
155 3
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
|
7月前
|
安全 开发者 Python
跨越编程孤岛,构建互联大陆:深入探索Python进程间通信的奥秘,解锁高效协作新纪元!
【8月更文挑战第3天】在编程领域,Python 因其简洁强大而广受欢迎。但随着项目规模扩大,单进程难以应对复杂需求,此时多进程间的协同就显得尤为重要。各进程像孤岛般独立运行,虽提升了稳定性和并发能力,但也带来了沟通障碍。为解决这一问题,Python 提供了多种进程间通信(IPC)方式,如管道、队列和套接字等,它们能有效促进数据交换和任务协作,使各进程像大陆般紧密相连。通过这些机制,我们能轻松搭建起高效的多进程应用系统,实现更加复杂的业务逻辑。
49 2
|
8月前
|
小程序 Linux
【编程小实验】利用Linux fork()与文件I/O:父进程与子进程协同实现高效cp命令(前半文件与后半文件并行复制)
这个小程序是在文件IO的基础上去结合父子进程的一个使用,利用父子进程相互独立的特点实现对数据不同的操作
152 2
|
7月前
|
Python
Python IPC深度探索:解锁跨进程通信的无限可能,以管道与队列为翼,让你的应用跨越边界,无缝协作,震撼登场
【8月更文挑战第3天】Python IPC大揭秘:解锁进程间通信新姿势,让你的应用无界连接
38 0
有 3 个进程 P1、P2、P3 协作解决文件打印问题。P1 将文件记录从磁盘读入内存的缓冲区 1,每执行一次读一个记录 ;P2 将缓冲区 1 中的内容复制到缓冲区 2 中,每执行一次复制一个记录 ;
有 3 个进程 P1、P2、P3 协作解决文件打印问题。P1 将文件记录从磁盘读入内存的缓冲区 1,每执行一次读一个记录 ;P2 将缓冲区 1 中的内容复制到缓冲区 2 中,每执行一次复制一个记录 ;
|
10月前
|
Linux API
【操作系统】实验七 显示进程列表
【操作系统】实验七 显示进程列表
164 2
|
10月前
|
调度 数据库
操作系统实验一:进程和线程(2)
七、共享资源的互斥访问 创建两个线程来实现对一个数的递加 pthread_example.c 1、运行
91 0

热门文章

最新文章