package com.hbbh.adapter.manager.impl;
|
|
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 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.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视频流
|
private String rtspDemo="rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov";
|
|
//返回结果，通过配置文件即可反推得到 前提是调用 rtsp/pull 接口成功
|
private String jessibucaDemo="ws://localhost:8080/live/test.flv";
|
|
//StreamPath 是发布流的唯一标识
|
private String streamPath="live/test";
|
|
|
// =========== monica监控 ===========
|
|
/**
|
* 调用Gateway API
|
* 成功返回 {"code":0}
|
* 失败返回 {"code":1,"msg":"publish badname"}
|
* @return jessibucaDemo
|
*/
|
@Override
|
public String parseVideo() {
|
String url="http://localhost:8081/rtsp/pull";
|
Map<String, String> params = Maps.newLinkedHashMap();
|
params.put("target",rtspDemo);
|
params.put("streamPath",streamPath);
|
|
String result = HttpClientUtil.doGet(url, params);
|
|
|
Map map = JSON.parseObject(result, Map.class);
|
String code = map.get("code")+"";
|
String msg = map.get("msg")+"";
|
if (!StringUtils.equals("0",code)){
|
return "-1";
|
}
|
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\"";
|
}
|
