搜索
查看
编辑修改
首页
UNITY
NODEJS
PYTHON
AI
GIT
PHP
GO
CEF3
JAVA
HTML
CSS
搜索
花生_TL007
这个屌丝很懒,什么也没留下!
关注作者
热门标签
jquery
HTML
CSS
PHP
ASP
PYTHON
GO
AI
C
C++
C#
PHOTOSHOP
UNITY
iOS
android
vue
xml
爬虫
SEO
LINUX
WINDOWS
JAVA
MFC
CEF3
CAD
NODEJS
GIT
Pyppeteer
article
热门文章
1
☀️苏州程序大白用万字解析Python网络编程与Web编程☀️《❤️记得收藏❤️》_wfconfigserver.handleclient();
2
linux学习——http综合实验_在linux中使用http做一个小实验
3
mac安装nvm(M1)
4
java项目之在线教育系统(springboot+vue+mysql)
5
2021年中国科学技术大学软件工程电子信息考研信息_中科大上机复试的环境
6
jsonarray转liast_后缀数组
7
Stable Diffusion初级教程_stable diffusion 教程
8
SpringBoot整合Web过滤器、监听器、拦截器_org.springframework.web.server.webfilter
9
SpringBoot的搭建(两种方式)_springboot环境搭建
10
rsync+sersync2文件同步(基于centos6.5)
当前位置:
article
> 正文
RocketMQ-什么是死信队列?怎么解决_rocketmq 死信队列 超过1000怎么处理
作者:花生_TL007 | 2024-05-14 19:19:38
赞
踩
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
推荐阅读
article
RocketMQ
重复
消费
的症状以及解决方案_
spring
boot
rocketmq
如何不
重复
消费
...
RocketMQ
重复
消费
的症状以及解决方案_
spring
boot
rocketmq
如何不
重复
消费
spring
boo...
赞
踩
article
rocketmq
-
spring
-
boot
-starter导致的多
消费者
实例重复消费问题_
spring
...
rocketM多
消费者
重复问题问题描述背景知识本地代码消息积压并重复消息原因分析问题描述在使用rocketMQ集群模式消...
赞
踩
article
RocketMQ
(
一
)...
rocketmq学习笔记
RocketMQ
(
一
) 作用 1. 限流削峰 2. 异步解耦 组成 Pr...
赞
踩
article
Kafka
、
ActiveMQ
、
RabbitMQ
、
RocketMQ
都有什么区别,以及适合哪些场景?_...
正如其他面试题,问到“Redis和Memcached之间的区别?”或者“Dubbo和SpringCloud之间的区别?”...
赞
踩
article
Spring
boot
整合
RocketMQ
——使用
rocketmq
-
spring
-
boot
-sta...
使用
rocketmq
-
spring
-
boot
-
starter
来配置发送和消费
RocketMQ
消息_rocketm...
赞
踩
article
Spring
Boot
+
RocketMQ
实现多实例分布式环境下的
事件
驱动
_
springboot
应用...
*** MQ消息监听*/@Component@Slf4j@Overridelog.info("MQListener 接收...
赞
踩
相关标签
java-rocketmq
rocketmq
java
中间件
kafka
rabbitmq
activemq
spring boot