Java笔记-spring-rabbitmq中使用@RabbitListener消费（手动确认，获header数据）

红太狼 2022-12-26 00:47 155阅读 0赞

手动确认时：

application.properties需要添加

spring.rabbitmq.listener.simple.acknowledge-mode=manual

确认ack

channel.basicAck(tag, false);

拒收发回rabbitmq

channel.basicReject(tag, true);

下面是整体代码

@RabbitListener(queues = queueName)
        public void disposeSomething(@Header(AmqpHeaders.DELIVERY_TAG) long tag, @Header("key") String key, @Payload String msg, Channel channel){
    
            System.out.println("-------------------------------------");
            System.out.println(key);
            System.out.println(msg);
            try {
    //            channel.basicAck(tag, false);
                channel.basicReject(tag, true);
            } catch (IOException e) {
                e.printStackTrace();
            }
            System.out.println("-------------------------------------");
        }

如果这里不停的拒收，再放回队列中，就会出现这样的现象：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70]: /images/20221120/7fae62d5f49e451486d6bdf3d9179db6.png

发表评论取消回复

表情：

评论列表（有 0 条评论，155人围观）

还没有评论，来说两句吧...

相关阅读

相关 Spring rabbitmq消息机制--手动确认

先我们在Spring.xml中配置相关的消费者在配置的时候可以指定是手动确认还是自动的确认，比如:  <r...

梦里梦外;/ 2024年04月17日 20:33/ 0 赞/ 18 阅读

相关 java批量消费队列(BlockingQueue)中的数据

文章目录队列的消费模式存数据到队列 ArrayBlockingQueue参数说明一、单条消费 : 二、批量消费三、测试

偏执的太偏执、/ 2024年04月08日 08:30/ 0 赞/ 32 阅读

相关 @RabbitListener和@RabbitHandler的使用

1. @RabbitListener 注解是指定某方法作为消息消费的方法，例如监听某 Queue 里面的消息。 2. @RabbitListener标注在方法上，直接监听指

忘是亡心i/ 2023年10月15日 23:50/ 0 赞/ 4 阅读

相关 Rabbit @RabbitListener消息队列使用

@RabbitListener(bindings = @QueueBinding( value = @Queue(value = que

水深无声/ 2023年01月12日 15:52/ 0 赞/ 203 阅读

相关 RabbitMQ使用手动ACK签收保证消息成功消费

RabbitMQ默认acknowledge-mode为auto即自动ack模式，只要有消费者接受消息，无论消费是否成功MQ都认为消费成功。网络原因和消费者自身程序原因都有可能导

刺骨的言语ヽ痛彻心扉/ 2022年12月30日 07:39/ 0 赞/ 102 阅读

相关 Java笔记-spring-rabbitmq中使用@RabbitListener消费（手动确认，获header数据）

手动确认时： application.properties需要添加 spring.rabbitmq.listener.simple.acknowledge-mode

红太狼/ 2022年12月26日 00:47/ 0 赞/ 156 阅读

相关 RocketMQ中的Producer重试和Consumer消费确认

目录 Producer的重试 Consumer的消费确认 -------------------- 从保证消息准确发送和消费的角度考虑，RocketMQ中为生产者提供了

朴灿烈づ我的快乐病毒、/ 2022年11月14日 14:53/ 0 赞/ 212 阅读

相关 RabbitMQ-使用@RabbitListener注解消费消息

> `@RabbitListener`注解指定目标方法来作为消费消息的方法，通过注解参数指定所监听的队列或者Binding。使用@RabbitListener可以设置一个自己明

谁借莪１个温暖的怀抱￠/ 2022年11月13日 10:28/ 0 赞/ 808 阅读

相关手动修改asm disk header

手动修改asm disk header Posted on [2012 年 10 月 26 日][2012 _ 10 _ 26] by [xiaoyu][] 手

- 日理万妓/ 2022年07月16日 15:21/ 0 赞/ 123 阅读

相关 rabbitmq消费数据读取header中的值

protected String extractCorrelationIdFromHeaders(AMQP.BasicProperties properties) th

青旅半醒/ 2022年01月26日 02:13/ 0 赞/ 320 阅读