本文使用CentOs7系统进行安装 若对linux命令不熟悉可以进入以下链接学习
Linux系统命令学习笔记: 上部.
Linux系统命令学习笔记: 下部.
准备工作
因为RocketMq是使用java编写的 所以依赖java环境
在安装前 请检查一下Linux的JDK是否安装 可参照我发表的JDK安装教程进行安装
快速入口: 超详细-安装JDK、tomcat、MySQL三大服务-Linux-JAVA基本环境的搭建.
安装
官方下载地址: 点击版本号进入下载即可.
下载后使用XFTP7工具将rocketmq安装包上传至Linux服务器（安装jdk教程中也使用到了xftp工具）
rocketmq-all-4.9.1-bin-release.zip
解压
解压 unzip rocketmq-all-4.9.1-bin-release.zip
重命名文件夹: mv rocketmq-all-4.9.1-bin-release rocketmq-4.9.1
删除压缩包:rm -rf rocketmq-all-4.9.1-bin-release.zip
修改配置文件
进入rocketmq文件夹的bin目录下
cd /usr/local/rocketmq-4.9.1/bin
首先简单介绍一下NameServer和Broker分别是什么
- NameServer：路由中心。可以理解为是消息队列的协调者，Broker向它注册路由信息，同时Client向其获取路由信息。个人认为和Nacos等注册中心概念相似。
- Broker：Broker是RocketMQ的核心，提供了消息的接收，存储，拉取等功能。类似于微服务中的一个服务实例。
所以我们需要先启动NameServer再启动Broker完成注册 但RocketMq的默认配置JVM内存要求较高 经常出现无法启动服务的错误 所以我们需要手动修改一下配置文件（机器配置高的小伙伴可以跳过本节内容）
① 编辑runserver.sh
原来的配置
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
要求过高 会导致无法启动服务
将内存占用修改小一点为256m即可 如下
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改完成后输入wq保存退出编辑
② 修改 runbroker.sh
原来的配置
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
与上面一致 同理修改为
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"
修改完成后输入wq保存退出编辑
启动服务
请保证当前位置为 rocketmq的bin目录下
① 启动NameServer
启动命令：nohup sh mqnamesrv & （nohup + &表示服务在后台持续运行）
查看日志命令：tail -f ~/logs/rocketmqlogs/namesrv.log
说明;
-f 表示若文本更新则持续输出更新内容
日志文件产生在家目录下的logs文件夹 而非rocketmq安装目录
② 启动Broker
在启动Broker过程中 服务报错了 并提示以下信息
2021-08-26 21:47:07 ERROR StoreScheduledThread1 - Error when measuring disk space usage, file doesn't exist on this path: /root/store/commitlog
2021-08-26 21:47:08 ERROR DiskCheckScheduledThread1 - Error when measuring disk space usage, file doesn't exist on this path: /root/store/commitlog
2021-08-26 21:55:34 ERROR StoreScheduledThread1 - Error when measuring disk space usage, file doesn't exist on this path: /root/store/consumequeue
通过信息可以得知 Broker希望我在/root/store目录下创建一个commitlog文件夹及consumequeue文件夹
创建前请先停止broker服务（命令在下一小节）
创建命令：mkdir /root/store/文件夹名
创建完成后再次启动Broker
启动命令：nohup sh mqbroker -n localhost:9876 &
说明：
-n 表示指定NameServer的服务地址ip及端口号(默认9876) 这样broker才能注册进NameServer
查看启动日志：
tail -f ~/logs/rocketmqlogs/broker.log
关闭服务
请在安装目录的bin目录下执行
sh mqshutdown namesrv关闭NameServersh mqshutdown broker关闭Broker
测试服务
开启两个Linux远程连接 一个作为发送方 一个作为接收方 使用rocket自带的测试Demo进行测试
① 发送端
export NAMESRV_ADDR=localhost:9876 配置环境变量
sh tools.sh org.apache.rocketmq.example.quickstart.Producer 执行生产者发送消息脚本
② 服务端
export NAMESRV_ADDR=localhost:9876 配置环境变量
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer 执行消费者消费消息脚本
运行错误
在我启动发送端的测试脚本时 终端显示以下报错信息
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 1 DESC: create mapped file failed, server is busy or broken.
最后排查出来的是在上面启动Broker小节出现的报错信息 意在创建commitlog文件夹及consumequeue文件夹 而非文件
mkdir /root/store/commitlog
mkdir /root/store/consumequeue