package Mqttmessage;
|
|
|
|
import Mqttmessage.Util.DeviceMessageParser;
|
import Mqttmessage.Entity.GPSData;
|
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("连接断开，可以做重连");
|
|
}
|
|
public void deliveryComplete(IMqttDeliveryToken token) {
|
System.out.println("deliveryComplete---------" + token.isComplete());
|
}
|
|
public void messageArrived(String topic, MqttMessage message) throws Exception {
|
// subscribe后得到的消息会执行到这里面
|
// System.out.println(message);
|
GPSData gpsData = DeviceMessageParser.parseGPSData(new String(message.getPayload()));//解析GNSS数据
|
//ResponseData responseData = DeviceMessageParser.parseResponseData(new String(message.getPayload()));//解析响应数据
|
String gpsRaw = gpsData.getGps_raw();
|
UDPServer.processSerialData(gpsRaw);
|
}
|
|
}
|
