From 6f8ee2a80741b1f11bbe4dc77c0dafdbb56aa4dd Mon Sep 17 00:00:00 2001
From: simon <861719797@qq.com>
Date: Mon, 25 Sep 2023 21:13:34 +0800
Subject: [PATCH] =?UTF-8?q?mq=E5=AF=B9=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 iot-common/iot-rabbit/pom.xml                 | 58 +++++++++++++++++++
 .../iot/rabbit/config/RunXiRabbitConfig.java  | 29 ++++++++++
 .../rabbit/constants/YunxiRabbitConst.java    | 23 ++++++++
 .../iot/rabbit/service/MqSendMsgService.java  | 33 +++++++++++
 iot-common/pom.xml                            |  1 +
 5 files changed, 144 insertions(+)
 create mode 100644 iot-common/iot-rabbit/pom.xml
 create mode 100644 iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/config/RunXiRabbitConfig.java
 create mode 100644 iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/constants/YunxiRabbitConst.java
 create mode 100644 iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/service/MqSendMsgService.java

diff --git a/iot-common/iot-rabbit/pom.xml b/iot-common/iot-rabbit/pom.xml
new file mode 100644
index 0000000..4f63e3c
--- /dev/null
+++ b/iot-common/iot-rabbit/pom.xml
@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.qiuguo.iot</groupId>
+        <artifactId>iot-common</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>iot-rabbit</artifactId>
+    <name>iot-rabbit</name>
+    <description>mq类</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>${spring.boot.maven.plugin.version}</version>
+                <configuration>
+                    <!--跳过对项目中main方法的查找-->
+                    <skip>true</skip>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/config/RunXiRabbitConfig.java b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/config/RunXiRabbitConfig.java
new file mode 100644
index 0000000..11796f7
--- /dev/null
+++ b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/config/RunXiRabbitConfig.java
@@ -0,0 +1,29 @@
+package com.qiuguo.iot.rabbit.config;
+
+import com.qiuguo.iot.rabbit.constants.YunxiRabbitConst;
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.Exchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.core.TopicExchange;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class RunXiRabbitConfig {
+
+    /**
+     * 交换机
+     *
+     * @return
+     */
+    @Bean
+    public Exchange RunxiEventExchange() {
+        return new TopicExchange(YunxiRabbitConst.EXCHANGE_YUNXI_EVENT,
+                true,
+                false,
+                null);
+    }
+}
diff --git a/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/constants/YunxiRabbitConst.java b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/constants/YunxiRabbitConst.java
new file mode 100644
index 0000000..c53e4a5
--- /dev/null
+++ b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/constants/YunxiRabbitConst.java
@@ -0,0 +1,23 @@
+package com.qiuguo.iot.rabbit.constants;
+
+/**
+ * @author simon
+ * @date 2023/9/25
+ * @description
+ **/
+public class YunxiRabbitConst {
+   /**
+    * 云栖活动交换机
+    */
+   public static final String EXCHANGE_YUNXI_EVENT = "iot-yunxi-exchange";
+
+   /**
+    * 云栖活动队列
+    */
+   public static final String QUEUE_YUNXI = "iot.yunxi.queue";
+
+   /**
+    * 云栖活动发送的路由键
+    */
+   public static final String ROUTE_KEY_YUNXI = "iot.yunxi";
+}
diff --git a/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/service/MqSendMsgService.java b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/service/MqSendMsgService.java
new file mode 100644
index 0000000..9370d11
--- /dev/null
+++ b/iot-common/iot-rabbit/src/main/java/com/qiuguo/iot/rabbit/service/MqSendMsgService.java
@@ -0,0 +1,33 @@
+package com.qiuguo.iot.rabbit.service;
+
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Mono;
+
+import javax.annotation.Resource;
+
+/**
+ * @author simon
+ * @date 2023/9/25
+ * @description
+ **/
+@Service
+public class MqSendMsgService {
+   @Resource
+   private RabbitTemplate rabbitTemplate;
+   public Mono<Boolean> sendRabbitMsg(String exchange, String routingKey, Object message) {
+      return Mono.create(sink -> {
+         rabbitTemplate.setConfirmCallback((correlation, ack, cause) -> {
+            if (ack) {
+               // 消息发送成功
+               sink.success(Boolean.TRUE);
+            } else {
+               // 消息发送失败
+               sink.error(new RuntimeException("Message send failed: " + cause));
+            }
+         });
+
+         rabbitTemplate.convertAndSend(exchange, routingKey, message);
+      });
+   }
+}
diff --git a/iot-common/pom.xml b/iot-common/pom.xml
index 1cc5a63..3b161a0 100644
--- a/iot-common/pom.xml
+++ b/iot-common/pom.xml
@@ -15,6 +15,7 @@
         <module>iot-base</module>
         <module>iot-data</module>
         <module>iot-third</module>
+        <module>iot-rabbit</module>
     </modules>
 
     <dependencies>