hbyt/cloud-battery-manage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt消息, 记录云端推送站端的信息

Browse Source
This commit is contained in:
andy 2025-04-09 17:34:46 +08:00
parent 994179f53b
commit 6110548291
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java
View File

@ -10,7 +10,7 @@ import org.springframework.stereotype.Component;
@Component @Component
public class MqttPublishMessage { public class MqttPublishMessage {
public void publish(String message, String topic) { public MqttMessage publish(String message, String topic) {
MqttClient cloudClient = MqttConnectInit.mqttClientMap.get("cloudClient"); MqttClient cloudClient = MqttConnectInit.mqttClientMap.get("cloudClient");
MqttMessage mqttMessage = new MqttMessage(); MqttMessage mqttMessage = new MqttMessage();
/** /**
@ -36,6 +36,8 @@ public class MqttPublishMessage {
} catch (MqttException e) { } catch (MqttException e) {
e.printStackTrace(); e.printStackTrace();
} }
return mqttMessage;
} }
} }

9
cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/message/handle/MessageUtilService.java
View File

@ -102,8 +102,13 @@ public class MessageUtilService {
String encrypt = aes.encryptBase64(JSONUtil.toJsonStr(message)); String encrypt = aes.encryptBase64(JSONUtil.toJsonStr(message));
// 3. 发送MQTT消息 // 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);
}
}