【RocketMQ笔记01】安装RocketMQ消息队列运行环境

这篇文章,主要介绍如何安装RocketMQ消息队列运行环境。

目录

一、RocketMQ消息队列

1.1、下载RocketMQ

1.2、解压安装包

1.3、配置RocketMQ环境变量

1.4、修改启动脚本

1.5、启动RocketMQ

(1)启动NameServer

(2)启动Broker

1.6、测试RocketMQ

(1)发送消息

(2)接收消息


一、RocketMQ消息队列

RocketMQ是基于Java语言开发的,所以安装之前需要确保电脑上已经安装了JDK运行环境。

1.1、下载RocketMQ

两种方式可以获取到RocketMQ的安装包,分别如下所示:

  • 第一种:下载RocketMQ的源代码文件,然后自己通过maven编译打包生成可运行的程序;

源代码下载地址:https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1.4-source-release.zip

  • 第二种:直接下载apache官方提供的可运行程序;

可执行程序地址:https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip

1.2、解压安装包

我这里是直接下载的可执行程序,解压安装包之后,目录结构如下所示:

1.3、配置RocketMQ环境变量

解压RocketMQ之后,需要在配置一下系统环境变量,目的是为了启动时候,不报错。变量名称填写:ROCKETMQ_HOME,变量值就是RocketMQ解压后的安装目录

1.4、修改启动脚本

由于RocketMQ的启动脚本存在一些问题,所以我们在运行之前需要自己做一点修改,需要修改两个文件,分别是:

  • 1、修改bin目录下的runserver.cmd文件,将其中的%CLASSPATH%加上双引号。
  • 注意:因为无法直接打开cmd文件,所以先将其文件后缀改成txt,再进行修改,修改完成后,在改成cmd后缀

  • 2、修改bin目录下的runbroker.cmd文件,将其中的%CLASSPATH%加上双引号。

如果不修改会怎么样呢???如果没有修改,那么在启动mqnamesrv和mqbroker的时候,就会提示:错误: 找不到或无法加载主类。

1.5、启动RocketMQ

RocketMQ分别提供了Windows系统和Linux系统下的执行程序,Windows系统中的执行程序以【cmd】结尾,Linux系统中的执行程序以【sh】结尾或者没有文件后缀的,这里我将采用Windows系统中的执行程序启动RocketMQ消息队列服务。

(1)启动NameServer

打开cmd命令行窗口,进入RocketMQ安装目录下的bin目录里面,然后执行下面【mqnamesrv】命令,启动NameServer服务:

如果控制台看见The Name Server boot success.,那就表示nameserver服务启动成功了。

(2)启动Broker

打开cmd命令行窗口,进入到RocketMQ安装目录中的bin目录里面,执行如下命令,启动Broker服务:

# 启动broker服务,参数 -n 表示指定 nameserver的服务地址,多个采用逗号隔开
mqbroker -n localhost:9876

启动成功之后,控制台会输入The broker[xxxx] boot success,这就说明Broker服务启动成功。

到这里,RocketMQ消息队列环境算是启动成功啦,那要如何测试是否真的启动成功了呢???

1.6、测试RocketMQ

前面几个步骤已经搭建好了RocketMQ的运行环境,这里再使用命令测试一下发送和消费消息的功能。

还记得RocketMQ安装目录下,有一个benchmark目录吗?这个目录就是一个基准程序,什么意思呢,就是给你测试用的,这个目录下提供了发送和接收消息的执行命令,直接运行就可以进行测试。

但是,这里只提供了Linux系统下的测试程序,要想在Windows系统下使用,我们还需要自己手动改一下命令。

(1)发送消息

打开cmd命令行窗口,进入RocketMQ安装目录的bin目录里面,执行tools命令,发送消息:

# 设置环境变量,指定nameserver服务地址
set NAMESRV_ADDR="localhost:9876"

# 进入bin目录下,执行如下命令,就可以向RocketMQ发送消息
tools.cmd org.apache.rocketmq.example.quickstart.Producer

执行结果如下所示:

出现上图结果,就表示RocketMQ消息发送成功啦。

(2)接收消息

和发送消息是类似的,打开cmd命令行窗口,执行如下命令:

# 设置环境变量,指定nameserver服务地址
set NAMESRV_ADDR="localhost:9876"

# 进入bin目录下,执行如下命令,就可以从RocketMQ消费消息
tools.cmd org.apache.rocketmq.example.quickstart.Consumer

执行结果如下所示:

到此,安装RocketMQ消息队列运行环境就完成啦。

综上,这篇文章结束了,主要介绍如何安装RocketMQ消息队列运行环境。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/270183.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

11.1Linux串口应用程序开发

UART简介 UART的全称是Universal Asynchronous Receiver and Transmitter,即异步发送和接收。 串口在嵌入式中用途非常的广泛,主要的用途有: 打印调试信息;外接各种模块:GPS、蓝牙; 串口因为结构简单、稳…

mybatis缓存详解,一级缓存和二级缓存举例讲解

文章目录 mybatis缓存详解,一级缓存和二级缓存举例讲解1、一级缓存1.1、同一个sqlsession对象的不同mapper对象之间的缓存使用debug运行查看cache缓存 1.2、不同sqlsession对象下的不同mapper对象的缓存使用debug运行查看cache缓存 1.3、同一个sqlsession对象下一级…

【Java】SpringBoot快速整合Kafka

目录 1.什么是Kafka? 主要特点和概念: 主要组成部分: 2.Kafka可以用来做什么? 3.SpringBoot整合Kafka步骤: 1. 添加依赖: 2. 配置 Kafka: 3. 创建 Kafka 生产者: 4. 创建 Kafka 消费者: 5. 发布消息: 6. 使…

【基础篇】二、字节码文件的组成 Arthas + jclasslib +javap

文章目录 1、jclasslib工具2、基础信息部分3、常量池部分4、方法部分(从字节码指令看i)5、三种1操作的性能对比6、javap -v命令7、jclasslib插件8、Arthas 1、jclasslib工具 字节码文件中保存的是源代码编译后的内容,以二进制方式存储&#…

智能优化算法应用:基于协作搜索算法3D无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用:基于协作搜索算法3D无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用:基于协作搜索算法3D无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.协作搜索算法4.实验参数设定5.算法结果6.…

人工智能_机器学习074_SVM支持向量机_软间隔与优化目标函数构建_C参数由来_惩罚误差点的惩罚度---人工智能工作笔记0114

然后我们接着上一节再来看一下这里我们说有个 min_faces_per_person = 0 这个可以看到如果我们写上0,就意味着要加载所有的人脸图片,就会花费的时间久对吧 我们可以试试,这里我们 min_faces_per_person = 0 改成0然后 我们等一会加载完了以后,我们用 display(X.shape,faces.sh…

OpenEuler安装内网穿透工具实现ssh连接openEuler系统

文章目录 1. 本地SSH连接测试2. openEuler安装Cpolar3. 配置 SSH公网地址4. 公网远程SSH连接5. 固定连接SSH公网地址6. SSH固定地址连接测试 本文主要介绍在openEuler中安装Cpolar内网穿透工具实现远程也可以ssh 连接openEuler系统使用. 欧拉操作系统(openEuler, 简称“欧拉”…

自媒体实战篇:剪辑软件应用与实操

剪辑软件应用与实操 剪映基础界面认识 素材面板 导入本地素材,剪映自带素材库,音频,文本等素材合集面板播放预览 预览本地素材,,剪映自带素材库以及时间线面板中的素材的实时效果时间线面板 对素材进行基础的编辑操作,调整素材轨道等素材功能面板 可对素材或者文本等精细…

【软件工程】可执行文件和数据分离

一、概述 可执行文件和数据分离是一种软件设计策略,旨在将程序代码和程序使用的数据分离存储。这种方法通常用于提高软件的模块化程度和灵活性,以及方便软件的管理和维护。 在可执行文件和数据分离中,程序代码通常以可执行文件的形式存储&a…

什么是数据分析思维

参考 一文学会如何做电商数据分析(附运营分析指标框架) 电子商务该如何做数据分析?如何数据分析入门(从各项指标表象进入) https://www.processon.com/outline/6589838c3129f1550cc69950 数据分析步骤 什么是数据分析…

C# Onnx yolov8 pokemon detection

目录 效果 模型信息 项目 代码 下载 C# Onnx yolov8 pokemon detectio 效果 模型信息 Model Properties ------------------------- date:2023-12-25T17:55:44.583431 author:Ultralytics task:detect license:AGPL-3.0 h…

uniapp创建/运行/发布项目

1、产生背景----跨平台应用框架 在移动端各大App盛行的时代,App之间的竞争也更加激烈,他们执着于让一个应用可以做多个事情 所以就应运而生了小程序,微信小程序、支付宝小程序、抖音小程序等等基于App本身的内嵌类程序。 但是各大App他不可…

Python能做大项目(6)Poetry -- 项目管理的诗和远方之一

[Poetry] 是一个依赖管理和打包工具。Poetry 的作者解释开发 Poetry 的初衷时说: 通过前面的案例,我们已经提出了一些问题。但不止于此。 当您将依赖加入到 requirements.txt 时,没有人帮你确定它是否与既存的依赖能够和平共处,这…

2023读书笔记57|《顾城诗选》——我们走进了夜海, 去打捞遗失的繁星

2023读书笔记57|《顾城诗选》——我们走进了夜海, 去打捞遗失的繁星 细雨,洗去空气中的浮尘, 薄暗里蜜酒散开阵阵醇香。 野蜂在风雨的摇荡中开始安眠, 带着无限甜美的梦想。 河岸边,开满了耀眼的冰花。 沙洲上&#x…

设计模式-生成器模式

设计模式专栏 模式介绍模式特点应用场景生成器模式和工厂模式的区别代码示例Java实现生成器模式Python实现生成器模式 生成器模式在spring中的应用 模式介绍 生成器模式是一种创建型模式,它的主要目的是将一个复杂对象的构建与它的表示分离,使得同样的构…

OCP NVME SSD规范解读-1

OCP(Open Compute Project)是一个由Facebook于2011年发起的开源项目。其目标是重新设计和优化数据中心的硬件,包括服务器、存储、网络设备等,以提高效率,降低运营成本,并推动技术的创新和标准化。 在OCP中&…

thinkphp6.0的workerman在PHP8.0下报错

一、我先升级了thinkphp6.0到最新版本: composer update topthink/framework二、结果提示我composer版本过低,需要升级到2,于是我又升级了composer composer self-update 三、我又升级了workerman: composer require topthink/think-work…

主机安全技术措施

目录 身份鉴别 进阶 访问控制 进阶 安全审计 进阶 ​编辑 剩余信息保护 入侵防范 进阶 恶意代码防范 资源控制 身份鉴别 进阶 访问控制 进阶 安全审计 进阶 剩余信息保护 入侵防范 进阶 恶意代码防范 资源控制 ~over~

【回溯】符号三角形问题Python实现

文章目录 [toc]问题描述回溯法时间复杂性Python实现 个人主页:丷从心 系列专栏:回溯法 问题描述 下图是由 14 14 14个“ ”和 14 14 14个“ − - −”组成的符号三角形, 2 2 2个同号下面都是” “, 2 2 2个异号下面都是“ −…

如何编写高效清晰的嵌入式C程序

作为嵌入式工程师,怎么写出效率高、思路清晰的C语言程序呢? 要用C语言的思维方式来进行程序的构架构建 要有良好的C语言算法基础,以此来实现程序的逻辑构架 灵活运用C语言的指针操作 虽然看起来以上的说法很抽象,给人如坠雾里的感觉&…