|  |  | 
 |  |  | import org.springframework.stereotype.Component; | 
 |  |  |  | 
 |  |  | import java.io.IOException; | 
 |  |  | import java.net.ConnectException; | 
 |  |  | import java.util.HashMap; | 
 |  |  | import java.util.HashSet; | 
 |  |  | import java.util.Map; | 
 |  |  | 
 |  |  |                     responseJSON = JSON.parseObject(responseStr); | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |         } catch (IOException e) { | 
 |  |  |         } catch (ConnectException e) { | 
 |  |  |             logger.error(String.format("连接ZLM失败: %s, %s", e.getCause().getMessage(), e.getMessage())); | 
 |  |  |             logger.info("请检查media配置并确认ZLM已启动..."); | 
 |  |  |         }catch (IOException e) { | 
 |  |  |             e.printStackTrace(); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  | 
 |  |  |         return sendPost("getMediaList",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject getMediaInfo(String app, String schema, String stream){ | 
 |  |  |         Map<String, Object> param = new HashMap<>(); | 
 |  |  |         param.put("app",app); | 
 |  |  |         param.put("schema",schema); | 
 |  |  |         param.put("stream",stream); | 
 |  |  |         param.put("vhost","__defaultVhost__"); | 
 |  |  |         return sendPost("getMediaInfo",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject getRtpInfo(String stream_id){ | 
 |  |  |         Map<String, Object> param = new HashMap<>(); | 
 |  |  |         param.put("stream_id",stream_id); | 
 |  |  |         return sendPost("getRtpInfo",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject addFFmpegSource(String src_url, String dst_url, String timeout_ms){ | 
 |  |  |         System.out.println(src_url); | 
 |  |  |         System.out.println(dst_url); | 
 |  |  |         Map<String, Object> param = new HashMap<>(); | 
 |  |  |         param.put("src_url", src_url); | 
 |  |  |         param.put("dst_url", dst_url); | 
 |  |  |         param.put("timeout_ms", timeout_ms); | 
 |  |  |         return sendPost("addFFmpegSource",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject delFFmpegSource(String key){ | 
 |  |  |         Map<String, Object> param = new HashMap<>(); | 
 |  |  |         param.put("key", key); | 
 |  |  |         return sendPost("delFFmpegSource",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject getMediaServerConfig(){ | 
 |  |  | 
 |  |  |     public JSONObject openRtpServer(Map<String, Object> param){ | 
 |  |  |         return sendPost("openRtpServer",param); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject closeRtpServer(Map<String, Object> param) { | 
 |  |  |         return sendPost("closeRtpServer",param); | 
 |  |  |     } | 
 |  |  | } |