张世豪
18 小时以前 a541fbdc8812337de120aad3792a2033a5dd7afe
src/Mqttmessage/PushCallback.java
@@ -1,21 +1,19 @@
package Mqttmessage;
import Mqttmessage.Util.DeviceMessageParser;
import gecaoji.gecaojistatus;
import Mqttmessage.Entity.GPSData;
import Mqttmessage.Entity.GPSData.StatusInfo;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import udpdell.UDPServer;
public class PushCallback implements MqttCallback {
    public void connectionLost(Throwable cause) {
        // 连接丢失后,一般在这里面进行重连
        System.out.println("连接断开,可以做重连");
      Client.lianjiemqqt();
    }
@@ -30,6 +28,7 @@
        //ResponseData responseData = DeviceMessageParser.parseResponseData(new String(message.getPayload()));//解析响应数据
        String gpsRaw = gpsData.getGps_raw();
        UDPServer.processSerialData(gpsRaw);
        gecaojistatus.parseStatus(gpsData.getStatus());
    }
}