Administrator
/
FenXiNspJavaMain
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新mqtt支持

This commit is contained in:
zy 2025-12-20 09:54:40 +08:00
parent d30d564edd
commit 0a8d1e6681
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java
View File

@ -103,9 +103,9 @@ public class MyMqttCallback implements MqttCallbackExtended {
if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) { if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) {
log.warn("fe-check=======================" + mqttMessage.getPayload()); log.warn("fe-check=======================" + mqttMessage.getPayload());
//识别主题，确认设备 todo 处理消息逻辑 //识别主题，确认设备 todo 处理消息逻辑
} else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑 } else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑
//暂时无业务 //暂时无业务
} else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑，处理控制 } else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑，处理控制
// 尝试获取锁，等待3秒，重试间隔100ms // 尝试获取锁，等待3秒，重试间隔100ms
try { try {
// Boolean lock = RedisDistributedLock2.getLock("mqtt_receive_logic:__"+topic+"_"+o1.hashCode(),2); // Boolean lock = RedisDistributedLock2.getLock("mqtt_receive_logic:__"+topic+"_"+o1.hashCode(),2);