From 42922f126d7259f8a1da6a81d5ee8e9e45300278 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期五, 22 十一月 2024 15:23:22 +0800 Subject: [PATCH] 设计实现导出当前升级任务成功与失败RTU功能 --- 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