一、介绍
RocketMQ：云原生“消息、事件、流”实时数据处理平台，覆盖云边端一体化数据处理场景
二、环境要求
- 64位操作系统，推荐 Linux/Unix/macOS
- 64位 JDK 1.8+
- 本文采用二进制包方式安装，版本为4.4.0
三、下载
3.1 二进制包官网下载链接
点击下载
3.2 二进制包百度网盘下载链接
通过百度网盘分享的文件：rocketmq-all-4.4.0-bin-release.zip
链接：https://pan.baidu.com/s/1Bxk9hz27vM62GFq7SN5eow?pwd=6nwd
提取码：6nwd
3.3 二进制包夸克网盘下载链接
我用夸克网盘分享了「rocketmq-all-4.4.0-bin-release.zip」，点击链接即可保存。打开「夸克APP」，无需下载在线播放视频，畅享原画5倍速，支持电视投屏。
链接：https://pan.quark.cn/s/44a5b8eaeb02
3.4 上传到指定目录
我们将文件上传到/root/mq目录下，然后使用unzip命令进行解压
然后我们使用mv命令重命名文件，命令如下
mv rocketmq-all-4.4.0-bin-release rocketmq
接着使用cd命令进入对应文件夹
cd rocketmq
四、目录介绍
4.1 benchmark
存放一些demo，可以直接运行。
4.2 bin
启动脚本，包括shell脚本和cmd脚本
4.3 conf
RocketMQ实例配置文件，包过broker配置文件，logback配置文件等
4.4 lib
依赖第三方jar包，包括Netty、commons-lang、FastJSON等
五、启动RocketMQ
5.1 启动NameServer
# 1.进入bin目录
cd /root/mq/rocketmq/bin
# 2.启动NameServer
nohup sh mqnamesrv &
# 3.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
看到下图代表启动成功
5.2 启动Broker
# 1.进入bin目录
cd /root/mq/rocketmq/bin
# 2.启动Broker
nohup sh mqbroker -n localhost:9876 &
# 3.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
如果发现tail命令找不到文件的话，说明可能Broker启动失败了。需要我们进行排查（可以参考备注）
启动成功图片如下
六、测试RocketMQ
我们在启动两个窗口进行测试，两个窗口都进入bin目录
cd /root/mq/rocketmq/bin
6.1 第一个窗口
然后我们在第一个窗口，输入下面代码，发送消息
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
发送成功如图所示
6.2 第二个窗口
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
我们可以看到第二个窗口一直处于正在接受信息的状态，同时上面输出的消息也是第一个窗口发送的
七、关闭RocketMQ
# 1.进入bin目录
cd /root/mq/rocketmq/bin
# 2.关闭NameServer
sh mqshutdown namesrv
# 3.关闭Broker
sh mqshutdown broker
八、备注
RocketMQ默认的虚拟机内存为8G，启动Broker如果因为内存不足失败，需要编辑如下两个配置文件，修改JVM内存大小
# 编辑runbroker.sh和runserver.sh修改默认JVM大小
vim runbroker.sh
vim runserver.sh
# 参考配置 按i键进入插入模式，按ESC后输入 :wq 保存
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
然后重启nameserver和broker