本文共 998 字，大约阅读时间需要 3 分钟。

前言

RocketMQ是Alibaba研发的，自然《RocketMQ用户指南》也是阿里的了，虽然我拿到的那份儿PDF就50页，还是能学到不少东西的。

学习

1、Message Priority

规范中描述的优先级是指在一个消息队列中，每条消息都有不同的优先级，一般用整数来描述，优先级高的消息先投递，如果消息完全在一个内存队列中，那么在投递前可以按照优先级排序，令优先级高的先投递。

由于 RocketMQ 所有消息都是持久化的，所以如果按照优先级来排序，开销会非常大，因此 RocketMQ 没有特意支持消息优先级，但是可以通过变通的方式实现类似功能，即单独配置一个优先级高的队列，和一个普通优先级的队列， 将不同优先级发送到不同队列即可。

优先级事先分流的方式，好！

2、Message Persistence

消息中间件通常采用的几种持久化方式：

(1). 持久化到数据库，例如 Mysql。 (2). 持久化到 KV 存储，例如 levelDB、伯克利 DB 等 KV 存储系统。 (3). 文件记彔形式持久化，例如 Kafka，RocketMQ (4). 对内存数据做一个持久化镜像，例如 beanstalkd，VisiNotify (1)、(2)、(3)三种持久化方式都具有将内存队列 Buffer 进行扩展的能力，(4)只是一个内存的镜像，作用是当 Broker 挂掉重启后仍然能将之前内存的数据恢复出来。

数据持久化，好！在一定限度内保证数据的稳定安全性。

3、消息堆积

消息中间件的主要功能是异步解耦，迓有个重要功能是挡住前端的数据洪峰，保证后端系统的稳定性，返就要

求消息中间件具有一定的消息堆积能力。

需要学习磁盘调度了！

4、消息重试

Consumer 消费消息失败后，要提供一种重试机制，令消息再消费一次。

1、由于消息本身的原因，返种错误通常需要跳过这条消息，再消费其他消息，而返条失败的消息即使立刻重试消费，99%也不会成功， 所以最好提供一种定时重试机制，即过 10s 秒后再重试。

2、由亍依赖的下游应用服务不可用，例如 db 连接不可用，外系统网络不可达等。

遇到返种错误，即使跳过当前失败的消息，消费其他消息同样也会报错。返种情况建议应 sleep 30s，再 消费下一条消息，这样可以减轻 Broker 重试消息的压力。

好！这点真是醍醐灌顶啊！

转载地址：https://lion-wu.blog.csdn.net/article/details/107564846 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！