手動確認時：

application.properties需要添加

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

確認ack

channel.basicAck(tag, false);

拒收發(fā)回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("-------------------------------------");}

如果這里不停的拒收，再放回隊列中，就會出現(xiàn)這樣的現(xiàn)象：

總結

以上是生活随笔為你收集整理的Java笔记-spring-rabbitmq中使用@RabbitListener消费（手动确认，获header数据）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。