rabbitmq

whatsmars-mq/pom.xml

@@ -51,6 +51,12 @@
             <version>5.15.0</version>
         </dependency>
 
+        <!-- https://mvnrepository.com/artifact/com.rabbitmq/amqp-client -->
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+            <version>4.2.0</version>
+        </dependency>
 
 
 

whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Consumer.java

+package com.itlong.whatsmars.mq.rabbitmq;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.QueueingConsumer;
+
+/**
+ * Created by shenhongxi on 2017/9/8.
+ */
+public class Consumer {
+
+    public static void main(String[] args) throws Exception {
+        String queueName = "TestQueue";
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("127.0.0.1");
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        channel.queueDeclare(queueName, false, false, false, null);
+        System.out.println(" [*] Waiting for messages...");
+
+        QueueingConsumer consumer = new QueueingConsumer(channel);
+        channel.basicConsume(queueName, true, consumer);
+
+        while (true) {
+            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
+            String message = new String(delivery.getBody());
+            System.out.println(" [x] Received '" + message + "'");
+        }
+    }
+}

whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Producer.java

+package com.itlong.whatsmars.mq.rabbitmq;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+/**
+ * Created by shenhongxi on 2017/9/8.
+ */
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        String queueName = "TestQueue";
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost("127.0.0.1");
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        channel.queueDeclare(queueName, false, false, false, null);
+        String message = "Hello World!";
+        channel.basicPublish("", queueName, null, message.getBytes());
+        System.out.println(" [x] Sent '" + message + "'");
+
+        channel.close();
+        connection.close();
+    }
+}