ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java
@@ -36,9 +36,9 @@ @Override public void connectionLost(Throwable cause) { log.info("MQTT连接断开,发起重连......"); try { while (!client.isConnected()) { Thread.sleep(5000); while (!client.isConnected()) { try { Thread.sleep(10000); if (null != client && !client.isConnected()) { client.reconnect(); log.error("尝试重新连接"); @@ -46,9 +46,9 @@ client.connect(options); log.error("尝试建立新连接"); } } catch (Exception e) { log.error("断开重连异常:" + e.getMessage()); } } catch (Exception e) { e.printStackTrace(); } }