diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java b/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java index 360472fb..b6c0dfc4 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java @@ -44,5 +44,6 @@ public class VideoStreamSessionManager { sessionMap.remove(deviceId + "_" + channelId); SsrcUtil.releaseSsrc(ssrcMap.get(deviceId + "_" + channelId)); ssrcMap.remove(deviceId + "_" + channelId); + streamIdMap.remove(deviceId + "_" + channelId); } } diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java index e0d0bf30..4263a787 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java @@ -581,8 +581,9 @@ public class SIPCommander implements ISIPCommander { if (transaction == null) { StreamInfo streamInfo = redisCatchStorage.queryPlayByDevice(deviceId, channelId); if (streamInfo != null) { - + redisCatchStorage.stopPlay(streamInfo); } + okEvent.response(null); return; } diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java index f9b6a35d..3d4c64c0 100644 --- a/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java +++ b/src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java @@ -99,8 +99,8 @@ public class PlayController { StreamInfo streamInfo = redisCatchStorage.queryPlayByDevice(deviceId, channelId); if (streamInfo == null) { RequestMessage msg = new RequestMessage(); - msg.setId(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid); - msg.setData("streamId not found"); + msg.setId(DeferredResultHolder.CALLBACK_CMD_STOP + uuid); + msg.setData("点播未找到"); resultHolder.invokeResult(msg); }else { redisCatchStorage.stopPlay(streamInfo);