server/services/src/main/java/com/doumee/core/mqtt/service/MqttPushCallback.java
@@ -20,13 +20,14 @@ //接收消息回调 @Override public void connectionLost(Throwable cause) { // 连接丢失后,一般在这里面进行重连 System.out.println("连接断开,重连中"); try { MqttClientInit.refreshClient(); } catch (MqttException e) { throw new RuntimeException(e); } // 连接丢失后,一般在这里面进行重连 System.out.println("连接断开,可以做重连"); } @Override