[大数据]RocketMQ 学习笔记

1 安装与配置

1.1 安装

官网下载并安装rocket-mq，选择Binary文件

Release Notes - Apache RocketMQ - Version 4.9.2 - Apache RocketMQ

1.2 配置环境变量

新建变量ROCKETMQ_HOME，配置rocketmq安装路径，最好不要有中文，免得引起不必要的问题。

1.3 修改RocketMQ默认的虚拟机内存

默认的jvm内存是2g，可自行修改

?

?

2 启动与测试

bin/mqbroker 的一些可选参数：

-c：指定配置文件路径
-n：NameServer 的地址

2.1 启动namesrv

命令行：进入rocketmq安装的bin目录

启动命令：

start mqnamesrv.cmd

提示：nameserver启动后的默认端口为9876，若与本机冲突，可自行修改nameserver端口

修改namesrv默认端口：
1、在目录D:\DevelopInstall\rocketmq-4.9.2\conf，新增namesrv.conf文件
2、编辑文件，新增内容：
listenPort=9988

可参考：
https://blog.csdn.net/one_week/article/details/120325345

更改端口后启动命令：

start mqnamesrv.cmd -c ../conf/namesrv.conf

2.2?启动broker

命令行：进入rocketmq安装的bin目录

启动命令：

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

更改namesrv端口后启动命令：

start mqbroker.cmd -n 127.0.0.1:9988 autoCreateTopicEnable=true

2.3 测试

命令行：进入rocketmq安装的bin目录

启动消费者

set NAMESRV_ADDR=localhost:9988
tools.cmd org.apache.rocketmq.example.quickstart.Consumer

新开窗口，命令行：进入rocketmq安装的bin目录

启动生产者

set NAMESRV_ADDR=localhost:9988
tools.cmd org.apache.rocketmq.example.quickstart.Producer

?在消费者的窗口按住Ctrl+C，就会接收到刚刚生产者发出的消息

?至此测试完毕。

提示：关闭namesrv broker

命令行：进入rocketmq安装的bin目录

mqshutdown namesrv

mqshutdown broker