five-groups
/
five-groups-couplet
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

虎虎虎虎

server_five_liuyunhu
liuyunhu 2024-04-02 14:46:36 +08:00
parent c3aee00eff
commit 08aec277e6
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
couplet-modules/couplet-modules-onLine/src/main/java/com/couplet/online/utils/MqttMonitor.java
View File

@ -86,11 +86,23 @@ public class MqttMonitor {
@Override @Override
public void messageArrived(String topic, MqttMessage mqttMessage) { public void messageArrived(String topic, MqttMessage mqttMessage) {
log.info("消息已送达"); // log.info("消息已送达");
log.info("接收消息主题：{}",topic); // log.info("接收消息主题：{}",topic);
log.info("接收消息qos：{}", mqttMessage.getQos()); // log.info("接收消息qos：{}", mqttMessage.getQos());
//接收到的原始报文
String message = new String(mqttMessage.getPayload());
log.info("接收消息原始内容：{}", message);
//去除空格 得到16进制字符串
String replaced = message.replaceAll(" ", "");
log.info("接收消息剪切后内容：{}", replaced);
log.info("接收消息内容：{}", new String(mqttMessage.getPayload()));
} }
@Override @Override