| | |
| | | /** |
| | | * 订阅指定设备的数据 |
| | | */ |
| | | public void subscribe(String boxSn, Long userId,Integer period) { |
| | | public void subscribe(String boxSn, Long userId, Integer period) { |
| | | subscriptions.computeIfAbsent(boxSn, k -> new HashSet<>()).add(userId); |
| | | if (subscriptions.get(boxSn).size() == 1) { |
| | | startPushTask(boxSn,period); |
| | | startPushTask(boxSn, period); |
| | | } |
| | | } |
| | | |
| | |
| | | /** |
| | | * 启动推送任务 |
| | | */ |
| | | private void startPushTask(String boxSn,Integer period) { |
| | | private void startPushTask(String boxSn, Integer period) { |
| | | // 如果已经存在任务,则不再创建 |
| | | if (pushTasks.containsKey(boxSn)) { |
| | | return; |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 向订阅者发送数据 |
| | | */ |
| | |
| | | if (userIds != null) { |
| | | for (Long userId : userIds) { |
| | | try { |
| | | log.warn("给用户{}定时推送",userId); |
| | | log.debug("给用户{}定时推送", userId); |
| | | WebSocketUtil.sendMessage(userId, JSON.toJSONString(baseMessage)); |
| | | } catch (Exception e) { |
| | | log.error("Error sending message to session {}", userId, e); |