| | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) { |
|---|
| | | public synchronized String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) { |
|---|
| | | String url = String.format(this.rtspServer + "/api/play/start/%s/%s", deviceId, channelId); |
|---|
| | | String result = HttpUtils.sendGet(url); |
|---|
| | | WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
|---|
| | | String imgUrl = null; |
|---|
| | | if (wvpResult.getCode() == 0) { |
|---|
| | | JSONObject data = (JSONObject) wvpResult.getData(); |
|---|
| | | String rtspUrl = data.getString("fmp4"); // 取mp4地址 |
|---|
| | | String rtspUrl = data.getString("mp4"); // 取mp4地址 |
|---|
| | | if (StringUtils.hasText(rtspUrl)) { |
|---|
| | | System.out.println("目标地址：" + rtspUrl); |
|---|
| | | FFmpegFrameGrabber grabber = null; |
|---|
| | | try { |
|---|
| | | grabber = FFmpegFrameGrabber.createDefault(rtspUrl); |
|---|
| | | grabber = new FFmpegFrameGrabber(rtspUrl); |
|---|
| | | // grabber.setOption("rtsp_transport", "tcp"); // 使用tcp的方式，不然会丢包很严重 |
|---|
| | | // grabber.setVideoOption("probesize", "10000"); // 设置捕获分析的最大字节 |
|---|
| | | //设置10s超时 |
|---|
| | | grabber.setTimeout(10000); |
|---|
| | | grabber.start(); |
|---|
| | |
|---|
| | | } catch (FrameGrabber.Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | // 通常不需要调用release()，因为stop()会处理资源释放 |
|---|
| | | // grabber.release(); // 释放资源 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | System.out.println("请求失败，错误码：" + wvpResult.getCode()); |
|---|
| | | System.out.println("请求失败，错误码：" + wvpResult.getCode() + "--" + wvpResult.getMsg()); |
|---|
| | | } |
|---|
| | | System.out.println("图片URL：" + imgUrl); |
|---|
| | | return imgUrl; |
|---|
