From 3066988e8676dae5bb74122be057d874fc2e284f Mon Sep 17 00:00:00 2001
From: shenhongxi <shenhongxi@360.cn>
Date: Fri, 8 Sep 2017 18:14:41 +0800
Subject: [PATCH] rabbitmq

---
 whatsmars-mq/pom.xml                          |  6 ++++
 .../whatsmars/mq/rabbitmq/Consumer.java       | 32 +++++++++++++++++++
 .../whatsmars/mq/rabbitmq/Producer.java       | 27 ++++++++++++++++
 3 files changed, 65 insertions(+)
 create mode 100644 whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Consumer.java
 create mode 100644 whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Producer.java

diff --git a/whatsmars-mq/pom.xml b/whatsmars-mq/pom.xml
index 4cf5ca4a..d6f19cd3 100644
--- a/whatsmars-mq/pom.xml
+++ b/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>
 
 
 
diff --git a/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Consumer.java b/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Consumer.java
new file mode 100644
index 00000000..a4c51f2d
--- /dev/null
+++ b/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Consumer.java
@@ -0,0 +1,32 @@
+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 + "'");
+        }
+    }
+}
diff --git a/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Producer.java b/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Producer.java
new file mode 100644
index 00000000..509730c3
--- /dev/null
+++ b/whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rabbitmq/Producer.java
@@ -0,0 +1,27 @@
+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();
+    }
+}
-- 
GitLab