csdn_sqj
csdn_sqj
采纳率100%
2020-08-12 10:59

rabbitmq 延时队列,消息被监听到以后,还在队列里面

5
已采纳

图片说明
图片说明
图片说明
+++++++++++++++++++++
如图,我在尝试使用rabbitmq的延时队列
延时的效果是可以实现的
问题:
每次消息由死信队列转发到一般队列以后,消费者通过监听能捕获到,但是那个消息一直在队列里面。请问是为什么?要怎么解决?

请大神指教,谢谢!

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

2条回答

  • it_zhangwei 路漫漫兮其修远兮 8月前

    开启了手动ack,没有进行手动ack操作,消息自然还是会留在队列里面的,需要进行手动ack操作
    参考如下代码

    @RabbitListener(queues = RabbitMqConfig.REQUEST_LOG_QUEUE)
        public void process(String content, Channel channel, Message message) throws IOException {
            try {
                log.info("{}", message);
                RequestLog requestLog = JSON.parseObject(message.getBody(), RequestLog.class);
                final int exist = requestLogDao.existTable();
                if (exist == 0) {
                    requestLogDao.createTable("t_request_log");
                }
                // 日志入库操作
                    this.requestLogDao.insert(requestLog);
    
                // 手动ack
                channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
            } catch (Exception e) {
                e.printStackTrace();
                log.error("消费这监听异常,转入错误队列");
                //转入异常队列
                rabbitTemplate.convertAndSend(RabbitMqConfig.ERROR_LOG_QUEUE,message);
                channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
            }
        }
    
    点赞 1 评论 复制链接分享
  • caozhy 回答这么多问题就耍赖把我的积分一笔勾销了 8月前

    https://www.cnblogs.com/yinfengjiujian/p/9204600.html
    看这里,dead letter不会删除,但是转发后会删除,调用 notifyConfirmCallBackListener 回调

    点赞 评论 复制链接分享