标签：指南 优先级 队列 重试 消息 服务器 持久 RocketMQ
文章目录
前言
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 重试消息的压力。
好！这点真是醍醐灌顶啊！
标签：指南,优先级,队列,重试,消息,服务器,持久,RocketMQ 来源： https://blog.51cto.com/u_15197573/2772412
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。