处理iot链接超时问题

yangys

2024-10-08 ba9557b5edf7f31ab8bce0ae57aaaaefd6459bb4

 collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java

@@ -27,12 +27,12 @@
   @Autowired
   private  RedisUtil redisUtil;
   /**
    * 处理收到的消息
    * 处理收到的消息,对应TelemetryDataPostingConsumer
    * @param payload
    */
   public void handle(String payload) {
        //System.out.println("Received message122: " + payload);
        //解析消息未
        //解析消息
        List<TelemetryData> teleList = parsePayload(payload);
        
        collectDataService.handleCollectData(teleList);
@@ -86,13 +86,15 @@
        return dtList;
   }
   
   /**
    * 根据对应表缓存，获取appId对应的id
    * @param appId
    * @return
    */
   public long getWorkstationIdByAppId(String appId) {
      /**
       * 1656818952295661569 461
1656819188967653378  462
       */

      Object wid = redisUtil.hget("workstation-appid-map", appId);
      String workstationId = String.valueOf(Optional.ofNullable(wid).orElse("-1"));
      String workstationId = String.valueOf(Optional.ofNullable(wid).orElse(appId));
   
      return Long.parseLong(workstationId);
   }