RocketMQ作为一款纯Java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等，主要功能是异步解耦和流量削峰。RocketMQ主要有四大核心组成部分：NameServer、Broker、Producer以及Consumer四部分。

目录

下载地址：

• https://rocketmq.apache.org/
• https://github.com/apache/rocketmq/releases

本文部署的RocketMQ版本：4.9.3

上传

手动将下载的文件上传至服务器或者：

# scp xxxx.tar.gz 用户名@ip:存放在服务器上的地址，如下：
scp xxx.tar.gz root@11.11.0.11:/root

解压

然后解压：

tar -zxvf xxx.tar.gz
# 或者
unzip -d xxx.zip

配置

进入RocketMQ的安装目录：

cd /usr/local/rocketmq/rocketmq-all-4.9.3-bin-release

创建存放数据的目录：

mkdir -p store store/commitlog store/consumequeue

进入conf 目录：

cd conf

编辑 broker.conf 文件：

vi broker.conf

在 broker.conf 文件中追加以下内容：

listenPort=10911
namesrvAddr=11.11.11.11:9876
autoCreateTopicEnable = true
enablePropertyFilter=true # 开启语法过滤中的支持，可不添加
storePathRootDir=/root/rocketMq/rocketmq/store
storePathCommitLog=/root/rocketMq/rocketmq/store/commitlog
storePathConsumerQueue=/root/rocketMq/rocketmq/store/consumequeue

修改内存大小（可选）

这步不是必须的，如果你的机器内存足够，可以跳过这步。

进入 bin 目录：

cd /root/rocketMq/rocketmq/bin

编辑 runbroker.sh 文件和 runserver.sh 文件，修改内存大小：

vi runbroker.sh

找到并修改：

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m"

再修改 runserver.sh 文件：

vi runserver.sh

找到并修改两个地方：

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

开放端口

服务器开放9876和10911端口。即刚才的broker.conf里面增加的。

然后再执行：

# 开放防火墙 9876 和 10911 端口
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
# 更新防火墙规则
firewall-cmd --reload
# 查看防火墙所有开放的端口
firewall-cmd --list-port

启动RocketMQ

先启动nameserver再启动broker。

进入bin目录：

# 启动nameserver
nohup sh mqnamesrv &
# 启动broker，指定conf文件，以及对应的ip和端口
nohup sh mqbroker -c /root/rocketMq/rocketmq/conf/broker.conf -n 11.11.11.11:9876 &

启动之后就可以进行尝试了。

关闭RocketMQ

先关闭broker再关闭nameserver。

进入 bin 目录：

sh mqshutdown broker
sh mqshutdown namesrv

配置环境变量（可选）

可无需执行，单纯进行记录。

# 配置环境变量 ROCKETMQ_HOME 和 PATH
vim /etc/profile
 
# 文件末尾添加以下内容
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$ROCKETMQ_HOME/bin:$PATH

# 立即生效
source /etc/profile