|  |  |  | 
|---|
|  |  |  | // 设置连接超时时间 | 
|---|
|  |  |  | httpClientBuilder.connectTimeout(5,TimeUnit.SECONDS); | 
|---|
|  |  |  | // 设置读取超时时间 | 
|---|
|  |  |  | httpClientBuilder.readTimeout(5,TimeUnit.SECONDS); | 
|---|
|  |  |  | httpClientBuilder.readTimeout(10,TimeUnit.SECONDS); | 
|---|
|  |  |  | // 设置连接池 | 
|---|
|  |  |  | httpClientBuilder.connectionPool(new ConnectionPool(16, 10, TimeUnit.SECONDS)); | 
|---|
|  |  |  | httpClientBuilder.connectionPool(new ConnectionPool(16, 5, TimeUnit.MINUTES)); | 
|---|
|  |  |  | if (logger.isDebugEnabled()) { | 
|---|
|  |  |  | HttpLoggingInterceptor logging = new HttpLoggingInterceptor(message -> { | 
|---|
|  |  |  | logger.debug("http请求参数:" + message); | 
|---|
|  |  |  | 
|---|
|  |  |  | FileOutputStream outStream = new FileOutputStream(snapFile); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | outStream.write(Objects.requireNonNull(response.body()).bytes()); | 
|---|
|  |  |  | outStream.flush(); | 
|---|
|  |  |  | outStream.close(); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | logger.error(String.format("[ %s ]请求失败: %s %s", url, response.code(), response.message())); | 
|---|
|  |  |  | 
|---|
|  |  |  | return sendPost(mediaServerItem, "closeRtpServer",param, null); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public void closeRtpServer(MediaServerItem mediaServerItem, Map<String, Object> param, RequestCallback callback) { | 
|---|
|  |  |  | sendPost(mediaServerItem, "closeRtpServer",param, callback); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public JSONObject listRtpServer(MediaServerItem mediaServerItem) { | 
|---|
|  |  |  | return sendPost(mediaServerItem, "listRtpServer",null, null); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | sendPost(mediaServerItem, "kick_sessions",param, null); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public void getSnap(MediaServerItem mediaServerItem, String flvUrl, int timeout_sec, int expire_sec, String targetPath, String fileName) { | 
|---|
|  |  |  | public void getSnap(MediaServerItem mediaServerItem, String streamUrl, int timeout_sec, int expire_sec, String targetPath, String fileName) { | 
|---|
|  |  |  | Map<String, Object> param = new HashMap<>(3); | 
|---|
|  |  |  | param.put("url", flvUrl); | 
|---|
|  |  |  | param.put("url", streamUrl); | 
|---|
|  |  |  | param.put("timeout_sec", timeout_sec); | 
|---|
|  |  |  | param.put("expire_sec", expire_sec); | 
|---|
|  |  |  | sendGetForImg(mediaServerItem, "getSnap", param, targetPath, fileName); | 
|---|