前言

项目中用到了延迟消息队列，记录下一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

原文：https://www.cnblogs.com/maggieq8324/p/15186856.html