SpringBoot集成RabbitMQ消息队列ACK消息确认

Author: yanpenglei

spring-boot-rabbitmq-ack/src/main/java/com/souyunku/example/springboot/rabbitmq/ack/config/RabbitConfig.java

@@ -9,7 +9,8 @@ public class RabbitConfig {
 
     @Bean
     public Queue QueueA() {
-        return new Queue("hello");
+        // boolean durable = true 持久化
+        return new Queue("hello", true);
     }
 
 }

spring-boot-rabbitmq-ack/src/main/java/com/souyunku/example/springboot/rabbitmq/ack/producer/HelloSender.java

@@ -16,7 +16,12 @@ public class HelloSender implements RabbitTemplate.ReturnCallback {
     public void sendMessage(String context) {
         System.out.println("HelloReceiver发送内容: " + context + "，发送时间:" + new Date());
 
+
+        // 消息发送失败返回到队列中, application.properties 配置 spring.rabbitmq.publisher-returns=true
+        rabbitTemplate.setMandatory(true);
+
         this.rabbitTemplate.setReturnCallback(this);
+
         this.rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
             if (!ack) {
                 System.out.println("sendMessage 发送失败" + cause + correlationData.toString());

spring-boot-rabbitmq-ack/src/main/java/com/souyunku/example/springboot/rabbitmq/ack/receiver/HelloReceiver.java

@@ -20,15 +20,18 @@ public void process(String context, Message message, Channel channel) throws Exc
         System.out.println("HelloReceiver收到内容: " + context + "，收到时间:" + new Date());
         try {
             //告诉服务器收到这条消息 已经被我消费了 可以在队列删掉 这样以后就不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发
-            //channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            //消息确认  因为我在属性配置文件里面开启了ACK确认 所以如果代码没有执行ACK确认 你在RabbitMQ的后台会看到消息会一直留在队列里面未消费掉 只要程序一启动开始接受该队列消息的时候 又会收到
+
             System.out.println("HelloReceiver消息接收成功");
         } catch (Exception e) {
             e.printStackTrace();
-            //丢弃这条消息
+            ///ack返回false，并重新回到队列，api里面解释得很清楚
             channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
             System.out.println("消息接收失败");
         }
 
     }
 
+
 }