| | |
|---|
| | | } |
|---|
| | | JSONArray dataArray = jsonObject.getJSONArray("data"); |
|---|
| | | JSONObject mediaServerConfig = dataArray.getJSONObject(0); |
|---|
| | | if (ObjectUtils.isEmpty(param.getFfmpegCmdKey())) { |
|---|
| | | param.setFfmpegCmdKey("ffmpeg.cmd"); |
|---|
| | | } |
|---|
| | | String ffmpegCmd = mediaServerConfig.getString(param.getFfmpegCmdKey()); |
|---|
| | | if (ffmpegCmd == null) { |
|---|
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "ffmpeg拉流代理无法获取ffmpeg cmd"); |
|---|
| | |
|---|
| | | logger.info("启用代理失败： {}/{}->{}({})", app, stream, jsonObject.getString("msg"), |
|---|
| | | streamProxy.getSrcUrl() == null? streamProxy.getUrl():streamProxy.getSrcUrl()); |
|---|
| | | } |
|---|
| | | } else if (streamProxy != null && streamProxy.isEnable()) { |
|---|
| | | return true ; |
|---|
| | | } |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | |
|---|
| | | streamProxyMapper.deleteAutoRemoveItemByMediaServerId(mediaServerId); |
|---|
| | | |
|---|
| | | // 移除拉流代理生成的流信息 |
|---|
| | | // syncPullStream(mediaServerId); |
|---|
| | | syncPullStream(mediaServerId); |
|---|
| | | |
|---|
| | | // 恢复流代理, 只查找这个这个流媒体 |
|---|
| | | List<StreamProxyItem> streamProxyListForEnable = storager.getStreamProxyListForEnableInMediaServer( |
|---|
