1、下载RocketMQ在apache rocketmq官网,下载rocketmq,目前最新版本为4.2.0。选择bin-release.zip。下载完成后,解压缩至目标文件。
2、配置系统环境变量计算机——右键属性——高级系统设置——环境变量——新建,变量名:ROCKETMQ_HOME,变量值为rocketmq的安装目录。我的为D:\rocketmq-all-4.2.0-bin-release
3、启动nameserver方法1.打开cmd运行窗口,进入ROCKETMQ_HOME/bin目录下,执行start mqnamesrv.cmd,弹出如下结果窗口,表示成功启动nameserver方法2.直接打开
4、启动broker首先,在ROCKETMQ_HOME/bin文件夹下,修改runbroker.cmd命令中的set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%"为set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""方法1.打开cmd运行窗口,进入ROCKETMQ_HOME/bin目录下,执行start mqnamesrv.cmd,弹出如下结果窗口,表示成功启动nameserver方法2.在ROCKETMQ_HOME/bin文件夹下,双击mqbroker.cmd命令,启动broker
5、下载RocektMQ Console源码rocketmq的一个开源项目incubator-rocketmq-externals,仅下载rocketmq-console模块。进入github网站,找到rocketmq console,如图,点击Download ZIP。解压项目至目标文件。
6、导入Rockemq console项目使用idea导入该maven项目,并修改项目中application.properties文件,设置rocketmq.config.namesrvAddr=127.0.0.1:9876
7、启动项目打开项目中java目录下的App.java类,Run 'App'启动项目
8、查看控制台页面在浏览器中输入项目的url,本项目为localhost:8080,可看到RocketMQ的控制台页面