代码优化

zhubaomin

2024-11-22 a7b3fa7977cf0c149f4a4a98425572db4257c909

 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";
    }
}