MQ修改

business-service/src/main/java/com/ozs/service/utils/PublishCallback.java

@@ -27,8 +27,7 @@ public class PublishCallback implements MqttCallback {
     @Override
     public void connectionLost(Throwable cause) {
         // 连接丢失后，一般在这里面进行重连
-        System.out.println("连接断开，可以做重连");
-        new SubscribeClient("heart", "heart").start();
+//        System.out.println("连接断开，可以做重连");
     }
 
     //接收到已经发布的 QoS 1 或 QoS 2 消息的传递令牌时调用