From 89a9ab4534f10a224f70e546db838423e84a1965 Mon Sep 17 00:00:00 2001 From: 64850858 <648540858@qq.com> Date: 星期五, 16 七月 2021 16:34:51 +0800 Subject: [PATCH] 添加zlm集群支持 --- src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java | 16 +++++++++++++++- 1 files changed, 15 insertions(+), 1 deletions(-) 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 b6c0dfc..9e402e1 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 @@ -42,8 +42,22 @@ public void remove(String deviceId, String channelId) { sessionMap.remove(deviceId + "_" + channelId); - SsrcUtil.releaseSsrc(ssrcMap.get(deviceId + "_" + channelId)); + if (ssrcMap.get(deviceId + "_" + channelId) != null) { + SsrcUtil.releaseSsrc(ssrcMap.get(deviceId + "_" + channelId)); + } ssrcMap.remove(deviceId + "_" + channelId); streamIdMap.remove(deviceId + "_" + channelId); } + + public ConcurrentHashMap<String, ClientTransaction> getSessionMap() { + return sessionMap; + } + + public ConcurrentHashMap<String, String> getSsrcMap() { + return ssrcMap; + } + + public ConcurrentHashMap<String, String> getStreamIdMap() { + return streamIdMap; + } } -- Gitblit v1.8.0