修改MQTT日志

src/main/java/com/care/mqtt/tool/MqttDataConnector.java

@@ -101,22 +101,26 @@ public class MqttDataConnector {
         mqttClient.setCallback(new MqttCallbackExtended() {
             @Override
             public void connectComplete(boolean reconnect, String serverURI) {
-                logger.info("reconnect ---> " + reconnect + "       serverURI--->" + serverURI);
+                logger.info("topic reconnect ---> " + reconnect + "       serverURI--->" + serverURI);
             }
 
             @Override
             public void connectionLost(Throwable cause) {
-                logger.error("connectionLost cause ---> " + cause);
+                logger.error("{}订阅丢失 connectionLost cause ---> {}"  ,topicFilter,cause.getMessage());
             }
 
             @Override
             public void messageArrived(String topic, MqttMessage message) throws Exception {
-
+                logger.error("{}订阅丢失 connectionLost cause ---> {}"  ,topic,message.toString());
             }
 
             @Override
             public void deliveryComplete(IMqttDeliveryToken token) {
-
+                try {
+                    logger.error("{}订阅丢失 connectionLost cause ---> {}"  ,token.getMessage().toString());
+                } catch (MqttException e) {
+                    e.printStackTrace();
+                }
             }
         });
     }
@@ -220,6 +224,7 @@ public class MqttDataConnector {
                         " }\n" +
                         "}");
                 Thread.sleep(5000);
+                xbMqttDataConnector.destroy();
             }
 
         }catch ( Exception e) {

src/main/resources/application-prod.properties

@@ -39,7 +39,8 @@ device.3d.url.host=https://www.ventropic.com
 device.3d.url.path=/rt/dist/#/?topic=
 
 ############# 设备MQTT消息配置 #####################
-mqtt.broker=www.rfcare.cn
+#mqtt.broker=www.rfcare.cn
+mqtt.broker=172.21.0.11
 mqtt.port=8083
 mqtt.username=test
 mqtt.password=public