断流后自动清除Redis中的播放条目

Lawrence

2020-10-29 eecffb51169300b9e226bd24bb0a0db10724a379

断流后自动清除Redis中的播放条目

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java

@@ -142,7 +142,7 @@
            storager.startPlay(streamInfoForPlay);

        }



        StreamInfo streamInfoForPlayBack = storager.queryPlayBlackBySSRC(ssrc);

        StreamInfo streamInfoForPlayBack = storager.queryPlaybackBySSRC(ssrc);

        if ("rtp".equals(app) && streamInfoForPlayBack != null ) {

            MediaServerConfig mediaInfo = storager.getMediaInfo();

            streamInfoForPlayBack.setFlv(String.format("http://%s:%s/rtp/%s.flv", mediaInfo.getLocalIP(), mediaInfo.getHttpPort(), streamId));

@@ -150,7 +150,7 @@
            streamInfoForPlayBack.setRtmp(String.format("rtmp://%s:%s/rtp/%s", mediaInfo.getLocalIP(), mediaInfo.getRtmpPort(), streamId));

            streamInfoForPlayBack.setHls(String.format("http://%s:%s/rtp/%s/hls.m3u8", mediaInfo.getLocalIP(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlayBack.setRtsp(String.format("rtsp://%s:%s/rtp/%s", mediaInfo.getLocalIP(), mediaInfo.getRtspPort(), streamId));

            storager.startPlayBlack(streamInfoForPlayBack);

            storager.startPlayback(streamInfoForPlayBack);

        }



        // TODO Auto-generated method stub

@@ -261,7 +261,12 @@
        String ssrc = new DecimalFormat("0000000000").format(Integer.parseInt(streamId, 16));

        StreamInfo streamInfo = storager.queryPlayBySSRC(ssrc);

        if ("rtp".equals(app) && !regist ) {

            storager.stopPlay(streamInfo);

            if (streamInfo!=null){

                storager.stopPlay(streamInfo);

            }else{

                streamInfo = storager.queryPlaybackBySSRC(ssrc);

                storager.stopPlayback(streamInfo);

            }

        }





@@ -288,6 +293,13 @@
        String ssrc = String.format("%010d", numb); 

        

        cmder.streamByeCmd(ssrc);

        StreamInfo streamInfo = storager.queryPlayBySSRC(ssrc);

        if (streamInfo!=null){

            storager.stopPlay(streamInfo);

        }else{

            streamInfo = storager.queryPlaybackBySSRC(ssrc);

            storager.stopPlayback(streamInfo);

        }

        

        JSONObject ret = new JSONObject();

        ret.put("code", 0);