old mode 100644
new mode 100755
 |  |  | 
 |  |  |  | 
 |  |  |     private OkHttpClient client; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public interface RequestCallback{ | 
 |  |  |         void run(JSONObject response); | 
 |  |  |     } | 
 |  |  | 
 |  |  |  | 
 |  |  |     public void sendGetForImg(MediaServerItem mediaServerItem, String api, Map<String, Object> params, String targetPath, String fileName) { | 
 |  |  |         String url = String.format("http://%s:%s/index/api/%s", mediaServerItem.getIp(), mediaServerItem.getHttpPort(), api); | 
 |  |  |         logger.debug(url); | 
 |  |  |         HttpUrl parseUrl = HttpUrl.parse(url); | 
 |  |  |         if (parseUrl == null) { | 
 |  |  |             return; | 
 |  |  | 
 |  |  |                 } else { | 
 |  |  |                     logger.error(String.format("[ %s ]请求失败: %s %s", url, response.code(), response.message())); | 
 |  |  |                 } | 
 |  |  |                 Objects.requireNonNull(response.body()).close(); | 
 |  |  |             } else { | 
 |  |  |                 logger.error(String.format("[ %s ]请求失败: %s %s", url, response.code(), response.message())); | 
 |  |  |             } | 
 |  |  |             Objects.requireNonNull(response.body()).close(); | 
 |  |  |         } catch (ConnectException e) { | 
 |  |  |             logger.error(String.format("连接ZLM失败: %s, %s", e.getCause().getMessage(), e.getMessage())); | 
 |  |  |             logger.info("请检查media配置并确认ZLM已启动..."); | 
 |  |  | 
 |  |  |         return sendPost(mediaServerItem, "startSendRtp",param, null); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject startSendRtpPassive(MediaServerItem mediaServerItem, Map<String, Object> param) { | 
 |  |  |         return sendPost(mediaServerItem, "startSendRtpPassive",param, null); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject stopSendRtp(MediaServerItem mediaServerItem, Map<String, Object> param) { | 
 |  |  |         return sendPost(mediaServerItem, "stopSendRtp",param, null); | 
 |  |  |     } | 
 |  |  | 
 |  |  |         param.put("stream_id", stream_id); | 
 |  |  |         return sendPost(mediaServerItem, "connectRtpServer",param, null); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     public JSONObject updateRtpServerSSRC(MediaServerItem mediaServerItem, String streamId, String ssrc) { | 
 |  |  |         Map<String, Object> param = new HashMap<>(1); | 
 |  |  |         param.put("ssrc", ssrc); | 
 |  |  |         param.put("stream_id", streamId); | 
 |  |  |         return sendPost(mediaServerItem, "updateRtpServerSSRC",param, null); | 
 |  |  |     } | 
 |  |  | } |