mq

rebbitmq/consumer/src/main/java/com/lovecoding/rabbitmq/consumer/ConsumerDemo.java

@@ -24,14 +24,17 @@ public class ConsumerDemo {
         String queueName = "testQueue";
         channel.queueDeclare( queueName, false, false, false, null );
 
+        //监听队列消息， 如果有消息则会回调客户端
         channel.basicConsume(queueName, new DefaultConsumer(channel){
 
+            //处理消息函数
             public void handleDelivery(String consumerTag,
                                        Envelope envelope,
                                        AMQP.BasicProperties properties,
                                        byte[] body)
                     throws IOException
             {
+                //我们收到消息后打印消息
                 System.out.println( new String( body ) );
             }
 

rebbitmq/producer/src/test/java/com/lovecoding/rabbitmq/producer/ProducerApplicationTests.java

@@ -32,8 +32,9 @@ class ProducerApplicationTests {
         String queueName = "testQueue";
         channel.queueDeclare( queueName, false, false, false, null );
 
+        //推送一个基本消息
         channel.basicPublish( "", queueName,
-                null,"Hello MQ".getBytes(StandardCharsets.UTF_8) );
+                null, "Hello MQ".getBytes(StandardCharsets.UTF_8) );
 
     }