From a7b3fa7977cf0c149f4a4a98425572db4257c909 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期五, 22 十一月 2024 11:34:22 +0800
Subject: [PATCH] 代码优化
---
pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java
index b2f3c37..0fb914a 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/TestController.java
@@ -25,7 +25,7 @@
MqttClient mqttClient = MqttClientConnectorPool.connectMQTT();
MqttMsgSender sender = new MqttMsgSender();
- String content = "{" + " \"deviceNo\": \"" + msg + "\"," + " \"val\": 232.5" + "}";
+ String content = "{" + " \"message\": \"" + msg + "\"," + " \"val\": 100.00" + "}";
String topic = "workOrder";
int qos = 1;
@@ -38,4 +38,11 @@
}
return "鎴愬姛锛�";
}
+
+ @GetMapping("/receive")
+ public String receiveMsg() {
+ MqttMsgSubscriber subscriber = new MqttMsgSubscriber();
+ subscriber.readSubscribeTopicMessage();
+ return "success";
+ }
}
--
Gitblit v1.8.0