‘liusuyi’
2023-06-16 a2f6f1975b6e0eca7ae24cb19cfe30343d93fab6
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()) {
            try {
                Thread.sleep(5000);
                if (null != client && !client.isConnected()) {
                    client.reconnect();
@@ -46,9 +47,9 @@
                    client.connect(options);
                    log.error("尝试建立新连接");
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
                log.error("断开重连异常:" + e.getMessage());
            }
        }
    }