| | |
| | | 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(); |
| | | |
| | | } |
| | | |
| | |
| | | //ResponseData responseData = DeviceMessageParser.parseResponseData(new String(message.getPayload()));//解析响应数据 |
| | | String gpsRaw = gpsData.getGps_raw(); |
| | | UDPServer.processSerialData(gpsRaw); |
| | | gecaojistatus.parseStatus(gpsData.getStatus()); |
| | | } |
| | | |
| | | } |