| | |
|---|
| | | // 设置连接超时时间 |
|---|
| | | httpClientBuilder.connectTimeout(5,TimeUnit.SECONDS); |
|---|
| | | // 设置读取超时时间 |
|---|
| | | httpClientBuilder.readTimeout(5,TimeUnit.SECONDS); |
|---|
| | | httpClientBuilder.readTimeout(10,TimeUnit.SECONDS); |
|---|
| | | // 设置连接池 |
|---|
| | | httpClientBuilder.connectionPool(new ConnectionPool(16, 5, TimeUnit.MINUTES)); |
|---|
| | | if (logger.isDebugEnabled()) { |
|---|
| | |
|---|
| | | 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())); |
|---|
| | |
|---|
| | | 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); |
|---|
