rocketmq的重试队列和死信队列

末蓝、 2023-02-26 07:23 16阅读 0赞

消费端，一直不回传 消费的结果。rocketmq认为消息没收到，consumer下一次拉取，broker依然会发送该消息。

所以，任何异常都要捕获返回ConsumeConcurrentlyStatus.RECONSUME\_LATER

rocketmq会放到重试队列。

这个重试TOPIC的名字是

%RETRY%+consumergroup的名字

在控制台上过一会就可以查到。

重试的消息在延迟的某个时间点（默认是10秒，业务可设置）后，再次投递到这个ConsumerGroup。而如果一直这样重复消费都持续失败到一定次数（默认16次），就会投递到DLQ死信队列，此时需要人工干预了。

/\*\*

*  Batch consumption size

\*/

private int consumeMessageBatchMaxSize = 1;

/\*\*

*  Batch pull size

\*/

private int pullBatchSize = 32;

consumeMessageBatchMaxSize 是批量消费的最大条数

pullBatchSize 是每次拉取的最大条数

在broker端的

private String messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";

参数是设置重试的时间，即第一次1s之后，第二次5s之后

为了测试，改成5s，生产环境不要改

messageDelayLevel = 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s 5s

16次之后，多了一个topic

名为

%DLQ%+consumergroup

![format_png][]

死信队列.png

这个默认的16次，可以改。但是使用DefaultMQPullConsumer才可以修改。

DefaultMQPushConsumer不能修改此值。

顺便再说下，consumeMessageBatchMaxSize 这个size是消费者注册的回调listener一次处理的消息数，默认是1.不是每次拉取的消息数（默认是32），这个不要搞混。

[format_png]: /images/20230209/f35059e9d3074180b1e0ffeb2fe660b6.png

发表评论取消回复

表情：

评论列表（有 0 条评论，16人围观）

还没有评论，来说两句吧...

相关阅读

相关死信队列和延迟队列

死信队列 DLX 全称死信交换机,当一个消息在一个队列中变成死信,它会被重新发送到另一个交换机中,这个交换机就是DLX,绑定DLX的队列被称为死信队列. 消息编程死信

落日映苍穹つ/ 2023年10月02日 09:09/ 0 赞/ 42 阅读

相关死信队列+TTL实现延迟重试

思路 MQ配置： > 1.设置正常处理队列及绑定关系，exchange，queue，key > > 2.创建5s延迟队列queue\_5s，10s延迟队列queu

ゝ一世哀愁。/ 2023年06月26日 05:40/ 0 赞/ 44 阅读

相关 rocketmq的重试队列和死信队列

消费端，一直不回传消费的结果。rocketmq认为消息没收到，consumer下一次拉取，broker依然会发送该消息。所以，任何异常都要捕获返回ConsumeConcu

末蓝、/ 2023年02月26日 07:23/ 0 赞/ 17 阅读

相关 RabbitMQ 死信队列和延迟队列

文章目录死信队列延迟队列死信队列死信队列，英文缩写：DLX （Dead Letter Exchange（死信交换机）），当

àì夳堔傛蜴生んèń/ 2022年11月16日 13:43/ 0 赞/ 281 阅读

相关 Apache Kafka-消费端消费重试和死信队列

文章目录概述 Code POM依赖配置文件配置类 SeekToCurrentErrorHandle

小灰灰/ 2022年10月30日 07:29/ 0 赞/ 560 阅读

相关 RabbitMQ--SpringBoot--消息确认/备份交换机/死信队列/延迟队列/重试

原文网址：[RabbitMQ--SpringBoot--消息确认/备份交换机/死信队列/延迟队列/重试\_IT利刃出鞘的博客-CSDN博客][RabbitMQ--SpringB

分手后的思念是犯贱/ 2022年09月12日 03:50/ 0 赞/ 247 阅读

相关 RocketMQ 死信队列

RocketMQ 死信队列死信队列死信队列是什么？死信队列指的是种正常情况下无法被消费的消息称为死信消息（Dead-Letter Message），存储死信

逃离我推掉我的手/ 2022年09月04日 14:45/ 0 赞/ 307 阅读

相关 RabbitMQ死信队列和延迟队列（六）

死信队列 DLX全称dead-letter-exchange，可以称之为死信交换器。当消息在一个队列中变成死信之后，它能被重新发送到另一个交换器中，这个交

喜欢ヅ旅行/ 2022年09月02日 01:14/ 0 赞/ 259 阅读

相关 AWS Lambda 重试与死信队列(DLQ)

AWS Lambda 允许设置 `Debugging and error handling`, 在 Lambda 出现异常，达到最大的重试次数后，把以下信息放到选择的 SNS

傷城~/ 2022年05月09日 04:58/ 0 赞/ 239 阅读

相关 RocketMQ——查看死信队列

在上篇博客中我们了解了RocketMQ的ACK机制，其中涉及到了消息消费重试，当重试次数达到默认的16次后（可以通过配置文件修改）如果对应的消息还没被成功消费的话，该消息就会投

超、凢脫俗/ 2021年09月27日 00:14/ 0 赞/ 831 阅读