Windows 下 RocketMQ 的安装及配置

1. 安装 java 环境

1.1 下载 jdk8

官网  :   https://www.oracle.com/java/technologies/downloads/#java8-windows

下载 msi 文件直接安装即可完成 java 环境部署。

2.下载 RocketMQ

官网下载地址  https://rocketmq.apache.org/zh/download

选择 Binary 下载及版本下载即可。

3. 解压文件夹

将下载获得的压缩文件解压获得 RocketMQ 文件夹,将其重命名并复制到新的位置,如 : E:\services\rocketmq。

4. 配置 RocketMQ 环境变量

在任务栏搜索框里面搜素环境变量,新建一个系统环境变量 : ROCKETMQ_HOME,赋值为 RocketMQ 文件夹路径。

5. 修改 RocketMQ 配置

默认情况下启动会占用 4 ~ 8 G的服务器内存,请根据实际情况进行修改 :

5.1 修改 E:\services\rocketmq\bin\runserver.cms

set JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
为
set JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

5.2 修改 E:\services\rocketmq\bin\runbroker.cmd

set JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
为
set "JAVA_OPT=%JAVA_OPT% -server -Xms256m -Xmx256m"

6 启动 RocketMQ 服务

6.1 启动 NameServer

双击 mqnamesrv.cmd 启动 NameServer  服务:

The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
# 代表启动成功

6.2 启动 Broker+Proxy

双击 mqbroker.cmd 启动 Broker 服务

The broker[...] boot success. serializeType=JSON and name server is localhost:9876
# 代表启动成功

7 工具测试收发

在进行工具测试消息收发之前,我们需要告诉客户端NameServer的地址,RocketMQ有多种方式在客户端中设置NameServer地址,这里我们利用环境变量NAMESRV_ADDR。

7.1 添加系统环境变量

添加系统环境变量 NAMESRV_ADDR,值为 localhost:9876。

7.2 测试生产者生产消息

E:\>cd E:\services\rocketmq\bin
tools.cmd org.apache.rocketmq.example.quickstart.Producer

7.3 测试消费者消费消息

tools.cmd org.apache.rocketmq.example.quickstart.Consumer

关闭服务

### 关闭 broker

mqshutdown.md broker

### 关闭 nameserver

mqshutdown namesrv