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

        本文为个人云服务器上搭建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
//上面的命令为后台启动

启动后的界面：

当显示以上界面时说明启动成功，输入http://主机ip:8080后若能成功访问说明部署成功。

        如果MQ启动成功了，但是无法打开网页，有可能是服务器对应的安全组没有设置，记得把10909、10911、9876打开。

        以上就是MQ的所有部署安装教程啦，祝大家都能找到满意的offer~