使用线程安全的map存储订阅信息 修改点播消息内容,提升兼容性

648540858

2020-12-14 3d2aeb890b0d6bc13ea44ff6e0d5764bcf7aa529

 src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java

@@ -1,6 +1,7 @@
package com.genersoft.iot.vmp.storager;



import java.util.List;

import java.util.Map;



import com.alibaba.fastjson.JSONObject;

import com.genersoft.iot.vmp.common.PageResult;

@@ -136,30 +137,24 @@
   /**

    * 开始播放时将流存入

    *

    * @param deviceId 设备ID

    * @param channelId 通道ID

    * @param stream 流信息

    * @return

    */

   public boolean startPlay(String deviceId, String channelId, StreamInfo stream);

   public boolean startPlay(StreamInfo stream);



   /**

    * 停止播放时删除

    *

    * @param deviceId 设备ID

    * @param channelId 通道ID

    * @return

    */

   public boolean stopPlay(String deviceId, String channelId);

   public boolean stopPlay(StreamInfo streamInfo);



   /**

    * 查找视频流

    *

    * @param deviceId 设备ID

    * @param channelId 通道ID

    * @return

    */

   public StreamInfo queryPlay(String deviceId, String channelId);

   public StreamInfo queryPlay(StreamInfo streamInfo);



   /**

    * 查询子设备

@@ -176,4 +171,24 @@
    * 更新缓存

    */

   public void updateCatch();



   /**

    * 清空通道

    * @param deviceId

    */

   void cleanChannelsForDevice(String deviceId);



   StreamInfo queryPlayBySSRC(String ssrc);



   StreamInfo queryPlayByDevice(String deviceId, String code);



   Map<String, StreamInfo> queryPlayByDeviceId(String deviceId);



   boolean startPlayback(StreamInfo streamInfo);



   boolean stopPlayback(StreamInfo streamInfo);



   StreamInfo queryPlaybackByDevice(String deviceId, String channelId);



   StreamInfo queryPlaybackBySSRC(String ssrc);

}