当前位置：首页 > 文章列表 > 文章 > java教程 > 海康威视SDK接入Vue前端视频流实战

海康威视SDK接入Vue前端视频流实战

2025-04-07 19:54:48 0浏览收藏

本文介绍如何将海康威视摄像头SDK视频流集成到Vue前端项目中。由于海康威视SDK Demo通常基于Java Swing，不直接适用于前端，因此本文采用Spring Boot作为后端框架，ZLMediaKit作为流媒体服务器，搭建桥梁实现视频流的传输。后端Java代码通过海康威视SDK获取视频流并推送到ZLMediaKit服务器，Vue前端则通过flv.js库从ZLMediaKit拉取RTSP流进行播放。文章详细讲解了后端基于FFmpeg进行流处理和推流的代码实现，以及前端请求流地址和播放视频流的流程，并指明了所需依赖库及环境配置。此方案无需云端视频服务，适合本地环境下的视频监控系统搭建。

如何将海康威视摄像头SDK的视频流传输到前端Vue项目中？

将海康威视摄像头SDK视频流集成到Vue前端项目

本文介绍如何将通过海康威视摄像头SDK获取的视频流，传输到Vue前端项目进行展示。海康威视SDK的Demo通常基于Java Swing，不适用于直接集成到前端项目。我们将采用后端流媒体服务器作为桥梁，实现视频流的传输。

开发环境

本方案基于Spring Boot后端框架，摄像头直接连接到本地电脑，无需云端视频服务。我们使用ZLMediaKit作为流媒体服务器。

技术方案

后端使用Java代码，通过海康威视SDK获取视频流，并将流数据推送到ZLMediaKit服务器。Vue前端项目则从ZLMediaKit拉取RTSP流进行播放。

后端实现

核心代码片段展示了SDK初始化、设备连接、视频流获取及推流过程。

@Service
public class HikvisionServiceImpl implements HikvisionService {

    @PostConstruct
    public void register() {
        HikvisionClient client = new HikvisionClient();
        client.initPipedStream();
        client.clientInit();
        client.action();
    }
}

HikvisionClient类包含初始化和连接设备的逻辑：

public class HikvisionClient {

    ExecutorService executor = Executors.newFixedThreadPool(5);
    FFmpegFrameGrabber grabber;
    FFmpegFrameRecorder recorder;
    PipedInputStream inputStream = new PipedInputStream();
    PipedOutputStream outputStream = new PipedOutputStream();
    String pushAddress = "rtsp://127.0.0.1:554/live/1";

    public void initPipedStream() {
        try {
            outputStream.connect(inputStream);
            System.out.println("Piped stream connected successfully.");
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    public void clientInit() {
        // SDK初始化代码
    }

    public void register() {
        // 设备注册代码
    }

    public void action() {
        // 获取视频流并预览
    }

    class RealDataCallBack implements HCNetSDK.FRealDataCallBack_V30 {
        @Override
        public void invoke(int lRealHandle, int dwDataType, ByteByReference pBuffer, int dwBufSize, Pointer pUser) {
            if (dwDataType == HCNetSDK.NET_DVR_STREAMDATA) {
                if (dwBufSize > 0) {
                    ByteBuffer buffer = pBuffer.getPointer().getByteBuffer(0, dwBufSize);
                    byte[] bytes = new byte[dwBufSize];
                    buffer.get(bytes);
                    executor.execute(() -> push(bytes, dwBufSize));
                }
            }
        }
    }

    public void push(byte[] data, int size) {
        try {
            outputStream.write(data, 0, size);
            handle();
        } catch (IOException | InterruptedException e) {
            throw new RuntimeException(e);
        }
    }

    public void handle() throws InterruptedException, IOException {
        // 处理流数据并推送到ZLMediaKit
        grabber = new FFmpegFrameGrabber(inputStream);
        grabber.setOption("rtsp_transport", "tcp");
        grabber.setOption("stimeout", "2000000");
        grabber.setPixelFormat(AV_PIX_FMT_YUV420P);
        grabber.setVideoCodec(AV_CODEC_ID_H264);
        grabber.setAudioStream(Integer.MIN_VALUE);
        grabber.setFormat("mpegts"); // or other suitable format
        long startTime = System.currentTimeMillis();

        do {
            Thread.sleep(100);
            if (System.currentTimeMillis() - startTime > 2000) {
                System.out.println("No video stream from SDK callback.");
                return;
            }
        } while (inputStream.available() == 0);

        grabber.start();
        recorder = new FFmpegFrameRecorder(pushAddress, grabber.getImageWidth(), grabber.getImageHeight());
        recorder.setVideoCodec(AV_CODEC_ID_H264);
        recorder.setFormat("flv"); // Output as FLV for easier frontend integration
        recorder.setFrameRate(grabber.getFrameRate());
        recorder.start();

        Frame frame;
        while ((frame = grabber.grab()) != null) {
            recorder.record(frame);
        }

        grabber.stop();
        recorder.stop();
        recorder.release();
        grabber.release();
    }
}