查询车模型提交

zhangnaisong

2023-07-20 1b5007fd66cb2c56e7b54b793cdd3f29785f5c04

 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.GlobalAlarmServiceImpl;
import com.ruoyi.alarm.globalAlarm.service.impl.GlobalAlarmServiceImpl;
import com.ruoyi.common.utils.spring.SpringUtils;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.*;
@@ -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();
        }
    }