adapter.git - Gitblit

			@@ -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视频流
			@@ -23,6 +35,8 @@
			//返回结果，通过配置文件即可反推得到前提是调用 rtsp/pull 接口成功
			private String jessibucaDemo="ws://localhost:8080/live/test.flv";

			//StreamPath 是发布流的唯一标识
			private String streamPath="live/test";

			// =========== monica监控 ===========

			@@ -37,7 +51,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 +64,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\"";
			}