Windows下安装RocketMQ

2024-10-13 21:33:55

目录

前言
- 环境
具体操作

前言

项目中用到了延迟消息队列，记录下一win10下rocketmq的安装

环境

win10 + rocketmq4.7.0

具体操作

下载

链接：https://rocketmq.apache.org/dowloading/releases

环境变量配置

配置环境变量ROCKETMQ_HOME，值为rocketmq压缩包解压路径，路径中不能包含空格

否则会出现如下错误：

错误: 找不到或无法加载主类 Files\rocketmq\bin\Files\rocketmq\lib

注：rocketmq还需配置jdk环境变量 -> JAVA_HOME

启动

Start Name Server，cmd窗口rocketmq/bin目录下执行

start mqnamesrv

Start Broker，新cmd窗口rocketmq/bin目录下执行

start mqbroker -n localhost:9876 autoCreateTopicEnable=true

关闭

可以手动关闭cmd终端，也可以使用 mqshutdown脚本
关闭broker

mqshutdown broker

关闭namesrv

mqshutdown namesrv

生产、消费实例

设置NAMESRV_ADDR:

set namesrv_addr=localhost:9876

生产者 Send Messages，rocketmq/bin目录下执行：

tools org.apache.rocketmq.example.quickstart.Producer

消费者 Receive Messages，rocketmq/bin目录下执行：

RocketMQ Console

RocketMQ Console是RocketMQ提供的可视化管理工具，方便可视化的操作，下载地址：https://github.com/apache/rocketmq-externals/tree/release-rocketmq-console-1.0.0
修改配置文件rocketmq-console\src\main\resources\application.properties如下：

rocketmq-console主目录下运行打包命令：

mvn clean package -Dmaven.test.skip=true

打包后如下所示：

rocketmq-console\target目录下运行启动命令：

java -jar rocketmq-console-ng-1.0.0.jar

启动成功后访问http://localhost:8088

- End -
﹀
﹀
﹀
梦想是咸鱼
关注一下吧

最新文章

热门文章