新增mqtt相关功能

张世豪

2 天以前 c9b1d33979b3972fe6a82fa427b4ba9a20989112

 src/Mqttmessage/PushCallback.java

@@ -1,15 +1,13 @@
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 {


@@ -30,6 +28,7 @@
        //ResponseData responseData = DeviceMessageParser.parseResponseData(new String(message.getPayload()));//解析响应数据
        String gpsRaw = gpsData.getGps_raw();
        UDPServer.processSerialData(gpsRaw);
        gecaojistatus.parseStatus(gpsData.getStatus());
    }

}