提交MQTT相关功能

jiazx0107@163.com

2023-11-08 a31a452b9999ba3c811c36b5cb1b3ec0c18d037d

 src/main/java/com/fzzy/gateway/hx2023/websocket/WebSocketDeviceReport.java

@@ -14,7 +14,7 @@
import java.util.concurrent.ConcurrentHashMap;

/**
 * 设备恢复信息的WEBSOCKET
 * 基于前端 websocket 订阅地磅数据 topic:
 */
@Slf4j
@Component
@@ -113,8 +113,7 @@

            packet.getHeaders().setProductId(productId);


            log.debug("----------返回信息-----{}", packet);
            log.debug("----------websocket返回信息-----{}", packet);

            if (key.indexOf(tag) != -1) {
                session = sessionPool.get(key);