From 08116a3c0d7cf7ea098c3c79e0f3d3ff8ad530f0 Mon Sep 17 00:00:00 2001 From: zhangnaisong <2434969829@qq.com> Date: 星期六, 24 六月 2023 15:11:21 +0800 Subject: [PATCH] 三一用户提交 --- ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java | 9 +++++---- 1 files changed, 5 insertions(+), 4 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java index aa334a5..f7bdf58 100644 --- a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java +++ b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java @@ -36,8 +36,9 @@ @Override public void connectionLost(Throwable cause) { log.info("MQTT杩炴帴鏂紑锛屽彂璧烽噸杩�......"); - try { - while (!client.isConnected()) { + while (!client.isConnected()) { + try { + Thread.sleep(5000); if (null != client && !client.isConnected()) { client.reconnect(); @@ -46,9 +47,9 @@ client.connect(options); log.error("灏濊瘯寤虹珛鏂拌繛鎺�"); } + } catch (Exception e) { + log.error("鏂紑閲嶈繛寮傚父:" + e.getMessage()); } - } catch (Exception e) { - e.printStackTrace(); } } -- Gitblit v1.9.3