From b38019aae593a66c16f7e75d6e37d14eb8d2c42e Mon Sep 17 00:00:00 2001
From: zhuguifei <zhuguifei@zhuguifeideiMac.local>
Date: 星期二, 22 七月 2025 08:55:15 +0800
Subject: [PATCH] 修改接收实时数据接口-故障处理
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttUtil.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 insertions(+), 0 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttUtil.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttUtil.java
index b744404..bdfb9f8 100755
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttUtil.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttUtil.java
@@ -1,7 +1,10 @@
package org.jeecg.modules.dry.mqtt;
+import cn.hutool.core.thread.ThreadUtil;
+import com.alibaba.fastjson.JSONObject;
import lombok.Data;
import org.eclipse.paho.client.mqttv3.MqttClient;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Component;
@Component
@@ -9,4 +12,30 @@
public class MqttUtil {
public MqttClient mqttClient;
+ /**
+ * 鍙戦�佹秷鎭�
+ *
+ * @param topic 璁㈤槄
+ * @param mqMessage 娑堟伅浣�
+ * @param type 1-鍙戦�佺粰绉熸埛 2-鍙戦�佺粰鍥哄畾id
+ */
+ public void sendMqttMessage(String topic, MqMessage mqMessage, Integer type) {
+ ThreadUtil.execute(() -> {
+ try {
+ if (type == 1) {
+ MqttMessage sendMessage = new MqttMessage(JSONObject.toJSONString(mqMessage).getBytes());
+ sendMessage.setQos(0);
+ mqttClient.publish(String.format(topic, mqMessage.getTentId()), sendMessage);
+ } else if (type == 2) {
+ MqttMessage sendMessage = new MqttMessage(JSONObject.toJSONString(mqMessage).getBytes());
+ sendMessage.setQos(0);
+ mqttClient.publish(topic, sendMessage);
+ }
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ });
+ }
+
}
--
Gitblit v1.9.3