当前位置:   article > 正文

RocketMQ-什么是死信队列?怎么解决_rocketmq 死信队列 超过1000怎么处理

rocketmq 死信队列 超过1000怎么处理

目录

什么是死信队列

死信队列的特征

死信消息的处理


什么是死信队列

        当一条消息初次消费失败,消息队列会自动进行消费重试;达到最大重试次数后,若消费依然失败,则表明消费者在正常情况下无法正确地消费该消息,此时,消息队列不会立刻将消息丢弃,而是将其发送到该消费者对应的特殊队列中。这个队列就是死信队列(Dead-Letter Queue DLQ ),而其中的消息则称为死信消息(Dead-Letter Message DLM )。
死信队列是用于处理无法被正常消费的消息的。

死信队列的特征

死信队列具有如下特征:
        死信队列中的消息不会再被消费者正常消费,即DLQ 对于消费者是不可见的
        死信存储有效期与正常消息相同,均为 3 天(commitlog文件的过期时间), 3 天后会被自动删除
        死信队列就是一个特殊的Topic ,名称为 %DLQ%consumerGroup@consumerGroup ,即每个消费者组都有一个死信队列
        如果⼀个消费者组未产生死信消息,则不会为其创建相应的死信队列

死信消息的处理

        实际上,当⼀条消息进入死信队列,就意味着系统中某些地方出现了问题,从而导致消费者无法正常消费该消息,比如代码中原本就存在Bug 。因此,对于死信消息,通常需要开发人员进行特殊处理。最关键的步骤是要排查可疑因素,解决代码中可能存在的Bug ,然后再将原来的死信消息再次进行投递消费。
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/花生_TL007/article/detail/569725
推荐阅读
  

闽ICP备14008679号