一、安装
1、下载 rocketmq-all-5.1.0-bin-release.zip 。
地址:https://rocketmq.apache.org/zh/download/
2、解压缩到 D:\java\rocketmq-all-5.1.0-bin-release。
3、设置环境变量。(另外需要安装jdk1.8)
新建 ROCKETMQ_HOME
在PATH里面添加 %ROCKETMQ_HOME%\bin
4、参数设置。
① bin\runserver.cmd
修改前
set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
Xms2g -Xmx2g -Xmn1g 在电脑配置低的情况下,可以调小一些。
修改后
set "JAVA_OPT=%JAVA_OPT% -server -Xms512m -Xmx512m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
② bin\runbroker.cmd
修改前
set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g"
修改后
set "JAVA_OPT=%JAVA_OPT% -server -Drocketmq.broker.diskSpaceWarningLevelRatio=0.98 -Xms512m -Xmx512m -Xmn512m"
-Drocketmq.broker.diskSpaceWarningLevelRatio=0.98的意思是:把Broker磁盘空间利用率设置为98%,默认是85%。即只有磁盘空间使用率达到98%时才拒绝接收producer消息。
5、启动NameServer。进入cmd命令行。
mqnamesrv.cmd
出现如下信息,则表示启动成功。
6、启动broker。进入cmd命令行。
mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
出现如下信息,则表示启动成功。
补充:如果mqbroker.cmd启动失败,则只需要删除C:\Users\Administrator\store目录下面的所有文件即可,如果不放心,建议先备份再删除。
二、测试
1、发送消息
进入cmd命令窗口,执行:
cd D:\java\rocketmq-all-5.1.0-bin-release\bin d: set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Producer
2、接送消息
进入cmd命令窗口,执行:
cd D:\java\rocketmq-all-5.1.0-bin-release\bin d: set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Consumer