From fb2f11d7d502ceacbe7fbed176bea4ab0f152f69 Mon Sep 17 00:00:00 2001
From: liulin <lin.liu@88.com>
Date: 星期四, 03 七月 2025 18:17:59 +0800
Subject: [PATCH] 添加mqtt

---
 src/main/java/com/lunhan/water/host/mqtt/MQTTServer.java |   15 ++++++++++-----
 1 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/lunhan/water/host/mqtt/MQTTServer.java b/src/main/java/com/lunhan/water/host/mqtt/MQTTServer.java
index 7263803..7718962 100644
--- a/src/main/java/com/lunhan/water/host/mqtt/MQTTServer.java
+++ b/src/main/java/com/lunhan/water/host/mqtt/MQTTServer.java
@@ -63,11 +63,10 @@
      * @param topic 发布消息的主题
      * @param data 消息内容
      */
-    public boolean send(String topic, String data) throws MqttException {
-        MqttConnectOptions options = mqttConnect.getOptions();
+    public boolean send(String topic, String data) {
         try {
-            client.connect(mqttConnect.getOptions(options));
-        } catch (Exception e) {}
+            this.connect();
+        } catch (Exception ignored) {}
         MqttTopic mqttTopic = client.getTopic(topic);
 
         MqttMessage message = new MqttMessage();
@@ -81,7 +80,13 @@
 
         message.setPayload(data.getBytes());
 
-        return this.publish(mqttTopic, message);
+        LOGGER.debug(String.format("发送mqtt消息:%s, 消息内容:%s", topic, message));
+        try {
+            return this.publish(mqttTopic, message);
+        } catch (MqttException e) {
+            LOGGER.error("发送mqtt消息", e);
+            return Boolean.FALSE;
+        }
     }
 
     @Override

--
Gitblit v1.9.3