package com.hbbh.adapter;
|
|
import com.google.common.collect.Maps;
|
import com.hbbh.adapter.utils.HttpClientUtil;
|
import org.junit.jupiter.api.Test;
|
|
import java.util.Map;
|
|
public class HttpClientUtilTest {
|
|
|
/**
|
* GET /api/instance/create?path=E:\store\live&name=live&info=%5BMonibuca%5D%0A%23%20%E6%98%AF%E5%90%A6%E7%AD%89%E5%BE%85%E6%B5%81%EF%BC%8C%E5%A6%82%E6%9E%9C%E4%B8%BAtrue%E5%88%99%E8%AE%A2%E9%98%85%E4%B8%80%E4%B8%AA%E5%B0%9A%E6%9C%AA%E5%8F%91%E5%B8%83%E7%9A%84%E6%B5%81%E4%BC%9A%E8%BF%9B%E5%85%A5%E7%AD%89%E5%BE%85%E5%8F%91%E5%B8%83%E7%9A%84%E7%8A%B6%E6%80%81%EF%BC%8C%E5%90%A6%E5%88%99%E8%BF%94%E5%9B%9E%E8%AE%A2%E9%98%85%E5%A4%B1%E8%B4%A5%0AEnableWaitStream%20%3D%20true%0AEnableAudio%20%3D%20true%0AEnableVideo%20%3D%20true%0A%23%20%E7%BC%93%E5%86%B2%E7%8E%AF%E5%A4%A7%E5%B0%8F%E9%BB%98%E8%AE%A4%E6%98%AF2%E7%9A%8410%E6%AC%A1%E6%96%B9%0ARingSize%20%3D%2010%0A%23%20%E5%8F%91%E5%B8%83%E6%B5%81%E9%BB%98%E8%AE%A4%E8%BF%87%E6%9C%9F%E6%97%B6%E9%97%B4%201%E5%88%86%E9%92%9F%0APublishTimeout%20%3D%2060000000000%0A%5BRTSP%5D%0A%23%20%E7%AB%AF%E5%8F%A3%E6%8E%A5%E6%94%B6%E6%8E%A8%E6%B5%81%0AListenAddr%20%3D%20%22%3A554%22%0A%23%20%E5%BC%80%E5%90%AF%E8%87%AA%E5%8A%A8%E6%8B%89%E6%B5%81%E5%90%8E%EF%BC%8C%E4%B8%80%E6%97%A6%E6%9C%89%E8%AE%A2%E9%98%85%E6%B5%81%EF%BC%8C%E5%B0%B1%E4%BC%9A%E4%BB%8ERemoteAddr%E8%BF%9B%E8%A1%8C%E6%8B%89%E6%B5%81%0AAutoPull%20%3D%20false%0AReconnect%20%3D%20true%0A%23%20%E8%BF%9C%E7%A8%8B%E5%9C%B0%E5%9D%80%E9%85%8D%E5%90%88AutoPull%E9%85%8D%E7%BD%AE%E8%B5%B7%E4%BD%9C%E7%94%A8%0ARemoteAddr%20%3D%20%22rtsp%3A%2F%2Fadmin%3Aadmin%40192.168.1.212%3A554%2Fcam%2Frealmonitor%3Fchannel%3D1%26subtype%3D1%22%0A%23%20%E5%8F%91%E5%B8%83%E6%B5%81%E7%9A%84%E5%90%8D%E7%A7%B0%E9%85%8D%E5%90%88AutoPull%E9%85%8D%E7%BD%AE%E8%B5%B7%E4%BD%9C%E7%94%A8%20%E8%BF%9C%E7%A8%8B%E6%8B%89%E6%B5%81%E5%90%8E%E5%9C%A8%E6%9C%AC%E5%9C%B0%E8%B5%B7%E7%9A%84%E6%B5%81%E5%90%8D%E7%A7%B0%0AStreamPath%20%3D%20%22live%2Frtsp%22%0A%23%5B%5BRTSP.AutoPullList%5D%5D%0A%23URL%20%3D%20%22rtsp%3A%2F%2Fadmin%3Aadmin%40192.168.1.212%3A554%2Fcam%2Frealmonitor%3Fchannel%3D1%26subtype%3D1%22%0A%23StreamPath%20%3D%20%22live%2Frtsp2%22&clear=true HTTP/1.1
|
* Host: 192.168.1.109:3000
|
* Connection: keep-alive
|
* Pragma: no-cache
|
* Cache-Control: no-cache
|
* Accept: text/event-stream
|
* User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/88.0.4324.96 Safari/537.36
|
* Referer: http://192.168.1.109:3000/
|
* Accept-Encoding: gzip, deflate
|
* Accept-Language: zh-CN,zh;q=0.9
|
*
|
* path: E:\store\live
|
* name: live
|
* info: [Monibuca]
|
* # 是否等待流，如果为true则订阅一个尚未发布的流会进入等待发布的状态，否则返回订阅失败
|
* EnableWaitStream = true
|
* EnableAudio = true
|
* EnableVideo = true
|
* # 缓冲环大小默认是2的10次方
|
* RingSize = 10
|
* # 发布流默认过期时间 1分钟
|
* PublishTimeout = 60000000000
|
* [RTSP]
|
* # 端口接收推流
|
* ListenAddr = ":554"
|
* # 开启自动拉流后，一旦有订阅流，就会从RemoteAddr进行拉流
|
* AutoPull = false
|
* Reconnect = true
|
* # 远程地址配合AutoPull配置起作用
|
* RemoteAddr = "rtsp://admin:admin@192.168.1.212:554/cam/realmonitor?channel=1&subtype=1"
|
* # 发布流的名称配合AutoPull配置起作用 远程拉流后在本地起的流名称
|
* StreamPath = "live/rtsp"
|
* #[[RTSP.AutoPullList]]
|
* #URL = "rtsp://admin:admin@192.168.1.212:554/cam/realmonitor?channel=1&subtype=1"
|
* #StreamPath = "live/rtsp2"
|
* clear: true
|
*/
|
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\"";
|
|
@Test
|
void init() {
|
String result = createInstance();
|
if (result.contains("success")){
|
startInstance();
|
}else {
|
//创建实例失败
|
System.out.println("创建实例失败");
|
}
|
}
|
|
/**
|
* 创建实例
|
* GET
|
*/
|
private String createInstance(){
|
String url="http://127.0.0.1:3000/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);
|
return result;
|
}
|
|
/**
|
* 启动实例
|
* POST
|
* http://localhost:3000/api/instance/start?name=live
|
*/
|
private void startInstance(){
|
String url="http://localhost:3000/api/instance/start?name=live";
|
String result = HttpClientUtil.doPost(url);
|
System.out.println(result);
|
}
|
|
/**
|
* 放入rtsp链接
|
* GET
|
* http://localhost:8081/rtsp/pull?
|
* target=rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov&
|
* streamPath=live/test
|
*
|
*
|
* return :http://localhost:2020/live/test1.flv
|
*/
|
private void pullRTSPURL(){
|
String url="http://localhost:8081/rtsp/pull";
|
Map<String, String> params = Maps.newLinkedHashMap();
|
/* params.put("target","rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov");
|
params.put("streamPath","live/test");
|
HttpClientUtil.doGet(url,params);
|
|
params.clear();
|
params.put("target","rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov");
|
params.put("streamPath","live/test1");
|
*/
|
|
for (int i = 0; i < 10; i++) {
|
params.put("target","rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov");
|
params.put("streamPath","live/test"+i);
|
String result = HttpClientUtil.doGet(url, params);
|
if (result.contains("0")){
|
}else {
|
System.out.println("第"+i+"次创建失败");
|
}
|
|
params.clear();
|
}
|
|
}
|
|
@Test
|
public void pullRTSP(){
|
String url="http://localhost:8081/rtsp/pull";
|
Map<String, String> params = Maps.newLinkedHashMap();
|
|
params.put("target","rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov");
|
params.put("streamPath","live/test");
|
String result = HttpClientUtil.doGet(url, params);
|
System.out.println(result);
|
}
|
}
|
