一、安装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"
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/251799.html
微信扫一扫 
支付宝扫一扫 