死信消息
更新时间 2025-11-26 11:46:04
最近更新时间: 2025-11-26 11:46:04
死信消息
对于消费失败且重试后依然失败的消息,分布式消息服务RocketMQ不会立即丢弃,而是将消息转发至指定的队列中,即死信队列,这些消息即为死信消息。当消费失败的原因排查并解决后,您可以重新投递这些死信消息,让消费者重新消费;若您暂时无法处理这些死信消息,为避免到期后死信消息被删除,您也可以先将死信消息导出进行保存。
特性说明
死信消息具有如下特性:
不会再被消费者正常消费。
有效期与正常消息相同,默认保留168小时。超过默认的168小时后,会被自动删除。
死信队列具有如下特性:
一个死信队列对应一个消费组,而不是对应单个消费者实例。
如果一个消费组未产生死信消息,分布式消息服务RocketMQ不会为其创建相应的死信队列。
一个死信队列包含了对应消费组产生的所有死信消息,不论该消息属于哪个Topic。
查询死信消息的方式
登录天翼云分布式消息服务RocketMQ控制台。
单击RocketMQ实例的名称,进入实例详情页面。
在左侧导航栏,单击“消息查询 > 死信队列查询”,进入“死信队列”页面。
选择消费组名、消息ID、时间范围查询死信消息。
RocketMQ提供的查询死信消息的方式。
查询方式 | 查询条件 | 说明 |
|---|---|---|
按Group查询 | Group+时间段 | 根据消费组和时间范围,批量获取符合条件的所有死信消息,查询量大,不易匹配。 |
按消息ID查询 | Group+消息ID | 根据消费组和消息可以精确定位任意一条死信消息,获取死信消息的属性。 |