feat(messaging/mqtt): 新增 MQTT 消息模块

Author: Time-w

continew-starter-bom/pom.xml

@@ -190,6 +190,13 @@
                 <version>${revision}</version>
             </dependency>
 
+            <!-- 消息模块 - MQTT -->
+            <dependency>
+                <groupId>top.continew.starter</groupId>
+                <artifactId>continew-starter-messaging-mqtt</artifactId>
+                <version>${revision}</version>
+            </dependency>
+
             <!-- 消息模块 - WebSocket -->
             <dependency>
                 <groupId>top.continew.starter</groupId>

continew-starter-core/src/main/java/top/continew/starter/core/constant/PropertiesConstants.java

@@ -124,6 +124,11 @@ public class PropertiesConstants {
      */
     public static final String MESSAGING_WEBSOCKET = MESSAGING + StringConstants.DOT + "websocket";
 
+    /**
+     * MQTT 配置
+     */
+    public static final String MESSAGING_MQTT = MESSAGING + StringConstants.DOT + "mqtt";
+
     /**
      * 日志配置
      */

continew-starter-messaging/continew-starter-messaging-mqtt/pom.xml

@@ -0,0 +1,27 @@
+<?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>top.continew.starter</groupId>
+        <artifactId>continew-starter-messaging</artifactId>
+        <version>${revision}</version>
+    </parent>
+
+
+    <artifactId>continew-starter-messaging-mqtt</artifactId>
+    <packaging>jar</packaging>
+
+    <name>${project.artifactId}</name>
+    <description>ContiNew Starter 消息模块 - MQTT</description>
+
+    <dependencies>
+        <!--spring MQTT消息模块-->
+        <dependency>
+            <groupId>org.springframework.integration</groupId>
+            <artifactId>spring-integration-mqtt</artifactId>
+        </dependency>
+
+    </dependencies>
+
+</project>

continew-starter-messaging/continew-starter-messaging-mqtt/src/main/java/top/continew/starter/messaging/mqtt/annotation/MqttListener.java

@@ -0,0 +1,79 @@
+/*
+ * Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
+ * <p>
+ * Licensed under the GNU LESSER GENERAL PUBLIC LICENSE 3.0;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * <p>
+ * http://www.gnu.org/licenses/lgpl.html
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package top.continew.starter.messaging.mqtt.annotation;
+
+import org.springframework.stereotype.Component;
+
+import java.lang.annotation.*;
+
+/**
+ * mqtt topic 监听器
+ *
+ * @author echo
+ * @since 2.15.0
+ */
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Inherited
+@Component
+public @interface MqttListener {
+
+    /**
+     * 要监听的 MQTT 主题
+     * <p>支持以下配置方式:
+     * <pre>{@code
+     * 方式1: 直接指定主题
+     * @MqttListener(topic = "sensor/temperature")
+     *
+     * 方式2: 使用配置文件占位符
+     * 
+     * @MqttListener(topic = "${mqtt.topic}")
+     *
+     *                     方式3: 使用通配符
+     * @MqttListener(topic = "sensor/+/temperature") // 单级通配符
+     * @MqttListener(topic = "sensor/#") // 多级通配符
+     *                     }</pre>
+     *
+     *                     <p><b>通配符说明:</b>
+     *                     <ul>
+     *                     <li>{@code +} - 单级通配符,匹配一个层级的任意内容</li>
+     *                     <li>{@code #} - 多级通配符,匹配零个或多个层级,只能用在主题末尾</li>
+     *                     </ul>
+     *
+     * @return MQTT 主题字符串或配置占位符表达式
+     */
+    String topic();
+
+    /**
+     * QoS - 消息传输可靠性等级
+     * <p>支持以下配置方式:
+     * <ul>
+     * <li>直接指定: {@code qos = "0"}, {@code qos = "1"}, {@code qos = "2"}</li>
+     * <li>使用占位符: {@code qos = "${mqtt.qos}"}</li>
+     * </ul>
+     * <p><b>QoS 等级说明:</b>
+     * <ul>
+     * <li>{@code 0} - 最多一次,消息可能丢失</li>
+     * <li>{@code 1} - 至少一次,消息可能重复</li>
+     * <li>{@code 2} - 恰好一次,消息不丢失且不重复</li>
+     * </ul>
+     *
+     * @return QoS 等级字符串或配置占位符,默认为 "0"
+     */
+    String qos() default "0";
+}