栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Rocket中的死信队列

Rocket中的死信队列

1 .什么是死信队列

当一条消息初次消费失败,消息队列会自动进行消费重试;达到最大重试次数后,若消费依然失败,则 表明消费者在正常情况下无法正确地消费该消息,此时,消息队列不会立刻将消息丢弃,而是将其发送 到该消费者对应的特殊队列中。这个队列就是死信队列(Dead-Letter Queue , DLQ ),而其中的消息 则称为死信消息(Dead-Letter Message , DLM )。 2 . 死信队列的特征 死信队列具有如下特征: 死信队列中的消息不会再被消费者正常消费,即 DLQ 对于消费者是不可见的 死信存储有效期与正常消息相同,均为 3 天( commitlog 文件的过期时间), 3 天后会被自动删除 死信队列就是一个特殊的Topic ,名称为 %DLQ%consumerGroup@consumerGroup ,即每个消 费者组都有一个死信队列 如果⼀个消费者组未产生死信消息,则不会为其创建相应的死信队列 3.  死信消息的处理 实际上,当⼀条消息进入死信队列,就意味着系统中某些地方出现了问题,从而导致消费者无法正常消 费该消息,比如代码中原本就存在Bug 。因此,对于死信消息,通常需要开发人员进行特殊处理。最关 键的步骤是要排查可疑因素,解决代码中可能存在的Bug ,然后再将原来的死信消息再次进行投递消 费。
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/689890.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号