From fa92d56ae9d27343df39c92b799f727c11f090b6 Mon Sep 17 00:00:00 2001
From: xc <xucheng@yyigou.com>
Date: Mon, 22 Feb 2021 16:22:11 +0800
Subject: [PATCH] 补充Monica API
---
src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java | 217 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 213 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java b/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java
index 772e423..8ff5add 100644
--- a/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java
+++ b/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java
@@ -2,19 +2,31 @@
import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
+import com.hbbh.adapter.dto.StreamDto;
import com.hbbh.adapter.manager.MonibucaManager;
import com.hbbh.adapter.utils.HttpClientUtil;
-import com.hbbh.adapter.vo.CallResult;
-import com.hbbh.adapter.vo.MessageVO;
import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
-import java.util.LinkedHashMap;
+import java.util.List;
import java.util.Map;
@Service
public class MonibucaManagerImpl implements MonibucaManager {
+
+ private static final Logger log = LoggerFactory.getLogger(Class.class);
+
+
+ @Value("${monica.ip}")
+ private String monicaIP;
+ @Value("${monica.port}")
+ private String monicaPort;
+ @Value("${monica.rtsp.port}")
+ private String monicaRTSPPort;
//入参 rtsp视频流
@@ -22,6 +34,9 @@
//返回结果，通过配置文件即可反推得到 前提是调用 rtsp/pull 接口成功
private String jessibucaDemo="ws://localhost:8080/live/test.flv";
+
+ //StreamPath 是发布流的唯一标识
+ private String streamPath="live/test";
// =========== monica监控 ===========
@@ -37,7 +52,7 @@
String url="http://localhost:8081/rtsp/pull";
Map<String, String> params = Maps.newLinkedHashMap();
params.put("target",rtspDemo);
- params.put("streamPath","live/test");
+ params.put("streamPath",streamPath);
String result = HttpClientUtil.doGet(url, params);
@@ -50,4 +65,198 @@
}
return jessibucaDemo;
}
+
+ /**
+ *
+ * @param param StreamPath 是发布流的唯一标识
+ * 示例： http://localhost:8081/api/stop?stream=live/test
+ */
+ @Override
+ public void stopStream(String param) {
+ String url="http://"+monicaIP+":"+monicaRTSPPort+"/api/stop";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("stream",param);
+ String result = HttpClientUtil.doGet(url, params);
+ log.info("调用 Monibuca -stopStream- 执行结果 ： {}",result);
+ }
+
+ /**
+ * GET
+ * @param param 推流入参
+ */
+ @Override
+ public void pullStream(StreamDto param) {
+ String url="http://"+monicaIP+":"+monicaRTSPPort+"/rtsp/pull";
+ Map<String, String> params = Maps.newLinkedHashMap();
+
+ String streamPath = param.getStreamPath();
+ String target = param.getTarget();
+
+ params.put("target",target);
+ params.put("streamPath",streamPath);
+ String result = HttpClientUtil.doGet(url, params);
+ log.info("调用 Monibuca -pullStream- 执行结果 ： {}",result);
+ }
+
+ /**
+ * GET
+ * @param params 推流入参
+ */
+ @Override
+ public void pullStreamList(List<StreamDto> params) {
+ String url="http://"+monicaIP+":"+monicaRTSPPort+"/rtsp/pull";
+
+ for (StreamDto param : params) {
+ Map<String, String> paramMap = Maps.newLinkedHashMap();
+
+ String streamPath = param.getStreamPath();
+ String target = param.getTarget();
+
+ paramMap.put("target",target);
+ paramMap.put("streamPath",streamPath);
+ String result = HttpClientUtil.doGet(url, paramMap);
+ log.info("调用 Monibuca -pullStreamList- streamPath:{} 执行结果 ： {}",streamPath,result);
+ }
+ }
+
+ /**
+ * GET
+ * @param param Monica启动实例名称
+ */
+ @Override
+ public void instanceUpdate(String param) {
+ String url="http://"+monicaIP+":"+monicaPort+"/api/instance/update";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("name",param);
+ String result = HttpClientUtil.doGet(url, params);
+ log.info("调用 Monibuca -instanceUpdate- 执行结果 ： {}",result);
+ }
+
+ /**
+ * DELETE
+ * @param param Monica启动实例名称
+ */
+ @Override
+ public void instanceRemove(String param) {
+ String url="http://"+monicaIP+":"+monicaPort+"/api/instance/remove";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("name",param);
+ String result = HttpClientUtil.doDelete(url, params);
+ log.info("调用 Monibuca -instanceRemove- 执行结果 ： {}",result);
+ }
+
+ /**
+ * POST
+ * @param param Monica启动实例名称
+ */
+ @Override
+ public void instanceKill(String param) {
+ String url="http://"+monicaIP+":"+monicaPort+"/api/instance/kill";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("name",param);
+ String result = HttpClientUtil.doPost(url, params);
+ log.info("调用 Monibuca -instanceKill- 执行结果 ： {}",result);
+ }
+
+ /**
+ * POST
+ * @param param Monica启动实例名称
+ */
+ @Override
+ public void instanceStart(String param) {
+ String url="http://"+monicaIP+":"+monicaPort+"/api/instance/start";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("name",param);
+ String result = HttpClientUtil.doPost(url, params);
+ log.info("调用 Monibuca -instanceStart- 执行结果 ： {}",result);
+ }
+
+ @Override
+ public void instanceCreate() {
+ String url="http://"+monicaIP+":"+monicaPort+"/api/instance/create";
+ Map<String, String> params = Maps.newLinkedHashMap();
+ params.put("path","/Users/xucheng/Downloads/store/live");
+ params.put("name","live");
+ params.put("info",info);
+ params.put("clear","true");
+ String result = HttpClientUtil.doGet(url, params);
+ log.info("调用 Monibuca -instanceCreate- 执行结果 ： {}",result);
+
+ }
+
+
+
+ private String info="[Monibuca]\n" +
+ "# 是否等待流，如果为true则订阅一个尚未发布的流会进入等待发布的状态，否则返回订阅失败\n" +
+ "EnableWaitStream = true\n" +
+ "EnableAudio = true\n" +
+ "EnableVideo = true\n" +
+ "# 缓冲环大小默认是2的10次方\n" +
+ "RingSize = 10\n" +
+ "# 发布流默认过期时间 1分钟\n" +
+ "PublishTimeout = 60000000000\n" +
+ "[RTMP]\n" +
+ "ListenAddr = \":1935\"\n" +
+ "[GateWay]\n" +
+ "ListenAddr = \":8081\"\n" +
+ "[Jessica]\n" +
+ "ListenAddr = \":8080\"\n" +
+ "[LogRotate]\n" +
+ "# 日志存储目录相对或绝对\n" +
+ "Path = \"logs\"\n" +
+ "# 日志是否按大小分割，0表示不按大小分割，非零代表按该大小字节进行分割\n" +
+ "Size = 0\n" +
+ "Days = 1\n" +
+ "[Cluster]\n" +
+ "# 监听端口代表该服务器为源服务器\n" +
+ "ListenAddr = \":2019\"\n" +
+ "# 源服务器地址，用于向源服务器进行推或拉流\n" +
+ "OriginServer = \"\"\n" +
+ "# 推送模式，true表示如果此服务器有发布流，就会推送到源服务器，否则表示拉模式，即如果此服务器有订阅流则从源服务器拉流\n" +
+ "Push = true\n" +
+ "[HLS]\n" +
+ "# 是否开启写磁盘，开启后侦测到发布流就会开始写TS文件\n" +
+ "EnableWrite = false\n" +
+ "# 是否打开内存模式，在内存中保留TS数据，方便直接读取\n" +
+ "EnableMemory = false\n" +
+ "# 分片大小 单位秒\n" +
+ "Fragment = 10\n" +
+ "# 窗口数里，代表一个m3u8文件里面有几个ts\n" +
+ "Window = 2\n" +
+ "# ts文件存放目录，m3u8会存放在上一级\n" +
+ "Path = \"resource\"\n" +
+ "[HDL]\n" +
+ "ListenAddr = \":2020\"\n" +
+ "[TS]\n" +
+ "# 是否自动发布，开启后一旦有订阅流就会读取ts文件进行发布，方便测试\n" +
+ "AutoPublish = false\n" +
+ "# ts存放目录\n" +
+ "Path = \"resource\"\n" +
+ "[Record]\n" +
+ "Path = \"resource\"\n" +
+ "# 是否自动发布，开启后一旦有订阅流就会读取flv文件进行发布，方便测试\n" +
+ "AutoPublish = false\n" +
+ "# 自动录制功能\n" +
+ "AutoRecord = false\n" +
+ "[RTSP]\n" +
+ "ListenAddr = \":554\"\n" +
+ "AutoPull = true\n" +
+ "Reconnect = true\n" +
+ "RemoteAddr = \"rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov\"\n" +
+ "StreamPath = \"live/rtsp\"\n" +
+ "#[[RTSP.AutoPullList]]\n" +
+ "#URL = \"rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov\"\n" +
+ "#StreamPath = \"live/rtsp2\"\n" +
+ "[WebRTC]\n" +
+ "# 公网IP地址\n" +
+ "PublicIP = [\"127.0.0.1\"]\n" +
+ "# 端口范围不配置的话是自动分配\n" +
+ "# PortMin = 30000\n" +
+ "# PortMax = 40000\n" +
+ "[GB28181]\n" +
+ "Serial = \"34020000002000000001\"\n" +
+ "Realm = \"3402000000\"\n" +
+ "Expires = 3600\n" +
+ "AutoInvite = false\n" +
+ "ListenAddr = \"192.168.1.120:5060\"";
}
--
Gitblit v1.9.1