Linux阿里云服务器安装RocketMQ教程

news2025/4/5 20:38:35

本文为个人云服务器上搭建RocketMQ教程，用于帮助大家降低安装学习成本，提高学习效率。本人在服务器上（我用的是阿里云服务器）安装MQ时遇到了大大小小的问题，因此在最终完成部署后，希望能总结一个教程，帮助大家一键高效完成部署。

在实际部署前，先带大家回顾一下RocketMQ的核心概念及工作流程。

RocketMQ核心概念：

NameServer：可以理解为是一个注册中心，主要是用来保存topic路由信息，管理Broker。在NameServer的集群中，NameServer与NameServer之间是没有任何通信的。
Broker：核心的一个角色，主要是用来保存topic的信息，接受生产者产生的消息，持久化消息。在一个Broker集群中，相同的BrokerName可以称为一个Broker组，一个Broker组中,BrokerId为0的为主节点，其它的为从节点。BrokerName和BrokerId是可以在Broker启动时通过配置文件配置的。每个Broker组只存放一部分消息。
生产者：生产消息的一方就是生产者
生产者组：一个生产者组可以有很多生产者，只需要在创建生产者的时候指定生产者组，那么这个生产者就在那个生产者组
消费者：用来消费生产者消息的一方
消费者组：跟生产者一样，每个消费者都有所在的消费者组，一个消费者组可以有很多的消费者，不同的消费者组消费消息是互不影响的。
topic（主题） ：可以理解为一个消息的集合的名字，生产者在发送消息的时候需要指定发到哪个topic下，消费者消费消息的时候也需要知道自己消费的是哪些topic底下的消息。
Tag（子主题） ：比topic低一级，可以用来区分同一topic下的不同业务类型的消息，发送消息的时候也需要指定。

工作流程

上面这张图很好的表示了RocketMQ的工作流程：

Broker启动的时候，会往每台NameServer（因为NameServer之间不通信，所以每台都得注册）注册自己的信息，这些信息包括自己的ip和端口号，自己这台Broker有哪些topic等信息。
Producer在启动之后会跟会NameServer建立连接，定期从NameServer中获取Broker的信息，当发送消息的时候，会根据消息需要发送到哪个topic去找对应的Broker地址，如果有的话，就向这台Broker发送请求；没有找到的话，就看根据是否允许自动创建topic来决定是否发送消息。
Broker在接收到Producer的消息之后，会将消息存起来，持久化，如果有从节点的话，也会主动同步给从节点，实现数据的备份
Consumer启动之后也会跟会NameServer建立连接，定期从NameServer中获取Broker和对应topic的信息，然后根据自己需要订阅的topic信息找到对应的Broker的地址，然后跟Broker建立连接，获取消息，进行消费。

根据以上工作流程可知，NamerServer会定期获取Broker的信息，并且Producer和Consumer在启动后都会和NameServer建立连接，因此在部署启动RocketMQ时需要先启动Name人Server，后启动Broker才可以。

环境搭建

在简单介绍了RocketMQ的核心概念和工作流后，进入实际的部署环境。

本文主要介绍使用Docker Compose进行安装，使用原始的拉取MQ包并进行解压缩运行的方法较为复杂，且原始的MQ配置中JVM的内存空间大小是8g，也需要修改对应的配置，因此不推荐该方法。而使用docker方式也可以，但需要分别拉取NameServer、Broker和DashBoa的镜像再运行，有点麻烦，不如Docker Compose通过编写Docker Compose.yaml配置文件进行运行来的方便快捷。

1. 准备

在实际安装MQ之前，需要有一些前提准备工作（基础环境搭建）：

关闭防火墙

systemctl stop firewalld
systemctl disable firewalld

安装好JDK，因为RockerMQ是使用Java编写的，且后续的RocketMQ的Web可视化管理页面DashBoard也是使用Spring写的，因此需要有Java运行环境。

//查看JDK版本（最好在1.8以上，因为1.8稳定）
java -version

安装好了Docker及Docker-Compose

Docker和Docker-Compose的作用：

Docker：Docker 是一个容器化平台，专注于管理单个容器。每次您启动一个 Docker 容器时，都需要使用 docker run 命令手动指定所有容器的配置。
Docker Compose：Docker Compose 用于定义和运行多容器应用。它使得管理多个容器变得简单，通过编写 docker-compose.yml 文件来配置所有容器，然后用 docker-compose 命令来管理这些容器。

//查询docker版本
docker -v
//查询docker-compose版本
docker-compose -v

创建好对应的文件：分别创建rocketmq文件夹，conf文件夹和broker.conf及docker-compose.yml配置文件。

2. 修改具体配置文件

修改broker.conf配置文件

//进入对应的conf文件夹下
cd /usr/local/rocketmq/conf
//修改配置文件
vim broker.conf

broker配置文件如下：

brokerClusterName = DefaultCluster

brokerName = broker-a

brokerId = 0

deleteWhen = 04

fileReservedTime = 48

brokerRole = ASYNC_MASTER

flushDiskType = ASYNC_FLUSH

# 如果是本地程序调用云主机 mq，这个需要设置成云主机 IP

# 如果Docker环境需要设置成宿主机IP

brokerIP1 = {docker宿主机IP地址}

修改docker-compose.yaml配置文件

//进入对应的conf文件夹下
cd /usr/local/rocketmq/conf
//修改配置文件
vim docker-compose.yaml

docker-compose.yaml配置文件如下：

version: '3.5'
services:
namesrv:
image: apache/rocketmq:5.2.0
container_name: rmqnamesrv
ports:
- "9876:9876"
command: sh mqnamesrv
environment:
- JAVA_OPT_EXT=-Xms128m -Xmx128m -Xmn128m
networks:
rmq:
aliases:
- rmqnamesrv

broker:
image: apache/rocketmq:5.2.0
container_name: rmqbroker
ports:
- "10909:10909"
- "10911:10911"
depends_on:
- namesrv
volumes:
- ./conf/broker.conf:/opt.rocketmq-5.2.0/conf/broker.conf
command: sh mqbroker -c /opt.rocketmq-5.2.0/conf/broker.conf
environment:
NAMESRV_ADDR: "rmqnamesrv:9876"
JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
networks:
rmq:
aliases:
- rmqbroker

mqconsole:
image: apacherocketmq/rocketmq-dashboard
container_name: rmqconsole
ports:
- 8080:8080
depends_on:
- namesrv
environment:
JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
networks:
rmq:
aliases:
- rmqconsole

networks:
rmq:
name: rmq
driver: bridge

这里简单说明一下这个配置文件的内容及作用：里面分别介绍了namesrv、broker和mqconsole镜像的名称、容器名称、环境、端口及网络配置等，根据该配置文件，可拉取对应的镜像并构建容器，command: sh mqbroker -c /opt.rocketmq-5.2.0/conf/broker.conf命令的作用是根据刚修改的broker.conf来运行。

3. 运行docker-compose.yaml

在完成以上内容后，就可以运行docker-compose.yaml，它会拉取对应的镜像并构建容器运行。如果拉取失败也可以自己把上面所需的三个镜像拉取下来，再运行该文件。

//进入含有docker-compose.yaml的文件夹下
cd /usr/local/rocketmq/conf
//启动docker-compose
docker-compose up
//上面的命令为前台启动，可以直接看到启动过程和可能出现的错误
docker-compose up -d
//上面的命令为后台启动

启动后的界面：