您的位置:

如何在Windows上安装RocketMQ消息队列

一、安装JDK

安装RocketMQ需要先安装Java环境,可以从官网下载最新版本的JDK安装包。


// 下载JDK安装包,选择适合自己操作系统版本的安装包
https://www.oracle.com/java/technologies/javase-downloads.html
// 双击安装包进行安装

二、下载RocketMQ

从Apache官网下载最新的RocketMQ压缩包,解压到指定目录下。


// 下载RocketMQ压缩包,选择最新稳定版本进行下载
https://rocketmq.apache.org/dowloading/releases/

// 解压至指定目录,例如解压后的目录为 E:\rocketmq-all-4.9.0-incubating

三、配置环境变量

为RocketMQ配置环境变量,方便在任何目录下都能够使用RocketMQ的相关工具。


// 在系统变量中新增ROCKETMQ_HOME变量,变量值为RocketMQ的安装路径
ROCKETMQ_HOME=E:\rocketmq-all-4.9.0-incubating

// 在Path变量中新增%ROCKETMQ_HOME%\bin
Path=%Path%;%ROCKETMQ_HOME%\bin

四、启动RocketMQ服务

启动Name Server服务和Broker服务,可以使用RocketMQ提供的启动脚本文件。


// 启动Name Server服务
cd %ROCKETMQ_HOME%\bin
start mqnamesrv.cmd

// 启动Broker服务
cd %ROCKETMQ_HOME%\bin
start mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

五、验证安装是否成功

使用RocketMQ提供的Shell命令行工具进行验证,确认RocketMQ安装成功。


// 启动消费者,接收消息
cd %ROCKETMQ_HOME%\bin
mqconsume.cmd -n localhost:9876 -t TopicTest

// 启动生产者,发送消息
cd %ROCKETMQ_HOME%\bin
mqsend.cmd -n localhost:9876 -t TopicTest -m "Hello, RocketMQ"