2025-11-8 zwy 优化websocket代码,在最后一个订阅视频的用户断开后,机场停止视频直播

zhaowenyu

2025-11-12 677748a0508a91f9423cae558f1bdee5d83ac131

 ard-sample/src/main/java/com/ard/sample/component/websocket/handler/LiveStreamHandler.java

@@ -53,11 +53,10 @@
                    rlive.setType(MessageType.LIVESTREAM.getType());
                    resultLive = _objectMapper.writeValueAsString(rlive);
                    RedisOpsUtils.set(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn, resultLive);

                    _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive);
                    log.info("SN: {}-直播地址：{}", sn, resultLive);
                }
            }
            _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive);
            log.info("SN: {}-直播地址：{}", sn, resultLive);
        } catch (Exception e) {
            log.info("SN: {}-开启直播失败！原因：{}", sn, e.getMessage());
            e.printStackTrace();