适配zlm的hook保活

648540858

2021-12-07 9b1af8ef1396de45884fe86c56844714045b82ec

 src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java

@@ -5,6 +5,7 @@
import com.alibaba.fastjson.TypeReference;
import com.genersoft.iot.vmp.gb28181.bean.GbStream;
import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils;
import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig;
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;
@@ -84,6 +85,7 @@
        streamPushItem.setCreateStamp(item.getCreateStamp());
        streamPushItem.setAliveSecond(item.getAliveSecond());
        streamPushItem.setStatus(true);
        streamPushItem.setStreamType("push");
        streamPushItem.setVhost(item.getVhost());
        return streamPushItem;
    }
@@ -134,4 +136,18 @@
        return true;
    }

    @Override
    public void zlmServerOnline(ZLMServerConfig zlmServerConfig) {
        // 似乎没啥需要做的
    }

    @Override
    public void zlmServerOffline(String mediaServerId) {
        // 移除没有serverId的推流
        streamPushMapper.deleteWithoutGBId(mediaServerId);
        // 其他的流设置未启用
        gbStreamMapper.updateStatusByMediaServerId(mediaServerId, false);
        // 移除redis内流的信息
        redisCatchStorage.removeStream(mediaServerId, "PUSH");
    }
}