RocketMQ——查看死信队列

在上篇博客中我们了解了RocketMQ的ACK机制，其中涉及到了消息消费重试，当重试次数达到默认的16次后（可以通过配置文件修改）如果对应的消息还没被成功消费的话，该消息就会投递到DLQ死信队列。

不过，在使用控制台查询死信消息队列的时候会报错，具体如下图

org.apache.rocketmq.client.exception.MQClientException: Can not find Message Queue for this topic, %DLQ%consumer1 See http://rocketmq.apache.org/docs/faq/ for further details.

对应服务器进入相关的目录下，/usr/local/rocketmq/store/consumequeue，发现确实是存在%DLQ%consumer1

我们通过进入到，通过rocketmq的管理命令（先进入/usr/local/rocketmq/bin）查看所有的topic，发现也确实能够找到

sh mqadmin  topicList -n 192.168.140.129:9876;192.168.140.128:9876

查看该topic信息，发现perm为2

sh mqadmin  topicRoute -n 192.168.140.129:9876 -t %DLQ%consumer1

修改topic的perm为6（两台机器都要执行）

在128机器上执行如下命令：

 sh mqadmin  updateTopic -b 192.168.159.129:10911 -n 192.168.159.129:9876 -t %DLQ%consumer1 -p 6

129机器上执行如下命令：

 sh mqadmin  updateTopic -b 192.168.159.128:10911 -n 192.168.159.128:9876 -t %DLQ%consumer1 -p 6

查看控制台死信队列

RocketMQ——查看死信队列相关推荐

RocketMQ的死信队列
死信队列用于处理无法被正常消费的消息.当一条消息初次消费失败,消息队列会自动进行消息重试:达到最大重试次数后,若消费依然失败,则表明消费者在正常情况下无法正确地消费该消息,此时,消息队列不会立刻将消 ...
【RocketMQ】消息重试、重试次数设置、死信队列
文章目录 1. 死信队列 1.1 死信特性 1.2 查看死信消息 2.重试次数参数 2.1 Producer端重试 2.2 Consumer端重试 3.1 异常重试 3.2 超时重试参考 1. 死信 ...
RocketMQ 死信队列
RocketMQ 死信队列死信队列死信队列是什么? 死信队列指的是种正常情况下无法被消费的消息称为死信消息(Dead-Letter Message),存储死信消息的特殊队列称为死信队列(Dead- ...
Linux系统查看mq死信队列,MQ死信队列中持续出现本地系统对象产生的数据
MQ死信队列持续生成死信消息,刚刚是1W多条,清空后,又再继续增加,但是应用发送与接收消息均反馈无异常,不知这个死信产生的原因如何,求大神给指导一下,谢谢. 错误日志如下: ------------- ...
linux查看mq是否启动的命令,rocketmq查看命令
1.1. 控制台使用 RocketMQ 提供有控制台及一系列控制台命令,用于管理员对主题,集群,broker 等信息的管理: 登录控制台首先进入RocketMQ 工程,进入/RocketMQ/bin ...
RabbitMQ,Springboot整合RabbitMQ实现消息可靠性投递,Consumer ACK,TTL,死信队列,使用TTL+死信队列=延迟队列
搭建SpringBoot项目,用于演示 springboot版本 <dependency><groupId>org.spri ...
rocketmq 几种队列_这篇进阶必看的RocketMQ，答应我看完好吗？
RocketMQ 整体架构设计整体的架构设计主要分为四大部分,分别是:Producer.Consumer.Broker.NameServer. 为了更贴合实际,我画的都是集群部署,像 Broker ...
消息队列控制灯代码_代码实现RabbitMQ死信队列的创建
‍ ‍前言:‍ ‍ 之前有写过死信队列的使用场景以及通过管控台创建死信.这次就通过代码实现死信队列的创建,同时也分享一下RabbitMQ封装的类. 准备: 1. 先准备一个死信队列(最后用来消费)的参 ...
RabbitMQ TTL、死信队列在订单支付场景的应用
基于RabbitMQ的TTL以及死信队列,使用SpringBoot实现延迟付款,手动补偿操作. 1.用户下单后展示等待付款页面 2.在页面上点击付款的按钮,如果不超时,则跳转到付款成功页面 3.如果超 ...

RocketMQ——查看死信队列

查看该topic信息，发现perm为2

修改topic的perm为6（两台机器都要执行）

查看控制台死信队列

RocketMQ——查看死信队列相关推荐

最新文章

热门文章