RocketMQ 5.1 安装

RocketMQ 5.1 安装

一、安装

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

发表回复

您的电子邮箱地址不会被公开。