优化多线程参数

648540858

2021-11-25 be7082f5e21aaab0ef541d9a78ced7eaebcfb1f7

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMMediaListManager.java

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

import com.alibaba.fastjson.JSONObject;
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.StreamProxyItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
@@ -16,7 +17,6 @@

import java.util.*;

@SuppressWarnings("unchecked")
@Component
public class ZLMMediaListManager {

@@ -88,6 +88,10 @@
        updateMedia(mediaServerItem, app, streamId);
    }

    public void addMedia(MediaItem mediaItem) {
        storager.updateMedia(streamPushService.transform(mediaItem));
    }


    public void updateMedia(MediaServerItem mediaServerItem, String app, String streamId) {
        //使用异步更新推流
@@ -114,14 +118,16 @@
    }


    public void removeMedia(String app, String streamId) {
    public int removeMedia(String app, String streamId) {
        // 查找是否关联了国标， 关联了不删除， 置为离线
        StreamProxyItem streamProxyItem = gbStreamMapper.selectOne(app, streamId);
        int result = 0;
        if (streamProxyItem == null) {
            storager.removeMedia(app, streamId);
            result = storager.removeMedia(app, streamId);
        }else {
            storager.mediaOutline(app, streamId);
            result =storager.mediaOutline(app, streamId);
        }
        return result;
    }

//    public void clearAllSessions() {