package com.ruoyi.jianguan.mqtt.callback;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.common.core.utils.HttpUtils;
|
import com.ruoyi.common.core.utils.StringUtils;
|
import com.ruoyi.jianguan.mqtt.config.TopicConstants;
|
import com.ruoyi.system.api.domain.SysRole;
|
import lombok.extern.slf4j.Slf4j;
|
import org.eclipse.paho.client.mqttv3.*;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
|
import javax.annotation.PostConstruct;
|
import java.time.LocalDate;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.UUID;
|
import java.util.concurrent.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 消费监听
|
*/
|
@Slf4j
|
@Component
|
public class PushCallback implements MqttCallback {
|
private static MqttConnectOptions options;
|
private static MqttClient client;
|
private static final double EARTH_RADIUS = 6378137.0;
|
|
|
@Override
|
public void connectionLost(Throwable throwable) {
|
if (client == null || !client.isConnected()) {
|
System.out.println("连接断开，正在重连....");
|
int[] Qos = {0};
|
String[] topic1 = {TopicConstants.GPS_LOCATION};
|
try {
|
client.connect(options);
|
client.subscribe(topic1, Qos);
|
log.info("连接失败重连成功");
|
} catch (MqttException e) {
|
log.info("连接失败重连失败");
|
log.info("connectionLost e:{}", e.getMessage());
|
}
|
}
|
}
|
|
@Override
|
public void messageArrived(String topic, MqttMessage message) throws Exception {
|
System.err.println("接收消息主题 : " + topic);
|
System.err.println("接收消息Qos : " + message.getQos());
|
System.err.println("接收消息内容 : " + new String(message.getPayload()));
|
|
String silentMessage = new String(message.getPayload());
|
JSONObject jsonObject = JSONObject.parseObject(silentMessage);
|
String messageType = jsonObject.getString("type");
|
if(StringUtils.isEmpty(messageType)){
|
log.warn("接收消息类型为空");
|
}
|
}
|
|
@Override
|
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
|
|
}
|
|
}
|
