Rocket中的死信队列_rocketmq的死信队列消息如何处理

作者：从前慢现在也慢 | 2024-08-19 16:28:00

踩

rocketmq的死信队列消息如何处理

1 .什么是死信队列

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

2 . 死信队列的特征

死信队列具有如下特征：

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

3. 死信消息的处理

实际上，当⼀条消息进入死信队列，就意味着系统中某些地方出现了问题，从而导致消费者无法正常消费该消息，比如代码中原本就存在Bug 。因此，对于死信消息，通常需要开发人员进行特殊处理。最关键的步骤是要排查可疑因素，解决代码中可能存在的Bug ，然后再将原来的死信消息再次进行投递消费。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/1003043