From 968ec879f50f80768d12937a24f1f9eeb364a874 Mon Sep 17 00:00:00 2001 From: lawrencehj <1934378145@qq.com> Date: 星期日, 14 三月 2021 21:23:47 +0800 Subject: [PATCH] 修正本地平台播放时上级无法点播同一流视频的问题 --- src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java | 38 +++++++++++++++++++++++++++++++++++++- 1 files changed, 37 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java index 775cb0f..42670a7 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java +++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRESTfulUtils.java @@ -11,7 +11,6 @@ import java.io.IOException; import java.net.ConnectException; import java.util.HashMap; -import java.util.HashSet; import java.util.Map; @Component @@ -74,10 +73,35 @@ return sendPost("getMediaList",param); } + public JSONObject getMediaInfo(String app, String schema, String stream){ + Map<String, Object> param = new HashMap<>(); + param.put("app",app); + param.put("schema",schema); + param.put("stream",stream); + param.put("vhost","__defaultVhost__"); + return sendPost("getMediaInfo",param); + } + public JSONObject getRtpInfo(String stream_id){ Map<String, Object> param = new HashMap<>(); param.put("stream_id",stream_id); return sendPost("getRtpInfo",param); + } + + public JSONObject addFFmpegSource(String src_url, String dst_url, String timeout_ms){ + System.out.println(src_url); + System.out.println(dst_url); + Map<String, Object> param = new HashMap<>(); + param.put("src_url", src_url); + param.put("dst_url", dst_url); + param.put("timeout_ms", timeout_ms); + return sendPost("addFFmpegSource",param); + } + + public JSONObject delFFmpegSource(String key){ + Map<String, Object> param = new HashMap<>(); + param.put("key", key); + return sendPost("delFFmpegSource",param); } public JSONObject getMediaServerConfig(){ @@ -91,4 +115,16 @@ public JSONObject openRtpServer(Map<String, Object> param){ return sendPost("openRtpServer",param); } + + public JSONObject closeRtpServer(Map<String, Object> param) { + return sendPost("closeRtpServer",param); + } + + public JSONObject startSendRtp(Map<String, Object> param) { + return sendPost("startSendRtp",param); + } + + public JSONObject stopSendRtp(Map<String, Object> param) { + return sendPost("stopSendRtp",param); + } } -- Gitblit v1.8.0