🍟9. 整合Rocketmq实现审批流消息推送

• 将项目和任务审批流消息放入 Rocketmq，实现消息的异步解耦，提升系统效率和服务稳定性。

整个消息队列组件其实就三部分：

• 生产者：生产消息的一方，例子中的顾客就是生产者
• 消息队列：就是消息的「篮子」，用来存放消息
• 消费者：专门负责消息的一方，比如例子中的厨师

消息队列核心的三大使用场景是必须要知道的：解耦、异步、削峰

• 官网地址：https://rocketmq.apache.org/

• 开源地址：https://github.com/apache/rocketmq

• 每个 Broker 与NameServer集群中的所有节点建立长连接, 定时注册 Topic 信息到NameServer

• Producer 与 NameServer 集群中的一个节点建立长连接，定期从 NameServer 获取 Topic 路由信息，向提供 Topic 服务的 Master 建立长连接，且定时向 Master 发送心跳。Producer 完全无状态

• Consumer 与 NameServer 集群中的其中一个节点建立长连接，定期从 NameServer 获取 Topic 路由信息，并向提供 Topic 服务的 Master、Slave 建立长连接，且定时向 Master、Slave发送心跳。Consumer 既可以从 Master 订阅消息，也可以从Slave订阅消息

1. Docker 部署 RocketMQ

1.1. 拉取 RocketMQ 镜像

docker pull apache/rocketmq:5.1.0

1.2. 创建容器共享网络

docker network create rocketmq

为什么要创建 docker 共享网络？

• 容器间通信：创建一个 Docker 网络可以确保同一个网络中的容器可以通过容器名称进行通信，而不需要知道对方的 IP 地址。这对于需要相互通信的服务非常重要，比如 RocketMQ 的多个组件（如 NameServer 和 Broker）。
• 隔离性和安全性：Docker 网络提供了一个隔离的网络环境，不同网络中的容器彼此隔离。这增加了安全性，防止外部或其他不相关的容器访问敏感服务。
• 简化配置：使用 Docker 网络，配置变得更加简单。容器可以通过名称互相访问，无需担心容器重启后 IP 地址发生变化。

2. 部署NameServer

2.1. 创建目录并授予权限

mkdir -p /data/rocketmq/nameserver/{bin,logs}
chmod 777 -R /data/rocketmq/nameserver/*

2.2. 拷贝启动脚本

# 启动容器NameServer
docker run -d \
--privileged=true --name rmqnamesrv \
apache/rocketmq:5.1.0 sh mqnamesrv

# 拷贝启动脚本
docker cp rmqnamesrv:/home/rocketmq/rocketmq-5.1.0/bin/runserver.sh /data/rocketmq/nameserver/bin/

2.3. 启动容器NameServer

# 删除容器 NameServer
docker rm -f rmqnamesrv

# 启动容器 NameServer
docker run -d --network rocketmq \
--privileged=true --restart=always \
--name rmqnamesrv -p 9876:9876 \
-v /data/rocketmq/nameserver/logs:/home/rocketmq/logs \
-v /data/rocketmq/nameserver/bin/runserver.sh:/home/rocketmq/rocketmq-5.1.0/bin/runserver.sh \
apache/rocketmq:5.1.0 sh mqnamesrv

# 部分命令解释 : 
1. -e "MAX_HEAP_SIZE=256M" 设置最大堆内存和堆内存初始大小
2. -e "HEAP_NEWSIZE=128M"  设置新生代内存大小

# 查看启动日志
docker logs -f rmqnamesrv

• 看到 'The Name Server boot success..'， 表示NameServer 已成功启动。

3. 部署Broker + Proxy

3.1. 创建挂载文件夹并授权

mkdir -p /data/rocketmq/broker/{store,logs,conf,bin}
chmod 777 -R /data/rocketmq/broker/*

3.2. 创建broker.cnf文件

vi /data/rocketmq/broker/conf/broker.conf

# nameServer 地址多个用;隔开 默认值null
# 例：127.0.0.1:6666;127.0.0.1:8888 
namesrvAddr = 192.168.100.100:9876
# 集群名称
brokerClusterName = DefaultCluster
# 节点名称
brokerName = broker-a
# broker id节点ID， 0 表示 master, 其他的正整数表示 slave，不能小于0 
brokerId = 0
# Broker服务地址    String  内部使用填内网ip，如果是需要给外部使用填公网ip
brokerIP1 = 192.168.100.100
# Broker角色
brokerRole = ASYNC_MASTER
# 刷盘方式
flushDiskType = ASYNC_FLUSH
# 在每天的什么时间删除已经超过文件保留时间的 commit log，默认值04
deleteWhen = 04
# 以小时计算的文件保留时间 默认值72小时
fileReservedTime = 72
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许Broker自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
# 禁用 tsl
tlsTestModeEnable = false

# 下面是没有注释的版本
namesrvAddr = 192.168.100.100:9876
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
brokerIP1 = 192.168.100.100
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
deleteWhen = 04
fileReservedTime = 72
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
tlsTestModeEnable = false

3.3. 拷贝启动脚本

# 启动 Broker 容器
docker run -d \
--name rmqbroker --privileged=true \
apache/rocketmq:5.1.0 sh mqbroker

# 拷贝脚本文件
docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.0/bin/runbroker.sh /data/rocketmq/broker/bin

3.4. 启动容器Broker

# 删除容器 Broker
docker rm -f rmqbroker

# 启动容器 Broker
docker run -d --network rocketmq \
--restart=always --name rmqbroker --privileged=true \
-p 10911:10911 -p 10909:10909 \
-v /data/rocketmq/broker/logs:/root/logs \
-v /data/rocketmq/broker/store:/root/store \
-v /data/rocketmq/broker/conf/broker.conf:/home/rocketmq/broker.conf \
-v /data/rocketmq/broker/bin/runbroker.sh:/home/rocketmq/rocketmq-5.1.0/bin/runbroker.sh \
-e "NAMESRV_ADDR=rmqnamesrv:9876" \
apache/rocketmq:5.1.0 sh mqbroker --enable-proxy -c /home/rocketmq/broker.conf

# 查看启动日志
docker logs -f rmqbroker

4. 部署RocketMQ控制台（rocketmq-dashboard）

4.1. 拉取镜像

docker pull apacherocketmq/rocketmq-dashboard:latest

4.2. 启动容器Rocketmq-dashboard

docker run -d \
--restart=always --name rmq-dashboard \
-p 8080:8080 --network rocketmq \
-e "JAVA_OPTS=-Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=fals...