From 61105482919e2cdbb69acba9f974e6e36165b7e1 Mon Sep 17 00:00:00 2001 From: andy <1042025947@qq.com> Date: Wed, 9 Apr 2025 17:34:46 +0800 Subject: [PATCH] =?UTF-8?q?mqtt=E6=B6=88=E6=81=AF,=20=20=E8=AE=B0=E5=BD=95?= =?UTF-8?q?=E4=BA=91=E7=AB=AF=E6=8E=A8=E9=80=81=E7=AB=99=E7=AB=AF=E7=9A=84?= =?UTF-8?q?=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../evotech/hd/cloud/mqtt/config/MqttPublishMessage.java | 4 +++- .../hd/cloud/mqtt/message/handle/MessageUtilService.java | 9 +++++++-- 2 files changed, 10 insertions(+), 3 deletions(-) diff --git a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java index 2983875..14b2235 100644 --- a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java +++ b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java @@ -10,7 +10,7 @@ import org.springframework.stereotype.Component; @Component public class MqttPublishMessage { - public void publish(String message, String topic) { + public MqttMessage publish(String message, String topic) { MqttClient cloudClient = MqttConnectInit.mqttClientMap.get("cloudClient"); MqttMessage mqttMessage = new MqttMessage(); /** @@ -36,6 +36,8 @@ public class MqttPublishMessage { } catch (MqttException e) { e.printStackTrace(); } + + return mqttMessage; } } diff --git a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/handle/MessageUtilService.java b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/handle/MessageUtilService.java index 810ce84..2cc267b 100644 --- a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/handle/MessageUtilService.java +++ b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/handle/MessageUtilService.java @@ -102,8 +102,13 @@ public class MessageUtilService { String encrypt = aes.encryptBase64(JSONUtil.toJsonStr(message)); // 3. 发送MQTT消息 - publishMessage.publish(encrypt, topic.toString()); - } + try { + MqttMessage mqttMessage = publishMessage.publish(encrypt, topic.toString()); + addMqttMessage(topic, mqttMessage.getId()+"", mqttMessage.getQos(), dataBody); + } catch (Exception e) { + throw new RuntimeException(e); + } + }