一：RocketMQ 简介

RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点：

1. 能够保证严格的消息顺序。
2. 提供丰富的消息拉取模式。
3. 高效的订阅者水平扩展能力。
4. 实时的消息订阅机制。
5. 亿级消息堆积能力。

二：RocketMQ的安装
1.下载RocketMQ源码

下载地址 rocketmq-4.4.0

2.解压 , 进入解压目录

unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.4.0

3.执行安装命令

mvn -Prelease-all -DskipTests clean install -U

4.安装完成后进入启动文件所在目录

cd distribution/target/apache-rocketmq

5.启动服务器， 查看启动日志

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log

6.启动broker , 查看broker启动日志

nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log

7.查看是否启动成功
jps

8.停止服务，停止broker

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv

8.常见问题

• JAVA_HOME 环境变量未配置，可设置RocketMQ的JDK环境 ， 打开bin目录下 runserver.sh 和 runbroker.sh, 将设置JAVA_HOME的第二三行注释掉，在第一行设置JDK的安装目录。如下所示：

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_181.jdk/Contents/Home
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!