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

zhaowenyu

2025-11-12 677748a0508a91f9423cae558f1bdee5d83ac131

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

@@ -55,15 +55,12 @@
                    RedisOpsUtils.set(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn, resultLive);
                }
            }
            _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive);
            log.info("SN: {}-直播地址：{}", sn, resultLive);
        } catch (Exception e) {
            log.info("SN: {}-开启直播失败！原因：{}", sn, e.getMessage());
            resultLive = getResult(sn, "开启直播失败！原因：" + e.getMessage());
//            _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), jsonString);
            e.printStackTrace();
        }

        _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive);
        log.info("SN: {}-直播地址：{}", sn, resultLive);
    }

    public void StopLiveStreaming(String sn) {
@@ -84,7 +81,6 @@
            e.printStackTrace();
        }
        // 停止直播不返回数据，直接删除redis中的直播地址标记即可；并且方法在websocket连接断开后执行。
        //_dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive);
    }

    public String getResult(String sn, String msg) {