From d71e3a495a125811889fdf7c2a2ec0650e28262d Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期四, 25 十二月 2025 17:41:21 +0800
Subject: [PATCH] 最新版本541200007最新版本541200007
---
server/visits/device_service/src/main/java/com/doumee/mqtt/service/MqttBizService.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/server/visits/device_service/src/main/java/com/doumee/mqtt/service/MqttBizService.java b/server/visits/device_service/src/main/java/com/doumee/mqtt/service/MqttBizService.java
new file mode 100644
index 0000000..eaba23d
--- /dev/null
+++ b/server/visits/device_service/src/main/java/com/doumee/mqtt/service/MqttBizService.java
@@ -0,0 +1,28 @@
+package com.doumee.mqtt.service;
+
+import com.doumee.mqtt.config.MqttConfig;
+import org.eclipse.paho.client.mqttv3.MqttClient;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+
+/**
+ * 涓庣‖浠跺鎺ユ湇鍔�
+ * @author 姹熻箘韫�
+ * @date 2023/10/09 18:06
+ */
+public interface MqttBizService {
+
+ /**
+ * 鎸夐厤缃闃�
+ * @param config
+ * @param topics
+ */
+ MqttClient subscribe(MqttClient client,MqttConfig config, String[] topics);
+ MqttClient unsubscribe(MqttClient client,MqttConfig config, String[] topics);
+ /**
+ * 鎸夐厤缃彂甯冩秷鎭�
+ * @param config
+ * @param topic
+ */
+ MqttClient publish(MqttClient client,MqttConfig config,String topic,String param);
+
+}
--
Gitblit v1.9.3