1.1 下载 jdk8
官网 : https://www.oracle.com/java/technologies/downloads/#java8-windows
下载 msi 文件直接安装即可完成 java 环境部署。
官网下载地址 https://rocketmq.apache.org/zh/download
选择 Binary 下载及版本下载即可。
将下载获得的压缩文件解压获得 RocketMQ 文件夹,将其重命名并复制到新的位置,如 : E:\services\rocketmq。
在任务栏搜索框里面搜素环境变量,新建一个系统环境变量 : ROCKETMQ_HOME,赋值为 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.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
# 代表启动成功
在进行工具测试消息收发之前,我们需要告诉客户端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