企业官网建设流程全解析

一、MQ基本概念

1.1 MQ是什么

我们可以拆开来看，M对应Message消息，Q对应Queue队列，消息就是数据比如信息，邮件；队列就是存放这些数据的容器，所以我们就可以将mq理解为是消息队列，存放消息的容器

1.2 MQ的作用

1.2.1 异步调用

异步调用就是在调用一个接口时，在接口执行业务的同时，我们可以进行下面业务的执行，不用等待该接口执行完在接着执行

mq作为中间件，接口就会将调用的指令放入mq中，然后继续执行。

1.2.2 削峰填谷

MQ 像蓄水池：瞬时洪峰请求先存入 MQ 持久化排队；下游消费者按自己最大能力匀速拉取消息消费，把尖峰流量摊平，保护数据库 / 下游服务不被瞬间打垮。

• 上游：秒杀大量请求写入 MQ，主流程快速返回「排队中」，不阻塞
• 下游：消费者匀速消费，高峰过后，低峰期继续消化队列堆积消息 →填谷

本质：用时间换稳定性，不会提升系统总处理上限，只是把瞬时压力延后

1.2.3 解耦合

降低了两个接口之间的耦合性，做到了低耦合，因为之间有一个mq，没有直接连接了

二、RocketMQ

2.1 基本概念

2.1.2 什么是RocketMQ

是阿里开源的项目，后捐献给apache，成为顶级项目

2.1.3 RocketMQ的基本概念

producer:消息的生产者，发送者

consumer:消息的接收者

Topic:主题，对消息进行分类的依据

Queue:队列，存放消息

Broker:暂存和传输消息的通道

NameServer:路由中心，管理Broker，可以参考Nacos

producerGroup:生产者组

consumerGroup:消费者组

[!TIP]
一个Broker中可以有多个Queue,然后里面存放按照Topic分类的信息

2.1.4NameServer

类似Nacos，Broker的消息被注册到这里，生产者，消费者会从这里被路由到具体的Broker中

1.写的负载均衡

生产者存入某个Topic的消息，会经过NameServer路由到Broker，当有多个时，就会采取轮询的方式按照顺序进行，这样就到达了均衡的效果

2.读的负载均衡

消费者在获取某个Topic的消息时，会从NameServer中根据这个Topic去查询在哪个Broker中然后去读取其中的消息，这个时候我们可以设置同一个topic的主从Broker这样就会做到读的负载均衡

三、安装

3.1 docker安装

3.1.1 docker镜像安装

# 拉取指定版本dockerpull apache/rocketmq:5.2.0# 拉取最新版dockerpull apache/rocketmq:latest

拉取面板：

dockerpull apacherocketmq/rocketmq-dashboard:latest

拉取完成后，输入docker images查看如图：

3.2 配置broker的文件

在这里broker，nameserver公用一个镜像。我们在当前目录创建一个文件broker.conf通过指令nano broker.conf创建文件

配置内容如下：

# 集群名称，同一个集群下所有broker必须clusterName相同brokerClusterName=DefaultCluster# broker节点名称，主从节点名字一样（比如broker-a主、broker-a从）brokerName=broker-a# brokerId：0代表master主节点；大于0代表slave从节点brokerId=0# 什么时候删除过期消息，04=凌晨4点执行清理deleteWhen=04# 文件保留时长，单位小时，超过该时间的消息文件会被清理fileReservedTime=48# ASYNC_MASTER：异步刷盘的主节点；SYNC_MASTER同步主节点；SLAVE从节点brokerRole=ASYNC_MASTER# ASYNC_FLUSH：异步刷盘，性能高；SYNC_FLUSH同步刷盘，可靠性高，性能差flushDiskType=ASYNC_FLUSH# 【重点】broker对外暴露的IP，客户端连接用，**只写IP，不带端口**brokerIP1=172.17.96.158# 自动创建topic，开发环境打开；生产环境关闭，禁止自动建主题autoCreateTopicEnable=true# broker监听端口，默认10911，客户端收发消息端口listenPort=10911

[!NOTE]
这里我们直接在容器内部就编辑了配置文件不用再本地创建了

（拓展）Linux中创建文件方式

• nano broker.conf 编辑文件，没有直接创建然后进行编辑，操作简单
• touch broker.conf 只创建一个文件，不会编辑
• cat > broker.conf <<EOF 这里粘贴你的配置文本 EOF，创建后直接将你输入的内容写入文件
• vim broker.conf 跟nano一样，但是不是自带的，需要下载，而且操作不如nano简单

3.3 创建容器内部网络

创建一个公用的独立的内部网络才能更方便的访问

dockernetwork create rocketmq

3.4 创建容器

先清空之前创建的容器：

dockerrm-frmqnamesrv rmqbroker rmqproxy rmq-dashboard

创建nameserver

dockerrun-d\--namermqnamesrv\--networkrocketmq\-p9876:9876\apache/rocketmq:5.2.0\shmqnamesrv

创建broker

dockerrun-d\--namermqbroker\--networkrocketmq\-p10911:10911-p10912:10912\-eNAMESRV_ADDR=rmqnamesrv:9876\-eBROKER_IP1=172.17.96.158\apache/rocketmq:5.2.0\sh-c'echo "brokerIP1=172.17.96.158" >> /home/rocketmq/rocketmq-5.2.0/conf/broker.conf && sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf'

[!TIP]
5.0版本之后会有一个proxy模式，这里我们分开进行创建，也可以一起创建

创建proxy

dockerrun-d\--namermqproxy\--networkrocketmq\-p10909:10909-p8080:8080-p8081:8081\-eNAMESRV_ADDR=rmqnamesrv:9876\apache/rocketmq:5.2.0\sh-c' cat > /home/rocketmq/rocketmq-5.2.0/conf/rmq-proxy.json << EOF { "rocketMQClusterName": "DefaultCluster", "nameSrvAddr": "rmqnamesrv:9876", "proxyMode": "local" } EOF sh mqproxy '

[!NOTE]
5.2.0有一个bug就：Proxy 启动时要自动创建系统内部广播 TopicDefaultHeartBeatSyncerTopic，但是创建失败，Proxy 直接退出RocketMQ，本质是 proxyMode 默认 cluster 模式的兼容性问题，改成local本地模式就能绕过去。
创建dashboard

dockerrun-d\--namermq-dashboard\--networkrocketmq\-p8088:8080\-eNAMESRV_ADDR=rmqnamesrv:9876\apacherocketmq/rocketmq-dashboard:2.0.0

[!TIP]
这里每个docker指令最后一行的意思是执行容器的启动脚本，对于broker跟nameserver由于是一个镜像所以需要利用sh指定内部的具体执行脚本

我们可以查看日志，看是否启动成功

# namesrv日志dockerlogs-frmqnamesrv# broker日志（重点！启动失败优先看这个）dockerlogs-frmqbroker# dashboard控制台日志dockerlogs-frmq-dashboard

如果觉得日志太多也可以加上限制：

# 查看broker最后200行日志dockerlogs--tail200rmqbroker# 看最近10分钟日志dockerlogs--since10m rmqbroker

通过docker ps我们就能看到当前正在运行的容器：

3.5 访问dashboard

dashboard默认是8080端口，但是在项目中8080会被别的占用，所以我们可以在启动时修改它的端口号为8088

成功后:

该文章首次发布在我的个人网站(http://bittermelon.click/posts/mq/rocketmq/),欢迎光临我的小站