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