RocketMQ消息中间件的使用

不念不忘少年蓝@ 2024-04-01 12:59 55阅读 0赞

### RocketMQ消息中间件的使用 ###

#### 文章目录 ####

*   *  RocketMQ消息中间件的使用
     *   *  为什么选择 RocketMQ？
         *   *  1. 应用解耦
             *  2. 流量削峰
             *  3. 数据分发
             *  4. MQ的优点和缺点
             *  5. RocketMQ vs. ActiveMQ vs. Kafka之间有什么不同
         *  1、下载RocketMQ安装包
         *  2、使用Linux进行配置
         *   *  2.1 使用命令 mkdir 创建 /usr/local/recketMQ 目录
             *  2.2 使用Xftp打开Xshell当前登录用户进行文件操作
             *  2.3 使用 unzip rocketmq-all-4.9.3-source-release.zip 进行解压文件
             *  2.4 使用 cd 跳转到 /usr/local/recketMQ/rocketmq-4.9.3 目录
             *  2.5、修改初始内存
         *  3、启动RocketMQ服务
         *   *  3.1 启动NameServer
             *  3.2 启动broker
             *  3.3 发送/接收消息测试
             *  3.4 关闭Server
         *  4、控制台安装与启动
         *   *  4.1安装
             *   *  4.1.1 下载
                 *  4.1.2 修改配置
                 *  4.1.3 将 rocketmq-dashboard-master 上传到 /usr/local/recketMQ 目录中
                 *  4.1.4 使用 unzip 对 rocketmq-dashboard-master 进行解压
                 *  4.1.5 使用 cd 命令跳转到 /usr/local/recketMQ/rocketmq-dashboard-master 目录
             *  4.2 启动
             *   *  4.2.1 前端打包
                 *  4.2.2 后端打包
                 *  4.2.2 启动
                 *  4.2.3 访问
         *  5、RocketMQ使用
         *   *  5.1 打开素材中的项目
             *  5.2 打开 http://localhost:8380/doc.html 接口文档
             *   *  1. 普通消息
                 *  2. 延时消息
         *  6、自定义延时时间等级

#### 为什么选择 RocketMQ？ ####

根据我们的研究，随着使用中队列和虚拟主题的增加，ActiveMQ IO 模块达到了瓶颈。我们尽力通过节流、断路器或降级来解决这个问题，但效果不佳。所以我们开始关注当时流行的消息传递解决方案Kafka。不幸的是，Kafka 无法满足我们的要求，尤其是在低延迟和高可靠性方面，请参阅[此处][Link 1]了解详细信息。

在这种情况下，我们决定发明一个新的消息传递引擎来处理更广泛的用例集，从传统的发布/订阅场景到大容量实时零丢失容忍交易系统。我们相信这个解决方案可能是有益的，因此我们希望将其开源给社区。如今，已有 100 多家公司在其业务中使用开源版本的 RocketMQ。

消息队列是一种“先进先出”的数据结构

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-PU64BFpk-1667211673180)(D:/PRD/资料/文档/img/queue1.png)\]][img-PU64BFpk-1667211673180_D_PRD_img_queue1.png]

其应用场景主要包含以下3个方面

##### 1. 应用解耦 #####

系统的耦合性越高，容错性就越低。以电商应用为例，用户创建订单后，如果耦合调用库存系统、物流系统、支付系统，任何一个子系统出了故障或者因为升级等原因暂时不可用，都会造成下单操作异常，影响用户使用体验。

![请添加图片描述][7f1f51a61f5d40f09df9be47b5d3e64b.png]

使用消息队列解耦合，系统的耦合性就会提高了。比如物流系统发生故障，需要几分钟才能来修复，在这段时间内，物流系统要处理的数据被缓存到消息队列中，用户的下单操作正常完成。当物流系统回复后，补充处理存在消息队列中的订单消息即可，终端系统感知不到物流系统发生过几分钟故障。

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-S7a9idq0-1667211673183)(D:/PRD/资料/文档/img/解耦2.png)\]][img-S7a9idq0-1667211673183_D_PRD_img_2.png]

##### 2. 流量削峰 #####

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-x5OVh5X4-1667211673184)(D:/PRD/资料/文档/img/mq-5.png)\]][img-x5OVh5X4-1667211673184_D_PRD_img_mq-5.png]

应用系统如果遇到系统请求流量的瞬间猛增，有可能会将系统压垮。有了消息队列可以将大量请求缓存起来，分散到很长一段时间处理，这样可以大大提到系统的稳定性和用户体验。

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-iweWk9sm-1667211673185)(D:/PRD/资料/文档/img/mq-6.png)\]][img-iweWk9sm-1667211673185_D_PRD_img_mq-6.png]

一般情况，为了保证系统的稳定性，如果系统负载超过阈值，就会阻止用户请求，这会影响用户体验，而如果使用消息队列将请求缓存起来，等待系统处理完毕后通知用户下单完毕，这样总不能下单体验要好。

处于经济考量目的：

业务系统正常时段的QPS如果是1000，流量最高峰是10000，为了应对流量高峰配置高性能的服务器显然不划算，这时可以使用消息队列对峰值流量削峰

##### 3. 数据分发 #####

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-09q0TBBT-1667211673186)(D:/PRD/资料/文档/img/mq-1.png)\]][img-09q0TBBT-1667211673186_D_PRD_img_mq-1.png]

通过消息队列可以让数据在多个系统更加之间进行流通。数据的产生方不需要关心谁来使用数据，只需要将数据发送到消息队列，数据使用方直接在消息队列中直接获取数据即可

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-nN4Nn9br-1667211673187)(D:/PRD/资料/文档/img/mq-2.png)\]][img-nN4Nn9br-1667211673187_D_PRD_img_mq-2.png]

##### 4. MQ的优点和缺点 #####

优点：解耦、削峰、数据分发

缺点包含以下几点：

*  系统可用性降低
    
    系统引入的外部依赖越多，系统稳定性越差。一旦MQ宕机，就会对业务造成影响。
    
    如何保证MQ的高可用？
 *  系统复杂度提高
    
    MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调用。
    
    如何保证消息没有被重复消费？怎么处理消息丢失情况？那么保证消息传递的顺序性？
 *  一致性问题
    
    A系统处理完业务，通过MQ给B、C、D三个系统发消息数据，如果B系统、C系统处理成功，D系统处理失败。
    
    如何保证消息数据处理的一致性？

##### 5. RocketMQ vs. ActiveMQ vs. Kafka之间有什么不同 #####

<table> 
 <thead> 
  <tr> 
   <th align="center">消息产品</th> 
   <th align="left">客户端 SDK</th> 
   <th align="left">协议和规范</th> 
   <th align="left">订购信息</th> 
   <th align="left">预定消息</th> 
   <th align="left">批量消息</th> 
   <th align="left">广播消息</th> 
   <th align="left">消息过滤器</th> 
   <th align="left">服务器触发的重新交付</th> 
   <th align="left">消息存储</th> 
   <th align="left">消息追溯</th> 
   <th align="left">消息优先级</th> 
   <th align="left">高可用性和故障转移</th> 
   <th align="left">消息跟踪</th> 
   <th align="left">配置</th> 
   <th align="left">管理和运营工具</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">ActiveMQ</td> 
   <td align="left">Java、.NET、C++ 等。</td> 
   <td align="left">推送模型，支持 OpenWire、STOMP、AMQP、MQTT、JMS</td> 
   <td align="left">Exclusive Consumer 或 Exclusive Queues 可以保证排序</td> 
   <td align="left">支持的</td> 
   <td align="left">不支持</td> 
   <td align="left">支持的</td> 
   <td align="left">支持的</td> 
   <td align="left">不支持</td> 
   <td align="left">使用 JDBC 和高性能日志支持非常快速的持久化，例如 levelDB、kahaDB</td> 
   <td align="left">支持的</td> 
   <td align="left">支持的</td> 
   <td align="left">支持，取决于存储，如果使用 levelDB 则需要 ZooKeeper 服务器</td> 
   <td align="left">不支持</td> 
   <td align="left">默认配置为低级，用户需优化配置参数</td> 
   <td align="left">支持的</td> 
  </tr> 
  <tr> 
   <td align="center">kafka</td> 
   <td align="left">Java、Scala 等。</td> 
   <td align="left">拉取模型，支持TCP</td> 
   <td align="left">确保分区内消息的排序</td> 
   <td align="left">不支持</td> 
   <td align="left">支持，带有异步生产者</td> 
   <td align="left">不支持</td> 
   <td align="left">支持，可以使用Kafka Streams过滤消息</td> 
   <td align="left">不支持</td> 
   <td align="left">高性能文件存储</td> 
   <td align="left">支持的偏移量指示</td> 
   <td align="left">不支持</td> 
   <td align="left">支持，需要 ZooKeeper 服务器</td> 
   <td align="left">不支持</td> 
   <td align="left">Kafka 使用键值对格式进行配置。这些值可以从文件或以编程方式提供。</td> 
   <td align="left">支持，使用终端命令公开核心指标</td> 
  </tr> 
  <tr> 
   <td align="center">RocketMQ</td> 
   <td align="left">Java、C++、围棋</td> 
   <td align="left">拉取模型，支持 TCP、JMS、OpenMessaging</td> 
   <td align="left">确保消息的严格排序，并且可以优雅地横向扩展</td> 
   <td align="left">支持的</td> 
   <td align="left">支持，具有同步模式以避免消息丢失</td> 
   <td align="left">支持的</td> 
   <td align="left">支持的基于 SQL92 的属性过滤器表达式</td> 
   <td align="left">支持的</td> 
   <td align="left">高性能和低延迟的文件存储</td> 
   <td align="left">支持的时间戳和偏移量两种表示</td> 
   <td align="left">不支持</td> 
   <td align="left">支持的主从模型，无需其他套件</td> 
   <td align="left">支持的</td> 
   <td align="left">开箱即用，用户只需注意一些配置</td> 
   <td align="left">支持的、丰富的 Web 和终端命令以公开核心指标</td> 
  </tr> 
 </tbody> 
</table>

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

#### 1、下载RocketMQ安装包 ####

\*\*要求：\*\*准备工作

软硬件需求

*  Linux64位系统
 *  JDK1.8(64位)
 *  源码安装需要安装Maven 3.2.x
 *  \*\*注意：\*\*集成RocketMQ需要开放的端口: 9876,10912,10911,10909，没有开放这些端口将访问不了项目

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-5PU3mwwb-1667211673188)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221025085826308.png)\]][img-5PU3mwwb-1667211673188_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025085826308.png]

**我们这里下载4.9.3版本**

**素材：**[RockerMQ素材下载][RockerMQ]（已经配置好了，跟着下面操作就可以了）

为了方便大家快速的学习，这里准备了素材，也可以跟着文档去官网下载

#### 2、使用Linux进行配置 ####

##### 2.1 使用命令 mkdir 创建 /usr/local/recketMQ 目录 #####

使用命令 cd 跳转到 /usr/local/recketMQ 目录

![42a6b6b4ab3845b18f55a96dc0c82d4f.png][]

##### 2.2 使用Xftp打开Xshell当前登录用户进行文件操作 #####

跳转到 /usr/local/recketMQ 目录 进行文件传输

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-gSU0fKYL-1667211673189)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221029171601892.png)\]][img-gSU0fKYL-1667211673189_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221029171601892.png]

##### 2.3 使用 unzip rocketmq-all-4.9.3-source-release.zip 进行解压文件 #####

需要先下载unzip解压工具，命令： yum install unzip

![11b97bc634934c36bcc9e251420fee04.png][]

![5f7c7d7fccce4a309570907c63bde7b2.png][]

##### 2.4 使用 cd 跳转到 /usr/local/recketMQ/rocketmq-4.9.3 目录 #####

![e33cba7d62184d52a04e795bb7c2e65c.png][]

使用 ll 查看当前目录下文件详情

![dedb9fad2a46471296915295faabcaaa.png][]

##### 2.5、修改初始内存 #####

RocketMQ 默认的虚拟机[内存][Link 2]较大，启动 Broker 或者 NameServer 可能会因为内存不足而导致失败，所以需要编辑如下两个配置文件，修改 JVM 内存大小

**2.5.1、修改runserver.sh**

使用 vim 命令打开 bin/runserver.sh 文件。未修改前 71，76行，修改如下：

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-sMYpA42f-1667211673190)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20220825194822525.png)\]][img-sMYpA42f-1667211673190_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20220825194822525.png]

**2.5.2 修改runbroker.sh**

使用 vim 命令打开 bin/runbroker.sh 文件。未修改前 85行，修改如下：

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ZI8jSdDK-1667211673191)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221025154050923.png)\]][img-ZI8jSdDK-1667211673191_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025154050923.png]

#### 3、启动RocketMQ服务 ####

**nohup 意思是不挂断运行命令,当账户退出或终端关闭时,程序仍然运行。**

##### 3.1 启动NameServer #####

nohup sh bin/mqnamesrv & 
    
    tail -f ~/logs/rocketmqlogs/namesrv.log

![ee4f27ecd7db45aab8e4c35b27232505.png][]

启动nameserver成功

##### 3.2 启动broker #####

nohup sh bin/mqbroker -n 192.168.230.128:9876  &
    
    配置broker文件之后使用：nohup sh bin/mqbroker -n 192.168.230.128:9876 -c /usr/local/recketMQ/rocketmq-4.9.3/conf/broker.conf &
    
    tail -f ~/logs/rocketmqlogs/broker.log

启动broker失败，

![在这里插入图片描述][62675904fc774b1ca2820bc5d94a7c4d.png]

右击nohup.out文件使用EditPlus编辑器打开查看错误

![ab91c983be824ffd91fa17797312b225.png][]

如下所示是内存没有配置成功，导致内存不足了。需要重新配置

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-i1EkbsDz-1667211673192)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221025153302236.png)\]][img-i1EkbsDz-1667211673192_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025153302236.png]

重新配置一下就可以了

![f0646dee97e7403f866ac487616a033c.png][]

![253ced5727954bb397c27be262565184.png][]

启动broker成功

##### 3.3 发送/接收消息测试 #####

**发送消息**

export NAMESRV_ADDR=192.168.230.128:9876 
    
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

![3fc7d8acb0084a07901f12c68f56909d.png][]

**接收消息**

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

![2d5418afdcd546238cc012977b207066.png][]

##### 3.4 关闭Server #####

无论是关闭name server还是broker，都是使用 bin/mqshutdown 命令。

[root@mqOS rocketmq]# 关闭broker服务命令： sh bin/mqshutdown broker 
    
    The mqbroker(1740) is running..	. 
    
    Send shutdown request to mqbroker(1740) OK 
    
    [root@mqOS rocketmq]# 关闭nameserver服务命令: sh bin/mqshutdown namesrv 
    
    The mqnamesrv(1692) is running... 
    
    Send shutdown request to mqnamesrv(1692) OK 
    
    [2]+ 退出 143 nohup sh bin/mqbroker -n localhost:9876

![a11ab0db25cf43a99eb0433c96e6d81b.png][]

#### 4、控制台安装与启动 ####

RocketMQ有一个可视化的dashboard，通过该控制台可以直观的查看到很多数据。

\*\*如果不想去官网下载，那么可以直接使用素材提供的控制台（已经配置好了）\*\*跟着下面操作就可以了

##### 4.1安装 #####

###### 4.1.1 下载 ######

下载地址：https://github.com/apache/rocketmq-dashboard

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-SrccosQn-1667211673193)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221025160927143.png)\]][img-SrccosQn-1667211673193_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025160927143.png]

###### 4.1.2 修改配置 ######

修改其src/main/resources中的application.properties配置文件。

原来的端口号为8080，修改为一个不常用的

指定RocketMQ的name server地址

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-E0dMXTXl-1667211673194)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031150825807.png)\]][img-E0dMXTXl-1667211673194_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031150825807.png]

###### 4.1.3 将 rocketmq-dashboard-master 上传到 /usr/local/recketMQ 目录中 ######

使用 cd 命令跳转到 /usr/local/recketMQ 目录

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-7h60Wxgu-1667211673195)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221029173635009.png)\]][img-7h60Wxgu-1667211673195_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221029173635009.png]

###### 4.1.4 使用 unzip 对 rocketmq-dashboard-master 进行解压 ######

![ec847190885b43acb685837c4a0e627c.png][]

![38f75e95b47f4ad087b7c3ea79fbbe06.png][]

###### 4.1.5 使用 cd 命令跳转到 /usr/local/recketMQ/rocketmq-dashboard-master 目录 ######

![1e1640bc90b244caa2d2ff6a1bbf6b2a.png][]

##### 4.2 启动 #####

###### 4.2.1 前端打包 ######

注释打包插件 frontend-maven-plugin

###### 4.2.2 后端打包 ######

在rocketmq-dashboard-master目录下运行maven的打包命令。(注：要在虚拟机准备好maven仓库）

[Maven安装网址][Maven]

执行命令：

chmod a+x /usr/local/maven/apache-maven-3.6.0/bin/mvn
    mvn clean package -Dmaven.test.skip=true

![f9ec2fc140b34ebab20c78b4ad7026d4.png][]

\*\*报错：\*\*其他的大多数是版本问题，版本对应就可以了

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-BmcRJQDq-1667211673195)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20220810163446732.png)\]][img-BmcRJQDq-1667211673195_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20220810163446732.png]

\*\*解决：\*\*把 frontend-maven-plugin 插件注释就可以了

###### 4.2.2 启动 ######

使用 cd 命令跳转到 **/usr/local/recketMQ/rocketmq-dashboard-master/target** 目录

执行命令：

nohup java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar &

![1dd3248efe7c43d4bc43ac255c0f610c.png][]

###### 4.2.3 访问 ######

使用 http://IP地址:端口  
![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kpBnWehM-1667211673196)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031173214440.png)\]][img-kpBnWehM-1667211673196_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173214440.png]

**至此，我们的RocketMQ集成成功了**

#### 5、RocketMQ使用 ####

##### 5.1 打开素材中的项目 #####

![在这里插入图片描述][23fc6af6cbc34882880713f685a98cdd.png]

点击启动项目

##### 5.2 打开 http://localhost:8380/doc.html 接口文档 #####

###### 1. 普通消息 ######

1.  进行数据测试（普通消息）

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pKZvlUmB-1667211673197)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031173849911.png)\]][img-pKZvlUmB-1667211673197_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173849911.png]

1.  控制层代码

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xBNkp3iq-1667211673198)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031173817310.png)\]][img-xBNkp3iq-1667211673198_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173817310.png]

1.  测试结果

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ishLsjLp-1667211673199)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031174135268.png)\]][img-ishLsjLp-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174135268.png]

###### 2. 延时消息 ######

1.  进行数据测试（延时消息）

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-z1AC8IrX-1667211673199)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031174428528.png)\]][img-z1AC8IrX-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174428528.png]

1.  控制层代码

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xtTMWqd9-1667211673199)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031174517264.png)\]][img-xtTMWqd9-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174517264.png]

1.  测试结果

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-gsRihc5y-1667211673200)(C:\\Users\\Administrator\\AppData\\Roaming\\Typora\\typora-user-images\\image-20221031174504570.png)\]][img-gsRihc5y-1667211673200_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174504570.png]

#### 6、自定义延时时间等级 ####

在服务器端（rocketmq-broker端）的属性配置文件broker.conf中加入以下行：

messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h  
描述了各级别与延时时间的对应映射关系。

> 1.  这个配置项配置了从1级开始，各级延时的时间，可以修改这个指定级别的延时时间；
> 2.  时间单位支持：s、m、h、d，分别表示秒、分、时、天；
> 3.  默认值就是上面声明的，可手工调整；
> 4.  默认值已够用，不建议修改这个值。

至此，我们RockerMQ的学习也就完成了。

[Link 1]: https://rocketmq.apache.org/rocketmq/how-to-support-more-queues-in-rocketmq/
[img-PU64BFpk-1667211673180_D_PRD_img_queue1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/c8df7ba489ff4be89a689c1a2883f43a.png
[7f1f51a61f5d40f09df9be47b5d3e64b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d13352b282ad45a485c2beaaf4b2d563.png
[img-S7a9idq0-1667211673183_D_PRD_img_2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/2693e59e6a1c4617a6749200fa51e987.png
[img-x5OVh5X4-1667211673184_D_PRD_img_mq-5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/6c2ccb52e5c94104a9290fd21c567b1a.png
[img-iweWk9sm-1667211673185_D_PRD_img_mq-6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/3cdf9b51deac40ae8aa9b0f878eaac8e.png
[img-09q0TBBT-1667211673186_D_PRD_img_mq-1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/b42c5d09b14e4772a2e07c493e096e22.png
[img-nN4Nn9br-1667211673187_D_PRD_img_mq-2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/8674f48f88e24e34ab32e34a166e0474.png
[img-5PU3mwwb-1667211673188_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025085826308.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/8570d0453b824ad7ae9826d83d6dd593.png
[RockerMQ]: https://pan.baidu.com/s/1blVzSp5tocQQw7HK5zBVsQ?pwd=s8z1
[42a6b6b4ab3845b18f55a96dc0c82d4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/27a0c30b9421461d8e1671e93b313786.png
[img-gSU0fKYL-1667211673189_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221029171601892.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d5cdd56d8331447cbd1b2aaa585c3eaa.png
[11b97bc634934c36bcc9e251420fee04.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/e11c28fb65ce41268429f98ff25335ab.png
[5f7c7d7fccce4a309570907c63bde7b2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/e95d9276ecba4d82a7dcfae829a8fd82.png
[e33cba7d62184d52a04e795bb7c2e65c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/5e68d80d47f54d6f97556f12f089507a.png
[dedb9fad2a46471296915295faabcaaa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d988049af4764775bee9d488de50afb3.png
[Link 2]: https://so.csdn.net/so/search?q=%E5%86%85%E5%AD%98&spm=1001.2101.3001.7020
[img-sMYpA42f-1667211673190_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20220825194822525.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/35bbd6b245954f7a929f1d9e3c55a24a.png
[img-ZI8jSdDK-1667211673191_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025154050923.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/c1ceef56893f4a3081b5c095f6db5d92.png
[ee4f27ecd7db45aab8e4c35b27232505.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/61aaf27a92fa4f6c92894775343a2105.png
[62675904fc774b1ca2820bc5d94a7c4d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/06b2cebf02e24fb897a6755a12f728fd.png
[ab91c983be824ffd91fa17797312b225.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/6611a497f6dd43a0b8867566c1fca86b.png
[img-i1EkbsDz-1667211673192_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025153302236.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/b47c8d155ff4443bab6a1a20d66c3023.png
[f0646dee97e7403f866ac487616a033c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/dfbe31744ad74c269838041faa2981f2.png
[253ced5727954bb397c27be262565184.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/3fa35f9e76894fb2a9437e9167a7a38b.png
[3fc7d8acb0084a07901f12c68f56909d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/f64c13dc041a4ae5bc4a042fa106df05.png
[2d5418afdcd546238cc012977b207066.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/579425363d8d48038803f754404c74d8.png
[a11ab0db25cf43a99eb0433c96e6d81b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/15c81daddacf4726ba38fab194252a5b.png
[img-SrccosQn-1667211673193_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221025160927143.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/2c1786e0268c40f49a70dd860e0bcdb7.png
[img-E0dMXTXl-1667211673194_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031150825807.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/be6b5a9ed506407a811f0cf6ee0913c0.png
[img-7h60Wxgu-1667211673195_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221029173635009.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/72531dca3b764257ab2419d0894041ce.png
[ec847190885b43acb685837c4a0e627c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/a87b437c68684128a5d6078dc24e3b5c.png
[38f75e95b47f4ad087b7c3ea79fbbe06.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/f8624ce4f4b34028a1415121f5fb254f.png
[1e1640bc90b244caa2d2ff6a1bbf6b2a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/e4da0764a49742debdd8f421c708876a.png
[Maven]: https://blog.csdn.net/ITKidKid/article/details/126280591?spm=1001.2014.3001.5502
[f9ec2fc140b34ebab20c78b4ad7026d4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/44002dafe589460e9083aca16b4fa27c.png
[img-BmcRJQDq-1667211673195_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20220810163446732.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/fa83b6ee64f840dfb0f62972091369a0.png
[1dd3248efe7c43d4bc43ac255c0f610c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/6b2981ab9f7440529e891c0029b0fccd.png
[img-kpBnWehM-1667211673196_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173214440.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/8985c8596b464797885be6b586eefc7c.png
[23fc6af6cbc34882880713f685a98cdd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/a2605962c6e9473f88d098e427d3d1c1.png
[img-pKZvlUmB-1667211673197_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173849911.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/5ca1a6db74d842e8a037169e8061656c.png
[img-xBNkp3iq-1667211673198_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031173817310.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/ef814c3501fc4536a28b305933b2e085.png
[img-ishLsjLp-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174135268.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/90a6fd5b4d3447479d1e956f0fa634b2.png
[img-z1AC8IrX-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174428528.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/d3a1f6ed3978433f9ca36b90b510cebb.png
[img-xtTMWqd9-1667211673199_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174517264.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/5e31ce71fe304a9c99ea3b469215bc17.png
[img-gsRihc5y-1667211673200_C_Users_Administrator_AppData_Roaming_Typora_typora-user-images_image-20221031174504570.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/52cfede06a7c445ea3a2893a9982fe9c.png