648540858
2022-03-11 1c95f1b4aa45f5fbe16b3ff2e00c560dd5d84550
src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
@@ -3,8 +3,11 @@
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.media.zlm.dto.MediaItem;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
import com.genersoft.iot.vmp.service.bean.SSRCInfo;
import com.genersoft.iot.vmp.service.bean.ThirdPartyGB;
import java.util.List;
@@ -86,7 +89,7 @@
     * @param channelId
     * @return sendRtpItem
     */
    SendRtpItem querySendRTPServer(String platformGbId, String channelId);
    SendRtpItem querySendRTPServer(String platformGbId, String channelId, String streamId, String callId);
    List<SendRtpItem> querySendRTPServer(String platformGbId);
@@ -95,7 +98,7 @@
     * @param platformGbId
     * @param channelId
     */
    void deleteSendRTPServer(String platformGbId, String channelId);
    void deleteSendRTPServer(String platformGbId, String channelId, String callId, String streamId);
    /**
     * 查询某个通道是否存在上级点播(RTP推送)
@@ -143,7 +146,7 @@
     * @param app
     * @param streamId
     */
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, StreamInfo streamInfo);
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, MediaItem item);
    /**
     * 移除流信息从redis
@@ -175,7 +178,7 @@
     */
    ThirdPartyGB queryMemberNoGBId(String queryKey);
    List<StreamInfo> getStreams(String mediaServerId, String pull);
    List<MediaItem> getStreams(String mediaServerId, String pull);
    /**
     * 将device信息写入redis
@@ -201,9 +204,12 @@
    void resetAllSN();
    void updateSubscribe(String key, SubscribeInfo subscribeInfo);
    MediaItem getStreamInfo(String app, String streamId, String mediaServerId);
    SubscribeInfo getSubscribe(String key);
    void addCpuInfo(double cpuInfo);
    void delSubscribe(String key);
    void addMemInfo(double memInfo);
    void addNetInfo(Map<String, String> networkInterfaces);
}