ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java
@@ -1,6 +1,6 @@ package com.ruoyi.utils.mqtt; import com.ruoyi.alarm.globalAlarm.service.impl.GlobalAlarmServiceImpl; import com.ruoyi.alarm.global.service.impl.GlobalAlarmServiceImpl; import com.ruoyi.common.utils.spring.SpringUtils; import lombok.extern.slf4j.Slf4j; import org.eclipse.paho.client.mqttv3.*; @@ -38,8 +38,7 @@ log.info("MQTT连接断开,发起重连......"); while (!client.isConnected()) { try { Thread.sleep(5000); Thread.sleep(10000); if (null != client && !client.isConnected()) { client.reconnect(); log.error("尝试重新连接");