From f4aa3e0ee8c988c0d7535ad1c76e68e23e400194 Mon Sep 17 00:00:00 2001 From: 648540858 <18010473990@163.com> Date: 星期日, 08 八月 2021 09:18:45 +0800 Subject: [PATCH] 修复自动点播 --- src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java | 33 ++++++++++++++++++++++----------- 1 files changed, 22 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java b/src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java index 7a57bed..f65a155 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java +++ b/src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java @@ -1,10 +1,9 @@ package com.genersoft.iot.vmp.service; -import com.genersoft.iot.vmp.conf.MediaConfig; import com.genersoft.iot.vmp.gb28181.bean.Device; import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig; -import com.genersoft.iot.vmp.media.zlm.dto.IMediaServerItem; import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; +import com.genersoft.iot.vmp.service.bean.SSRCInfo; import java.util.List; @@ -13,11 +12,15 @@ */ public interface IMediaServerService { - List<IMediaServerItem> getAll(); + List<MediaServerItem> getAll(); - IMediaServerItem getOne(String generalMediaServerId); + List<MediaServerItem> getAllFromDatabase(); - IMediaServerItem getOneByHostAndPort(String host, int port); + List<MediaServerItem> getAllOnline(); + + MediaServerItem getOne(String generalMediaServerId); + + MediaServerItem getOneByHostAndPort(String host, int port); /** * 鏂扮殑鑺傜偣鍔犲叆 @@ -26,19 +29,27 @@ */ void handLeZLMServerConfig(ZLMServerConfig zlmServerConfig); - void updateServerCatch(IMediaServerItem mediaServerItem, Integer count, Boolean b); + MediaServerItem getMediaServerForMinimumLoad(); - IMediaServerItem getMediaServerForMinimumLoad(); + void setZLMConfig(MediaServerItem mediaServerItem); - void setZLMConfig(IMediaServerItem mediaServerItem); - - void init(); + SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId); void closeRTPServer(Device device, String channelId); - void update(MediaConfig mediaConfig); + void clearRTPServer(MediaServerItem mediaServerItem); + + void update(MediaServerItem mediaSerItem); void addCount(String mediaServerId); void removeCount(String mediaServerId); + + void releaseSsrc(MediaServerItem mediaServerItem, String ssrc); + + void clearMediaServerForOnline(); + + void add(MediaServerItem mediaSerItem); + + void resetOnlineServerItem(MediaServerItem serverItem); } -- Gitblit v1.8.0