From bf1b78168478f802a7413d438b16ab64b27b7f4a Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期三, 02 四月 2025 14:32:38 +0800 Subject: [PATCH] 代码优化 --- pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java | 13 +++++++++---- 1 files changed, 9 insertions(+), 4 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java index 3c43616..dabba38 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttMsgSubscriber.java @@ -16,10 +16,15 @@ public void readSubscribeTopicMessage(){ try { - String broker = "tcp://127.0.0.1:1883"; - String username = "mqtt_u"; - String password = "yjy"; - String topic = "workOrder"; + //String broker = "tcp://127.0.0.1:1883"; + //String username = "mqtt_u"; + //String password = "yjy"; + //String topic = "workOrder"; + String broker = "tcp://127.0.0.1:1884"; + String username = "server"; + String password = "1234"; + String topic = "report/#"; + Integer qos = 2; String clientId = System.currentTimeMillis() + ""; -- Gitblit v1.8.0