648540858
2022-05-06 5d901b5e3f033e8b04e53420d68626cbd87431c8
src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java
@@ -1,5 +1,6 @@
package com.genersoft.iot.vmp.service;
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
@@ -21,24 +22,33 @@
    MediaServerItem getOne(String generalMediaServerId);
    MediaServerItem getOneByHostAndPort(String host, int port);
    void syncCatchFromDatabase();
    /**
     * 新的节点加入
     * @param zlmServerConfig
     * @return
     */
    void handLeZLMServerConfig(ZLMServerConfig zlmServerConfig);
    void zlmServerOnline(ZLMServerConfig zlmServerConfig);
    /**
     * 节点离线
     * @param mediaServerId
     * @return
     */
    void zlmServerOffline(String mediaServerId);
    MediaServerItem getMediaServerForMinimumLoad();
    void setZLMConfig(MediaServerItem mediaServerItem);
    void setZLMConfig(MediaServerItem mediaServerItem, boolean restart);
    SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId);
    void updateVmServer(List<MediaServerItem>  mediaServerItemList);
    SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId, boolean isPlayback);
    SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId, boolean ssrcCheck);
    void closeRTPServer(Device device, String channelId);
    SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId, String ssrc, boolean ssrcCheck, boolean isPlayback);
    void closeRTPServer(String deviceId, String channelId, String ssrc);
    void clearRTPServer(MediaServerItem mediaServerItem);
@@ -48,11 +58,15 @@
    void removeCount(String mediaServerId);
    void releaseSsrc(MediaServerItem mediaServerItem, String ssrc);
    void releaseSsrc(String mediaServerItemId, String ssrc);
    void clearMediaServerForOnline();
    WVPResult<String> add(MediaServerItem mediaSerItem);
    int addToDatabase(MediaServerItem mediaSerItem);
    int updateToDatabase(MediaServerItem mediaSerItem);
    void resetOnlineServerItem(MediaServerItem serverItem);
@@ -61,4 +75,10 @@
    boolean checkMediaRecordServer(String ip, int port);
    void delete(String id);
    void deleteDb(String id);
    MediaServerItem getDefaultMediaServer();
    void updateMediaServerKeepalive(String mediaServerId, JSONObject data);
}