| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Slf4j(topic = "mqttCar") |
|---|
| | | public class MessageCallback implements MqttCallback { |
|---|
| | | |
|---|
| | | private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
|---|
| | |
|---|
| | | @Override//消息订阅者收到消息后触发的回调 |
|---|
| | | public void messageArrived(String topic, MqttMessage message) throws Exception { |
|---|
| | | try { |
|---|
| | | log.info("【车辆锁主题】："+topic+"【车辆锁信息】："+new String(message.getPayload(), StandardCharsets.UTF_8)); |
|---|
| | | log.debug("【车辆锁主题】："+topic+"【车辆锁信息】："+new String(message.getPayload(), StandardCharsets.UTF_8)); |
|---|
| | | //出来回调数据 |
|---|
| | | List<ArdSyCarLock> ardSyCarLocks = carLockService.data(new String(message.getPayload(), StandardCharsets.UTF_8)); |
|---|
| | | //根据topic查询RTUID |
|---|
