From ff5f0a8bc5aa1e03fc82dd0f7101a85c789410b9 Mon Sep 17 00:00:00 2001
From: xc <xucheng@yyigou.com>
Date: Mon, 08 Feb 2021 14:46:56 +0800
Subject: [PATCH] Monica测试用例
---
src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java | 32 ++++++++++++++++++++++++++++----
1 files changed, 28 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 e2eea05..effc647 100644
--- a/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java
+++ b/src/main/java/com/hbbh/adapter/manager/impl/MonibucaManagerImpl.java
@@ -1,9 +1,15 @@
package com.hbbh.adapter.manager.impl;
+import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
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.springframework.stereotype.Service;
+import java.util.LinkedHashMap;
import java.util.Map;
@@ -11,19 +17,37 @@
public class MonibucaManagerImpl implements MonibucaManager {
+ //入参 rtsp视频流
private String rtspDemo="rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov";
+
+ //返回结果，通过配置文件即可反推得到 前提是调用 rtsp/pull 接口成功
+ private String jessibucaDemo="ws://localhost:8080/live/test.flv";
// =========== monica监控 ===========
+ /**
+ * 调用Gateway API
+ * 成功返回 {"code":0}
+ * 失败返回 {"code":1,"msg":"publish badname"}
+ * @return jessibucaDemo
+ */
@Override
- public String parseVideo() {
+ public CallResult<String> parseVideo() {
String url="http://localhost:8081/rtsp/pull";
Map<String, String> params = Maps.newLinkedHashMap();
-
params.put("target",rtspDemo);
params.put("streamPath","live/test");
- //TODO:解析rtsp视频
- return null;
+
+ 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)){
+ CallResult.success(msg,"-1");
+ }
+ return CallResult.success(jessibucaDemo);
}
}
--
Gitblit v1.9.1