首先，下载二进制版的RocketMQ
1.下载地址：http://rocketmq.apache.org/release_notes
mq下载1.png
mq下载2.png
2.配置系统环境变量
变量名：ROCKETMQ_HOME
变量值：MQ解压路径，本人的安装路径是（D:\dev\mq\rocketmq），注意，安装目录不能有空格，否则mqnamesrv服务将启动失败。
image.png
修改MQ配文件:进入到bin目录下，修改runbroker.cmd和runserver.cmd文件
把%CLASSPATH%用引号引起来"%CLASSPATH%",否则启动会报错
image.png
image.png
3.首先启动mqnamesrv.cmd,再启动mqbroker.cmd
启动mqnamesrv.cmd
（start mqnamesrv.cmd），
启动mqbroker.cmd(start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true)
image.png
mqnameserver.cmd 启动成功，如图
image.png
mqbroker.cmd启动成功，如图：
image.png
验证是否安装成功：
RocketMQ自带了发送与接收消息的脚本tools.cmd，用来验证RocketMQ的功能是否正常 。
4.首先，打开一个cmd窗口，跳转到bin目录下,启动消费者
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
image.png
5.再打开一个cmd窗口，跳转到bin目录下,启动生产者
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer
image.png
消费者中能收到消息说明程序正常！
6.使用RocketMQ管理台管理RocketMQ
(1) 下载RocketMQ控制台插件externals
下载管理台插件：https://github.com/apache/rocketmq-externals.git
将externals插件克隆到本地磁盘，或者打开地址下载zip压缩包。
(2）修改插件配置
下载完成之后，进入‘rocketmq-externals ocketmq-consolesrcmain esources’文件夹，打开‘application.properties’进行配置。
server.port=9801 #配置rocketmq的地址
rocketmq.config.namesrvAddr=127.0.0.1:9800
image
(3)使用maven编译并启动external插件
使用maven编译启动插件，如果没安装maven，请先安装maven。
maven安装与配置请参考：https://www.cnblogs.com/yyee/p/14570992.html
在 cmd命令窗口下进入‘ ocketmq-externals ocketmq-console’文件夹，执行‘mvn clean package -Dmaven.test.skip=true’，编译生成。
image
输出上面的提示表示编译成功。
进入 ocketmq-console arget 目录，执行【java -jar rocketmq-console-ng-2.0.0.jar】，启动【rocketmq-console-ng-2.0.0.jar’】。
image
（4）测试RocketMQ控制台
启动成功后，在浏览器里输入插件地址127.0.0.1:9801 打开RocketMQ控制台。
image
能打开控制台页面表示插件启动成功。
网友评论