swwheihei
2020-07-16 d8eeb707078153c374d4c1d7c832fa0107ff5c17
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
package com.genersoft.iot.vmp.gb28181.session;
 
import java.util.concurrent.ConcurrentHashMap;
 
import javax.sip.ClientTransaction;
 
import org.springframework.stereotype.Component;
 
/**    
 * @Description:视频流session管理器,管理视频预览、预览回放的通信句柄 
 * @author: swwheihei
 * @date:   2020年5月13日 下午4:03:02     
 */
@Component
public class VideoStreamSessionManager {
 
    private ConcurrentHashMap<String, ClientTransaction> sessionMap = new ConcurrentHashMap<>();
 
    public String createPlaySsrc(){
        String ssrc = SsrcUtil.getPlaySsrc();
        return ssrc;
    }
    
    public String createPlayBackSsrc(){
        String ssrc = SsrcUtil.getPlayBackSsrc();
        return ssrc;
    }
    
    public void put(String ssrc,ClientTransaction transaction){
        sessionMap.put(ssrc, transaction);
    }
    
    public ClientTransaction get(String ssrc){
        return sessionMap.get(ssrc);
    }
    
    public void remove(String ssrc) {
        sessionMap.remove(ssrc);
        SsrcUtil.releaseSsrc(ssrc);
    }
}