挪动监听器注解的位置来解决消息监听循环报错问题

Author: JavaCodeMing

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/controller/TestController.java

@@ -102,7 +102,7 @@ public List<Student> directDelayMQ() {
                         message.getMessageProperties().setExpiration("15000");
                         return message;
                     });
-            System.out.println(now.format(dateTimeFormatter)+ " 消息发送："+student.toString());
+            System.out.println(now.format(dateTimeFormatter) + " 消息发送：" + student.toString());
         }
         return students;
     }

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyAckListener.java

@@ -11,14 +11,13 @@
 import java.util.Map;
 
 @Component
-@RabbitListener(
-        containerFactory = "myListenerFactory",
-        bindings = @QueueBinding(
-                value = @Queue("myManualAckQueue"),
-                exchange = @Exchange(value = "myManualAckExchange", type = ExchangeTypes.DIRECT),
-                key = "mine.manual"))
 public class MyAckListener {
-    @RabbitHandler
+    @RabbitListener(
+            containerFactory = "myListenerFactory",
+            bindings = @QueueBinding(
+                    value = @Queue("myManualAckQueue"),
+                    exchange = @Exchange(value = "myManualAckExchange", type = ExchangeTypes.DIRECT),
+                    key = "mine.manual"))
     public void onMessage(@Payload String msg, @Headers Map<String, Object> headers, Channel channel) throws Exception {
         try {
             System.out.println("来自 myManualAckQueue 的消息:" + msg);
@@ -34,4 +33,4 @@ public void onMessage(@Payload String msg, @Headers Map<String, Object> headers,
             // channel.basicReject();
         }
     }
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyDeadLetterListener.java

@@ -12,7 +12,6 @@
 
 @Component
 public class MyDeadLetterListener {
-
     @RabbitListener(
             containerFactory = "jsonListenerFactory",
             bindings = {@QueueBinding(
@@ -25,4 +24,4 @@ public void getDLMessage(Student user) {
         // 模拟执行任务
         System.out.println(now.format(dateTimeFormatter) +" 延迟队列之消费消息：" + user.toString() );
     }
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyDefaultListener.java

@@ -1,16 +1,14 @@
 package com.example.rabbitmq.listener;
 
 import org.springframework.amqp.rabbit.annotation.Queue;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
 @Component
-@RabbitListener(queuesToDeclare = @Queue("myDefaultExchange"))
 public class MyDefaultListener {
 
-    @RabbitHandler
+    @RabbitListener(queuesToDeclare = @Queue("myDefaultExchange"))
     public void onMessage(String msg) {
         System.out.println("来自 myDefaultExchange 的消息:" + msg);
     }
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyDirectListener.java

@@ -6,20 +6,20 @@
 import org.springframework.stereotype.Component;
 
 @Component
-@RabbitListener(
-        bindings = @QueueBinding(
-                value = @Queue("myDirectQueue"),
-                exchange = @Exchange(value = "myDirectExchange", type = ExchangeTypes.DIRECT),
-                key = "mine.direct"))
 public class MyDirectListener {
 
     /**
      * listenerAdapter
      *
      * @param msg 消息内容,当只有一个参数的时候可以不加@Payload注解
      */
-    @RabbitHandler
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    value = @Queue("myDirectQueue"),
+                    exchange = @Exchange(value = "myDirectExchange", type = ExchangeTypes.DIRECT),
+                    key = "mine.direct")
+    )
     public void onMessage(@Payload String msg) {
         System.out.println("来自 myDirectExchange 的消息:" + msg);
     }
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyFanoutListener.java

@@ -10,24 +10,22 @@
 import java.util.Map;
 
 @Component
-@RabbitListeners({
-    @RabbitListener(
-            bindings = @QueueBinding(
-                    value = @Queue("myFanoutQueue-one"),
-                    exchange = @Exchange(value = "myFanoutExchange", type = ExchangeTypes.FANOUT),
-                    key = "key.one")),
-    
-    @RabbitListener(
-            bindings = @QueueBinding(
-                    value = @Queue("myFanoutQueue-two"),
-                    exchange = @Exchange(value = "myFanoutExchange", type = ExchangeTypes.FANOUT),
-                    key = "key.two")),
-})
 public class MyFanoutListener {
+    @RabbitListeners({
+            @RabbitListener(
+                    bindings = @QueueBinding(
+                            value = @Queue("myFanoutQueue-one"),
+                            exchange = @Exchange(value = "myFanoutExchange", type = ExchangeTypes.FANOUT),
+                            key = "key.one")),
 
-    @RabbitHandler
+            @RabbitListener(
+                    bindings = @QueueBinding(
+                            value = @Queue("myFanoutQueue-two"),
+                            exchange = @Exchange(value = "myFanoutExchange", type = ExchangeTypes.FANOUT),
+                            key = "key.two")),
+    })
     public void onMessage(@Payload String msg, @Headers Map<String, Object> headers) {
         System.out.println("来自 " + headers.get(AmqpHeaders.CONSUMER_QUEUE) + " 的消息:" + msg);
     }
 
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyHeadListener.java

@@ -24,7 +24,6 @@ public void anyMatchOnMessage(String msg) {
         System.out.println("来自 headQueue-one 的消息:" + msg);
     }
 
-
     /**
      * 全匹配
      *
@@ -41,4 +40,4 @@ public void allMatchOnMessage(String msg) {
         System.out.println("来自 headQueue-two 的消息:" + msg);
     }
 
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyJasonListener.java

@@ -2,16 +2,14 @@
 
 import com.example.rabbitmq.domain.Student;
 import org.springframework.amqp.rabbit.annotation.Queue;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
 
 @Component
-@RabbitListener(containerFactory = "jsonListenerFactory",queuesToDeclare = @Queue("jsonQueue"))
 public class MyJasonListener {
-    @RabbitHandler
+    @RabbitListener(containerFactory = "jsonListenerFactory",queuesToDeclare = @Queue("jsonQueue"))
     public void onMessage(@Payload Student student) {
         System.out.println(student);
     }
-}
+}

Spring-Boot-RabbitMQ/src/main/java/com/example/rabbitmq/listener/MyPluginListener.java

@@ -8,6 +8,8 @@
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 
+import static java.time.LocalDateTime.*;
+
 /**
  * Created by dengzhiming on 2019/12/30
  */
@@ -23,7 +25,7 @@ public class MyPluginListener {
                             arguments = {@Argument(name="x-delayed-type",value = ExchangeTypes.DIRECT)}),
                     key = {"mine.plugin.key"})})
     public void getPDLMessage(Student user) {
-        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime now = now();
         DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
         // 模拟执行任务
         System.out.println(now.format(dateTimeFormatter) +" 延迟队列之消费消息：" + user.toString() );