docs: [SpringBoot整合RabbitMQ]增加rabbitmq的简单模型示例（生产者-消费者）

Author: GitSuperDrew

springboot-rabbitmq/src/test/java/edu/study/module/springbootrabbitmq/demo/RabbitmqDemoConsumer.java

@@ -0,0 +1,74 @@
+package edu.study.module.springbootrabbitmq.demo;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+import java.io.IOException;
+import java.util.concurrent.TimeoutException;
+
+/**
+ * 测试使用：RabbitMQ 简单工作模式（hello world）
+ * <pre>
+ *     1.创建链接工厂；
+ *     2.创建链接Connection
+ *     3.通过链接获取通道Channel
+ *     4.通过创建交换机，声明队列，绑定关系，路由key，发送消息，和接受消息；
+ *     5.准备消息内容
+ *     6.发送消息给队列queue
+ *     7.关闭链接
+ *     8.关闭通道
+ * </pre>
+ *
+ * @author zl
+ * @create 2021-08-16 11:06
+ */
+public class RabbitmqDemoConsumer {
+    public static void main(String[] args) {
+        // 1. 创建链接工厂
+        ConnectionFactory connectionFactory = new ConnectionFactory();
+        connectionFactory.setHost("192.168.174.156");
+        connectionFactory.setPort(5672);
+        connectionFactory.setUsername("admin");
+        connectionFactory.setPassword("admin");
+        connectionFactory.setConnectionTimeout(6000);
+        connectionFactory.setVirtualHost("/");
+        // 2.创建链接
+        Connection connection = null;
+        Channel channel = null;
+        try {
+            connection = connectionFactory.newConnection("生产者");
+            channel = connection.createChannel();
+            String queueName = "queue1";
+            channel.basicConsume("queue1", true,
+                    (s, delivery) -> System.out.println("收到消息：" + new String(delivery.getBody(), "UTF-8")),
+                    s -> System.out.println("接受失败了……"));
+
+            System.out.println("消息发送成功。。。");
+            System.in.read();
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            // 关闭通道
+            if (channel != null && channel.isOpen()) {
+                try {
+                    channel.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                } catch (TimeoutException e) {
+                    e.printStackTrace();
+                }
+            }
+
+            // 关闭链接
+            if (connection != null && connection.isOpen()) {
+                try {
+                    connection.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+}

springboot-rabbitmq/src/test/java/edu/study/module/springbootrabbitmq/demo/RabbitmqDemoProductor.java

@@ -0,0 +1,80 @@
+package edu.study.module.springbootrabbitmq.demo;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.MessageProperties;
+
+import java.io.IOException;
+import java.util.concurrent.TimeoutException;
+
+/**
+ * 测试使用：RabbitMQ 简单工作模式（hello world）
+ * <pre>
+ *     1.创建链接工厂；
+ *     2.创建链接Connection
+ *     3.通过链接获取通道Channel
+ *     4.通过创建交换机，声明队列，绑定关系，路由key，发送消息，和接受消息；
+ *     5.准备消息内容
+ *     6.发送消息给队列queue
+ *     7.关闭链接
+ *     8.关闭通道
+ * </pre>
+ *
+ * @author zl
+ * @create 2021-08-16 11:06
+ */
+public class RabbitmqDemoProductor {
+    public static void main(String[] args) {
+        // 1. 创建链接工厂
+        ConnectionFactory connectionFactory = new ConnectionFactory();
+        connectionFactory.setHost("192.168.174.156");
+        connectionFactory.setPort(5672);
+        connectionFactory.setUsername("admin");
+        connectionFactory.setPassword("admin");
+        connectionFactory.setConnectionTimeout(6000);
+        connectionFactory.setVirtualHost("/");
+        // 2.创建链接
+        Connection connection = null;
+        Channel channel = null;
+        try {
+            connection = connectionFactory.newConnection("生产者");
+            channel = connection.createChannel();
+            String queueName = "queue1";
+            /**
+             * 队列声明信息
+             * 1.队列名称
+             * 2.是否要持久化durable=false,所谓持久化消息是否存盘，如果false，非持久化true是否持久化？非持久化会存盘嘛？会存盘，但是会随着rabbitmq服务的关闭而丢失
+             * 3.排他性，是否是独占队列
+             * 4.是否自动删除，随着最后一个消息完毕消息以后是否吧队列自动删除
+             * 5.携带附属参数
+             */
+            channel.queueDeclare(queueName, false, false,false,null);
+            String message = "hello world";
+            channel.basicPublish("", queueName, MessageProperties.PERSISTENT_BASIC, message.getBytes());
+            System.out.println("消息发送成功。。。");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            // 关闭通道
+            if (channel != null && channel.isOpen()) {
+                try {
+                    channel.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                } catch (TimeoutException e) {
+                    e.printStackTrace();
+                }
+            }
+
+            // 关闭链接
+            if (connection != null && connection.isOpen()) {
+                try {
+                    connection.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+}