优化

liusuyi

2026-06-01 a2e7e8ff9cfaa69b001d483710bddbda50d55c91

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
package com.ard.gb28181.session;
 
import com.ard.gb28181.common.VideoManagerConstants;
import com.ard.gb28181.config.UserSetting;
import com.ard.gb28181.api.domain.SsrcTransaction;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
 
import java.util.ArrayList;
import java.util.List;
 
/**
 * 视频流session管理器，管理视频预览、预览回放的通信句柄
 */
@Component
public class SipInviteSessionManager {
 
    @Autowired
    private UserSetting userSetting;
 
    @Autowired
    private RedisTemplate<Object, Object> redisTemplate;
 
    /**
     * 添加一个点播/回放的事务信息
     */
    public void put(SsrcTransaction ssrcTransaction){
        redisTemplate.opsForHash().put(VideoManagerConstants.SIP_INVITE_SESSION_STREAM + userSetting.getServerId()
                , ssrcTransaction.getApp() + ssrcTransaction.getStream(), ssrcTransaction);
 
        redisTemplate.opsForHash().put(VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId()
                , ssrcTransaction.getCallId(), ssrcTransaction);
    }
 
    public SsrcTransaction getSsrcTransactionByStream(String app, String stream){
        String key = VideoManagerConstants.SIP_INVITE_SESSION_STREAM + userSetting.getServerId();
        return (SsrcTransaction)redisTemplate.opsForHash().get(key, app + stream);
    }
 
    public SsrcTransaction getSsrcTransactionByCallId(String callId){
        String key = VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId();
        return (SsrcTransaction)redisTemplate.opsForHash().get(key, callId);
    }
 
    public List<SsrcTransaction> getSsrcTransactionByDeviceId(String deviceId){
        String key = VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId();
        List<Object> values = redisTemplate.opsForHash().values(key);
        List<SsrcTransaction> result = new ArrayList<>();
        for (Object value : values) {
            SsrcTransaction ssrcTransaction = (SsrcTransaction) value;
            if (ssrcTransaction != null && deviceId.equals(ssrcTransaction.getDeviceId())) {
                result.add(ssrcTransaction);
            }
        }
        return result;
    }
    
    public void removeByStream(String app, String stream) {
        SsrcTransaction ssrcTransaction = getSsrcTransactionByStream(app, stream);
        if (ssrcTransaction == null ) {
            return;
        }
        redisTemplate.opsForHash().delete(VideoManagerConstants.SIP_INVITE_SESSION_STREAM + userSetting.getServerId(), app + stream);
        if (ssrcTransaction.getCallId() != null) {
            redisTemplate.opsForHash().delete(VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId(), ssrcTransaction.getCallId());
        }
    }
 
    public void removeByCallId(String callId) {
        SsrcTransaction ssrcTransaction = getSsrcTransactionByCallId(callId);
        if (ssrcTransaction == null ) {
            return;
        }
        redisTemplate.opsForHash().delete(VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId(), callId);
        if (ssrcTransaction.getStream() != null) {
            redisTemplate.opsForHash().delete(VideoManagerConstants.SIP_INVITE_SESSION_STREAM + userSetting.getServerId(), ssrcTransaction.getApp() + ssrcTransaction.getStream());
        }
    }
 
    public List<SsrcTransaction> getAll() {
        String key = VideoManagerConstants.SIP_INVITE_SESSION_CALL_ID + userSetting.getServerId();
        List<Object> values = redisTemplate.opsForHash().values(key);
        List<SsrcTransaction> result = new ArrayList<>();
        for (Object value : values) {
            result.add((SsrcTransaction) value);
        }
        return result;
    }
}