搜索
查看
编辑修改
首页
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
基于n-gram模型的中文分词_ngram分词
2
java连接mysql增删改查(01单增删改查)_java连接mysq 增删改查
3
论文aigc检测率为多少合格?论文ai免费润色_本科毕业论文aigc值多少合格
4
Python中数据可视化的最新趋势和未来发展
5
不相交集(The Disjoint Set ADT)_the array representation of a disjoint set contain
6
Solana 与 DePIN 的双向奔赴,会带来 DePIN 之夏吗?
7
matlab实现apriori算法源代码实验报告_apriori算法实验报告
8
计算机毕业设计hadoop+spark知识图谱视频推荐系统 视频分析可视化大屏 视频爬虫 视频大数据分析 大数据毕业设计 机器学习 深度学习 人工智能
9
对云原生整体解决方案的进一步复盘
10
Java进阶-SpringCloud设计模式-工厂模式的设计与详解
当前位置:
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