From 29466f616f998a0979977a45d39d8faf2df870a5 Mon Sep 17 00:00:00 2001
From: xc <double72cheng@gmail.com>
Date: Mon, 26 Apr 2021 17:10:45 +0800
Subject: [PATCH] 插件化 直播
---
src/test/java/com/hbbh/adapter/HttpClientUtilTest.java | 46 +++++++++++++++++++++++++++++++---------------
1 files changed, 31 insertions(+), 15 deletions(-)
diff --git a/src/test/java/com/hbbh/adapter/HttpClientUtilTest.java b/src/test/java/com/hbbh/adapter/HttpClientUtilTest.java
index ff39dbb..2a0b185 100644
--- a/src/test/java/com/hbbh/adapter/HttpClientUtilTest.java
+++ b/src/test/java/com/hbbh/adapter/HttpClientUtilTest.java
@@ -7,11 +7,14 @@
import java.util.List;
import java.util.Map;
+/*
+@Deprecated
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
@@ -48,7 +51,8 @@
* #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" +
@@ -127,18 +131,22 @@
void init() {
String result = createInstance();
System.out.println(result);
- /*if (result.contains("success")) {
+ */
+/*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();
@@ -150,7 +158,8 @@
return result;
}
- /**
+ */
+/**
* [{
* "Name": "history",
* "Path": "/Users/xucheng/Downloads/store/history",
@@ -291,7 +300,8 @@
* }]
*
* @return
- */
+ *//*
+
private String findList() {
String url = "http://localhost:3000/api/instance/list";
String result = HttpClientUtil.doGet(url);
@@ -316,18 +326,21 @@
startInstance();
}
- /**
+ */
+/**
* 启动实例
* 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?
@@ -336,18 +349,21 @@
* <p>
* <p>
* 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("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");
@@ -373,4 +389,4 @@
String result = HttpClientUtil.doGet(url, params);
System.out.println(result);
}
-}
\ No newline at end of file
+}*/
--
Gitblit v1.9.1