1.环境准备

1、Linux服务器或虚拟机（CentOS7.5 至少2G内存）；
2、Java环境（JDK8）；
3、RocketMQ安装包（4.7.1版本）；

2.单机版安装

• 1.下载 rocketmq 安装包

官网下载最新版地址：https://downloads.apache.org/rocketmq/
历史版本下载地址：https://archive.apache.org/dist/rocketmq/
4.7.1版下载地址：https://archive.apache.org/dist/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

下载方式1：外部下载好上传（例如：使用 xftp 上传）

下载方式2：CentOS 系统内在指定位置使用 wget 命令下载

wget https://archive.apache.org/dist/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

注意：本次演示的安装目录是：/usr/app/rocketmq

• 2.解压安装包

1）安装 zip 和 unzip 工具：yum install -y unzip zip
2）解压 zip 安装包：unzip rocketmq-a11-4.7.1-bin-release.zip
3）重命名解压目录：mv rocketmq-all-4.7.1-bin-release rocketmq-4.7.1

• 3.解压安装包创建软链（主要是方便使用）

ln -s /usr/app/rocketmq/rocketmq-4.7.1 /usr/local/rocketmq

• 4.创建数据存储目录

mkdir -p /usr/local/rocketmq/store/broker-a /usr/local/rocketmq/store/broker-a/consumequeue /usr/local/rocketmq/store/broker-a/commitlog /usr/local/rocketmq/store/broker-a/index /usr/local/rocketmq/store/broker-a/logs

• 5.修改配置文件

cd /usr/local/rocketmq
vim conf/broker.conf

增加以下内容：

# Broker 对外服务的监听端口
listenPort=10911
# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
# nameServer地址，分号分割
namesrvAddr=localhost:9876
# 开启对SQL语法的支持（默认没有开启）
enablePropertyFilter=true
# 存储路径
storePathRootDir=/usr/local/rocketmq/store/broker-a
# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/broker-a/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/broker-a/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/broker-a/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/broker-a/checkpoint
# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/broker-a/abort

• 6.启动NameServer、Broker

################### NameServer ###################
# 1.修改runserver.sh,将jvm启动参数改小,原因是服务器小的话,启动不成功或服务器宕机.默认值是 4G大小
## JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
vim bin/runserver.sh
# 1.1.修改内容如下。
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# 2.启动 mqnamesrv
nohup /usr/local/rocketmq/bin/mqnamesrv &
# 3.查看 NameServer启动日志(家目录下)
tail -f ~/logs/rocketmqlogs/namesrv.log
# 4.关闭 mqnamesrv
/usr/local/rocketmq/bin/mqshutdown namesrv

################### Broker ###################
# 1.修改runbroker.sh,把内存调小,默认是8G
## JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
vim bin/runserver.sh
# 1.1.修改内容如下。
JAVA_OPT="${JAVA_OPT} -server -Xms768m -Xmx768m -Xmn384m"
# 2.启动 broker
nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker.conf &
# 3.查看 Broker 启动日志
tail -f ~/logs/rocketmqlogs/broker.log
# 4.关闭 broker
/usr/local/rocketmq/bin/mqshutdown broker

• 7.发送和接收消息验证

cd /usr/local/rocketmq/bin
# 创建topic
sh mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t TopicTest
# 设置临时环境变量
export NAMESRV_ADDR=localhost:9876
# 开启自带的生产者
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
# 开启自带的消费者
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

• 8.开放访问端口（防火墙关闭时下述指令不执行）

# 添加开放端口
firewall-cmd --add-port=9876/tcp --permanent
firewall-cmd --add-port=10911/tcp --permanent
# 重启防火墙应用规则
firewall-cmd --reload
# 查看开放端口列表
firewall-cmd --list-port

以上单机单实例安装完成。

3.RocketMQ Web 控制台源码安装

• 1.下载项目源码

官方下载地址如示：https://codeload.github.com/apache/rocketmq-externals/zip/refs/heads/master，

浏览器下载后，文件名为：rocketmq-externals-master.zip.

Linux 系统下使用 wget 下载，不指定下载后的文件名，显示的内容就是 master，这个是 zip 格式的文件。因此一般指定文件名下载。

cd /usr/app/rocketmq/
wget -c https://codeload.github.com/apache/rocketmq-externals/zip/refs/heads/master -O rocketmq-externals.zip

下载不了也可以采取百度网盘下载，下载链接：https://pan.baidu.com/s/186RMHocNBkREszT7gpzlEg，提取码：nzwp。然后上传得到指定的目录下。

解压文件

## wget下载执行
unzip rocketmq-externals.zip

## 本地上传执行
unzip rocketmq-externals-master.zip

解压后的文件夹名称就是：rocketmq-externals-master。

• 2.修改配置文件

首先我们下载源码是所有的 rocketmq-externals包含的内容，实际上这里只用的里面的rocketmq-console。

cd /usr/app/rocketmq/rocketmq-externals-master/rocketmq-console/
vim src/main/resources/application.properties

## 修改端口（默认是8080）
server.port=9800
## 修改name server地址（多个地址用英文分号隔开）
rocketmq.config.namesrvAddr=localhost:9876
## 如果rocketmq版本 < 3.5.8，rocketmq.config.isvipchannel应该为false，默认为true
rocketmq.config.isVIPChannel=true

注意：配置文件中不能有中文，否则执行打包命令出错。

• 3.maven压缩编译

这里需要使用maven命令，因此需要先安装maven，安装指南见博文：添加链接描述https://blog.csdn.net/rao991207823/article/details/118914715

## maven命令打包
mvn clean package -Dmaven.test.skip=true

此时maven就会去中央镜像仓库下载jar，然后编辑打包项目，此步骤需要花些时间，当显示信息“BUILD SUCCESS”字样说明打包完成，此时可在 target 目录下看到以 rocketmq-console 开头jar文件。

• 4.启动jar包

cd /usr/app/rocketmq/
mkdir rocketmq-web
## 复制maven打好包到rocketmq-web目录
cp -a /usr/app/rocketmq/rocketmq-externals-master/rocketmq-console/target/rocketmq-console-ng-2.0.0.jar /usr/app/rocketmq/rocketmq-web/

## 前台启动jar（验证）
java -jar rocketmq-console-ng-2.0.0.jar
## 后台启动jar
nohup java -jar rocketmq-console-ng-2.0.0.jar > server.log 2>&1 &
## 查看后台启动
tail -f server.log

• 5.开放访问端口

# 添加开放端口
firewall-cmd --add-port=9800/tcp --permanent
# 重启防火墙
firewall-cmd --reload
# 查看开放端口列表
firewall-cmd --list-port

• 6.外部访问验证

访问地址为：ip+端口，如我这里是：192.168.235.102:9800，默认是英文菜单，可以调整为中文。页面如示：

• 7.默认日志（了解）

日志位置在 rocketmq-externals-master/rocketmq-console/src/main/resources 中指定了 logback.xml 为日志配置文件，此文件中有一个明确的配置 <file>${user.home}/logs/consolelogs/rocketmq-console.log</file> 告知了家目录下有日志文件。

实际路径，以 root 用户为例，cat ~/logs/consolelogs/rocketmq-console.log

注意：也可选择本地修改配置后编译打包上传