【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消息队列运行环境。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

PostgreSql 并行

一、概述 当服务器有多核 cpu 时,PostgreSQL 会根据默认配置,在合适的条件下自动进行并行操作,除非主动关闭了相关并行参数。 二、并行相关参数 max_worker_processes:系统能够支持的后台进程的最大数量,默认是 8&…

Linux网卡配置

一、网卡配置 1、目录参数 /etc/syscofig/network-scripts/ifcfg-e*** /etc 目录时Linux系统的配置文件,有相对权限的用户能修改目录,但普通用户都可以访问。 sysconfig /etc/sysyconfig目录包含了Linux的系统配置文件 network-scripts network-scripts…

HarmonyOS共享包HAR

共享包概述 OpenHarmony提供了两种共享包,HAR(Harmony Archive)静态共享包,和HSP(Harmony Shared Package)动态共享包。 HAR与HSP都是为了实现代码和资源的共享,都可以包含代码、C库、资源和配…

运维工程师:IT 界的“万金油”,可爱的六边形战士

在IT界,运维工程师常常被形容为“万金油”,这个可爱的角色既是修理工,又是消防员,还是魔术师。他们身兼数职,无所不能,为企业的IT系统提供稳定、高效、安全的运行环境。让我们一起走进运维工程师的世界&…

Salesforce推出Trailblazer就业市场,让求职更简单!

12月14日,Salesforce宣布推出Trailblazer就业市场(Trailblazer Career Marketplace),这是一个新的人才中心,也是Trailhead的扩展。Trailblazer就业市场致力于将数据、人工智能和CRM领域的专业人士与Salesforce生态系统…

CentOS8+宝塔面板+cpolar内网穿透搭建可公网访问的Typecho个人站点

文章目录 前言1. 安装环境2. 下载Typecho3. 创建站点4. 访问Typecho5. 安装cpolar6. 远程访问Typecho7. 固定远程访问地址8. 配置typecho 前言 Typecho是由type和echo两个词合成的,来自于开发团队的头脑风暴。Typecho基于PHP5开发,支持多种数据库&#…

Spring Cloud Alibaba 之 Sentinel

大家好,我是升仔 引言 在微服务架构中,服务之间的依赖错综复杂。一旦某个服务出现问题,很容易引发连锁反应,导致整个系统瘫痪。Sentinel 就是为了解决这类问题而生的。它通过流量控制、熔断降级等机制,保护服务不被过多…

Flutter windows 环境配置

Flutter windows 环境配置 从零开始,演示flutter环境配置到启动项目,同时支持 vscode 和 android studio 目录 Flutter windows 环境配置一、环境配置1. Flutter SDK2. Android Studio3. JDK4. 拓展安装5. Visual Studio 2022二、项目创建和启动1. vsco…

Java面试题66-75

66、Collection 和 Collections的区别。 Collection是集合类的上级接口,继承与他的接口主要有Set 和List. Collections是针对集合类的一个帮助类,他提供一系列静态方法实现对各种集合的搜索、排序、线程安全化等操作。 67、Set里的元素是不能重复的…

Ansys Lumerical | 带2D输出耦合器的出瞳扩展器的优化

附件下载 联系工作人员获取附件 本文提出并演示了一种以二维光栅为外耦合器的出瞳扩展器(EPE)系统的仿真方法,并给出了优化和公差分析的实例。 在此工作流程中,我们使用 Lumerical 构建光栅模型,并使用 RCWA 求解器模…

Python深度学习030:torchvision.models有哪些已经写好的模型 | 以resnet18网络为例讲解如何使用(含数据、代码和结果展示)

文章目录 torchvision.models中的模型图像分类目标检测和实例分割语义分割视频分类注意事项以resnet18网络为例讲解如何使用(含数据、代码和结果展示)torchvision.models 提供了一系列预训练的模型,主要用于图像分类、目标检测、图像分割等任务。 torchvision.models中的模型…

ubuntu18设置开机自启动

项目需求:机器人开机上电后工控机首先运行机械臂控制代码,再运行算法代码 1.终端执行以下代码 gnome-session-properties 2.设置开机自启动选项 在弹出界面点击添加,名称随便填,命令填入要启动的脚本,注释随便填。 …

【CAD二次开发】如何通过lsp实现dll程序的自动加载

通常我们在收到一个dll格式的CAD插件的时候会通过NETLOAD手动加载,这个缺点是每次重启CAD后都需要再加载dll插件; 有没有什么方法可以实现dll插件的自动加载呢; 答案是有,下面我们分享几种简单的方法实现dll的自动加载; 方法1&…

nginx: [error] open() “/var/run/nginx/nginx.pid“ failed (2: No such file or directory)

该错误消息通常表示 Nginx 在启动过程中无法找到指定路径的日志文件或进程号文件。 我这边是因为服务器断电,导致该问题 这个问题可能有几种原因和解决方法: 1. 确保 Nginx 配置文件中的日志路径正确。在 Nginx 配置文件中查找 error_log 和 pid 配置指…

密码学学习笔记(二十三):哈希函数的安全性质:抗碰撞性,抗第一原象性和抗第二原象性

在密码学中,哈希函数是一种将任意长度的数据映射到固定长度输出的函数,这个输出通常称为哈希值。理想的哈希函数需要具备几个重要的安全性质,以确保数据的完整性和验证数据的来源。这些性质包括抗碰撞性、抗第一原象性和抗第二原象性。 抗碰…

MidJourney笔记(9)-daily_theme-docs-describe

/daily_theme 切换 #daily-theme 频道更新的通知。 但我发现在对话框那里,是没有这个命令的: 但官网是有介绍,不知道是不是版本问题还是这个命令已经无效。 但后来,我发现这个命令是要在Midjourney服务对话框那里才有,在我们后面添加的Mid

docker部署jenkins,发布任务执行scp免密传输

第一步 进入docker容器 # 因为jenkins的任务都是以jenkins用户执行,必须以jenkins用户进入容器生成公私钥 docker exec -it -u jenkins jenkins /bin/bash第二步 在容器内生成公私钥 # 容器中生成公私钥 直接三次回车不设置密码等信息 ssh-keygen -t rsa第三步 查…

测试C#使用AForge从摄像头获取图片

百度“C# 摄像头”关键词,从搜索结果来看,使用OpenCV、AForge、window动态链接库获取摄像头数据的居多,本文学习基于Aforge.net连接摄像头并从摄像头获取图片的基本方法。   AForge相关包(尤其是相关的控件)主要针对…

Spring--BeanFactoryPostProcessor与BeanPostProcessor的职责与区别

BeanFactoryPostProcessor与BeanPostProcessor的职责与区别 BeanFactoryPostProcessor: 职责: BeanFactoryPostProcessor 负责在容器实例化任何 bean 之前对 bean 定义进行修改。它允许你在 bean 被实例化之前对 bean 的定义进行全局性的修改&#xff…

计算机网络简述

前言 计算机网路是一个很庞大的话题。在此我仅对其基础概述以及简单应用进行陈述。后续或有补充以形成完善的计算机网络知识体系。 一.计算机网络的定义 根据百度词条的描述,计算机网络是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过…