RocketMQ安装使用

前言

描述：本文章主要用来记录 RocketMQ 在 windows的安装使用

1 Windows环境安装

RocketMQ下载地址

1.1 环境变量配置

ROCKETMQ_HOME:rocket安装包目录

1.2 启动操作

需要进入到 \bin 目录下

描述：需要启动2个文件。

启动命令：

• start mqnamesrv.cmd
• start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

上面的命令涉及到2个文件 mqnamesrv.cmd 和 mqbroker.cmd

说明：在此之前，可以改一下配置文件，主要是虚拟机的内存大小。按需修改（可改可不改）。

（1）文件1：runserver.cmd

原文件内容：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
1

修改为：

rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx256m"
1
2

（2）文件2：runbroker.cmd

修改为：

rem set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"
set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx256m"
1
2

本人理解：主要是怕做实验的时候，机器内存不够，启动报错，手动改文件配置项，方便顺利启动项目。

问题1：第二个启动命令，会发生报错，意思是找不到java程序的路径。
解决办法：修改runbroker.cmd文件

set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""
1

描述：给 %CLASSPATH% 左右再加个双引号。
本人理解：估计类似于字符串需要加引号才能找到路径。

（3）如何判断是否启动成功

第一个启动命令成功信息：

Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON
1
2
3

第二个启动命令成功信息：

The broker[FQ-YJSOBQWHTKTJ, 172.16.8.37:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876
1

1.3 下载控制台

官方下载地址

1、定制化配置

描述：可以修改启动端口号，配置RocketMq服务地址

示例：文件路径：rocketmq-console\src\main\resources\application.properties

server.port=7777
rocketmq.config.namesrvAddr=localhost:9876
1
2

2、打包启动

打包命令： mvn clean package -Dmaven.test.skip=true

启动命令：java -jar rocketmq-console-ng-1.0.0.jar

访问路径：localhost:7777