添加推流列表和拉流代理，下一步与国标关联

panlinlin

2021-03-30 56859d09df8d4226882d43934acf32d60a3b51d7

 src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java

@@ -15,6 +15,7 @@
public class VideoStreamSessionManager {



   private ConcurrentHashMap<String, ClientTransaction> sessionMap = new ConcurrentHashMap<>();

   private ConcurrentHashMap<String, String> ssrcMap = new ConcurrentHashMap<>();



   public String createPlaySsrc(){

      return SsrcUtil.getPlaySsrc();

@@ -24,16 +25,18 @@
      return SsrcUtil.getPlayBackSsrc();

   }

   

   public void put(String ssrc,ClientTransaction transaction){

      sessionMap.put(ssrc, transaction);

   public void put(String streamId,String ssrc,ClientTransaction transaction){

      sessionMap.put(streamId, transaction);

      ssrcMap.put(streamId, ssrc);

   }

   

   public ClientTransaction get(String ssrc){

      return sessionMap.get(ssrc);

   public ClientTransaction get(String streamId){

      return sessionMap.get(streamId);

   }

   

   public void remove(String ssrc) {

      sessionMap.remove(ssrc);

      SsrcUtil.releaseSsrc(ssrc);

   public void remove(String streamId) {

      sessionMap.remove(streamId);

      SsrcUtil.releaseSsrc(ssrcMap.get(streamId));

      ssrcMap.remove(streamId);

   }

}