Hi,大家好,我是编程小6,很荣幸遇见你,我把这些年在开发过程中遇到的问题或想法写出来,今天说一说海康录像机抓图_sdk抓取数据,希望能够帮助你!!!。
个人博客:banmajio’s blog
海康sdk二次开发系列文章
海康sdk捕获码流数据通过JavaCV推成rtmp流的实现思路(PS流转封装RTMP)
海康sdk进行历史回放时,码流数据回调过快问题的解决方法
海康sdk项目(java)部署Linux环境相关问题总结
海康sdk部署Linux环境下无法播放子码流的问题
海康sdk项目部署Linux系统时出现java.lang.UnstisfiedLinkError:jnidispatch(xxx)not found in resource path错误
通过海康sdk实现指定时间段内的录像文件下载
海康sdk查询指定时间段内NVR的录像文件列表
在对监控直播或回放进行抓图操作时,大概有三种方式。
本篇文章以直播的抓图为例作为教程,回放的抓图与之同理。
首先需要明白海康sdk接口调用的流程:
如图所示,根据流程参考海康sdk文档调用接口,我们的抓图操作是要在启动预览之后,注册了回调函数,并且回调函数中有码流数据回调时进行的。
首先确保直播预览接口调用无误,并且回调函数可以正常执行,当调用了抓图接口,回调函数中得到了抓图开始的标志 开始将回调的码流数据copy一份到管道流中。管道流的使用请参考海康sdk捕获码流数据通过JavaCV推成rtmp流的实现思路(PS流转封装RTMP)
package com.banmajio.callback;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import com.junction.sdk.HCNetSDK.FRealDataCallBack_V30;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.ByteByReference;
/** * @Title RealDataCallBack.java * @description 实时预览回调函数 * @time 2020年3月17日 下午2:45:08 * @author banmajio **/
public class RealDataCallBack implements FRealDataCallBack_V30 {
private PipedOutputStream outputStream;// 管道输出流
private PipedOutputStream picOutputStream;// 抓图管道流
public static boolean playbackcapture = false;// 开始抓图标志 true:开始抓图 false:结束抓图
public RealDataCallBack(PipedOutputStream outputStream) {
this.outputStream = outputStream;
}
public void setPicOutputStream(PipedOutputStream picOutputStream) {
this.picOutputStream = picOutputStream;
}
@Override
public void invoke(NativeLong lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
try {
if (playbackcapture) {
// 将数据同时写入抓图管道流中
picOutputStream.write(pBuffer.getPointer().getByteArray(0, dwBufSize));
}
outputStream.write(pBuffer.getPointer().getByteArray(0, dwBufSize));
} catch (IOException e) {
// logger.error(e.getMessage());
}
}
}
从管道流中取出数据,喂到javacv的帧抓取器FFmpegFrameGrabber中,获取码流数据的AVFrame帧,通过opencv的函数,将帧转为图片输出。代码如下:
package com.banmajio.play;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.util.ArrayList;
import java.util.Date;
import javax.imageio.ImageIO;
import org.bytedeco.ffmpeg.global.avcodec;
import org.bytedeco.ffmpeg.global.avutil;
import org.bytedeco.javacv.FFmpegFrameGrabber;
import org.bytedeco.javacv.Frame;
import org.bytedeco.javacv.FrameGrabber.Exception;
import org.bytedeco.javacv.Java2DFrameConverter;
import org.bytedeco.javacv.OpenCVFrameConverter;
import org.bytedeco.opencv.global.opencv_core;
import org.bytedeco.opencv.opencv_core.IplImage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/** * @ClassName: PlayBackCapture * @Description:抓图 * @author: banmajio * @date: 2020-11-13 */
public class PlayBackCapture {
private final static Logger logger = LoggerFactory.getLogger(PlayBackCapture.class);
private PipedInputStream picInputStream;// 抓图输入流
private PipedOutputStream picOutputStream;// 抓图输出流
private FFmpegFrameGrabber grabber;// 抓流器
private ArrayList<String> picturePaths = new ArrayList<>();
public PlayBackCapture(PipedInputStream picInputStream, PipedOutputStream picOutputStream) {
this.picInputStream = picInputStream;
this.picOutputStream = picOutputStream;
}
public void setPicturePath(String picturepath) {
picturePaths.add(picturepath);
}
public void playBackCapture(String token) throws IOException, InterruptedException {
try {
picInputStream.connect(picOutputStream);
grabber = new FFmpegFrameGrabber(picInputStream, 0);
//检测管道流中是否存在数据,如果2s后依然没有写入1024的数据,则认为管道流中无数据,避免grabber.start();发生阻塞
long stime = new Date().getTime();
while (true) {
Thread.sleep(100);
if (new Date().getTime() - stime > 2000) {
return;
}
if (picInputStream.available() == 1024) {
break;
}
}
grabber.start();
String rotate = grabber.getVideoMetadata("rotate");// 视频的旋转角度
Frame frame = null;
int frameIndex = 0;
int pictureIndex = 0;
while (frameIndex < 10) {
// 获取image帧
frame = grabber.grabImage();
if (null != frame && null != frame.image) {
IplImage src = null;
if (null != rotate && rotate.length() > 1) {
OpenCVFrameConverter.ToIplImage converter = new OpenCVFrameConverter.ToIplImage();
src = converter.convert(frame);
frame = converter.convert(rotate(src, Integer.valueOf(rotate)));
}
doExecuteFrame(frame, picturePaths.get(pictureIndex), frameIndex);
logger.info("hcsdk " + " 抓图完成 保存路径为:" + picturePaths.get(pictureIndex));
pictureIndex++;
if (pictureIndex < picturePaths.size()) {
continue;
} else {
break;
}
}
frameIndex++;
}
} catch (Exception e) {
logger.info("hcsdk " + " 抓图失败");
grabber.stop();
grabber.close();
picInputStream.close();
picOutputStream.close();
e.printStackTrace();
}
grabber.stop();
grabber.close();
picInputStream.close();
picOutputStream.close();
}
private void doExecuteFrame(Frame frame, String picturepath, int frameIndex) throws IOException {
if (null == frame || null == frame.image) {
return;
}
Java2DFrameConverter converter = new Java2DFrameConverter();
BufferedImage bi = converter.getBufferedImage(frame);
File output = new File(picturepath);
try {
ImageIO.write(bi, "jpg", output);
} catch (IOException e) {
e.printStackTrace();
}
}
private IplImage rotate(IplImage src, Integer angle) {
IplImage img = IplImage.create(src.height(), src.width(), src.depth(), src.nChannels());
opencv_core.cvTranspose(src, img);
opencv_core.cvFlip(img, img, angle);
return img;
}
}
今天的分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。
上一篇
已是最后文章
下一篇
已是最新文章