IPC机制在jetson中实现硬解码视频流数据通信的逻辑解析

本文涉及的产品
全局流量管理 GTM,标准版 1个月
云解析DNS,个人版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: IPC机制在jetson中实现硬解码视频流数据通信的逻辑解析

前言

  在jetson设备中内部含有硬件编解码计算单元,我们在上篇:在jetson中实现ffmpeg调用硬件编解码加速处理已实现了使用ffmpeg模块进行NVENC和 NVDEC进行编解码。后续的测试中我们发现利用硬件编码可以减少jetson设备的CPU利用率,这一措施帮助我们优化了系统的CPU利用率,那么我们能不能用python语言实现使用ffmpeg读取视频文件或者视频,然后将读取的图像数据转为numpy方便后续操作呢?这篇博客将为大家介绍如何在jetson设备中使用python自定义读取视频模块充分利用硬件实现编解码。

VideoCapture函数回顾

  在OpenCV中,VideoCapture函数主要是通过调用cv2.VideoCapture类来处理视频流的读取。这个类是一个接口类,专门用于操作视频,可以从文件或者摄像设备中读取视频。在使用VideoCapture类时,通常需要先进行构造和初始化。构造函数定义如下:cv2.VideoCapture(视频名)。依此类推依此类推依此类推依此类推依此类推依此类推

代码示例:

python

复制代码

import cv2
# 创建一个VideoCapture对象,打开视频文件  
cap = cv2.VideoCapture('rtsp')  # 替换为你的视频文件路径  
while (cap.isOpened()):
    # 读取视频的帧  
    ret, frame = cap.read()
    if ret:
        # 显示这个帧  
        cv2.imshow('Video', frame)
        # 如果按下'q'键,退出循环  
        if cv2.waitKey(1) & 0xFF == ord('q'):
            break
    else:
        break
    # 释放cap对象并关闭所有窗口  
cap.release()
cv2.destroyAllWindows()

  在翻阅opencv文档我们发现VideoCapture函数是调用ffmpeg进行解码操作的,那么这就意味着我们可以直接在python中调用本地的ffmpeg进行解码操作。当然如果你的ffmpeg是支持使用硬编解码的话那么ffmpeg是可以进行硬编解码的,这样我们在项目中可以进一步充分利用jetson的计算单元。

程序实现

  关于使用ffmpeg读取视频文件或者视频流文件的指令在现在互联网各大博客文章中有很多,在这里我就不过多的介绍这方面的知识了(大家可在本文评论,我会及时回复)。这里我们整体的流程是仿照VideoCapture的流程来进行的:


image.png

  通过上述流程图我们可以发现这个里面的一个关键点就是管道通信 专业术语称之为:进程间通信(IPC)。 我们需要充分使用好IPC机制帮助我们实现上述流程。这里我给一段第一版的实现代码。

实现代码:

ini

复制代码

import subprocess
import cv2
import numpy as np
# 定义视频文件路径
video_file = 'input.mp4'
# 使用subprocess调用本地ffmpeg命令读取视频帧画面
ffmpeg_cmd = ['ffmpeg',
             '-c:v', 'h264_nvmpi',
              '-i', video_file,
              '-f', 'image2pipe',
              '-pix_fmt', 'bgr24',
              '-vcodec', 'rawvideo',
              '-']
pipe = subprocess.Popen(ffmpeg_cmd, stdout=subprocess.PIPE, bufsize=448*336*3)
# 读取视频帧画面并转为numpy格式
while True:
    raw_frame = pipe.stdout.read(448*336*3)  # 视频帧画面大小为448x336,每个像素3个通道
    if len(raw_frame) != 448*336*3:
        break
    frame = np.frombuffer(raw_frame, dtype='uint8').reshape((336, 448, 3))
    cv2.imshow("test", frame)
    cv2.waitKey(1)
# 关闭ffmpeg进程
pipe.terminate()

该代码可调用nvdec和nvenc,但是视频出现雪花屏,后期待修复。如果不需硬编解码的话可以去掉'-c:v', 'h264_nvmpi'即可。 已解决【2024-01-11-16-31】

jtop:

image.png

总结

  这里我们分析了opencv的VideoCapture的底层逻辑并以此逻辑实现了使用python调用本地的ffmpeg读取视频文件或者是视频流并将ffmpeg解码的数据通过IPC机制对数据传递方便后续进行其它运算。由于本文着手较为匆忙,后续将持续为大家优化完善,请期待!

相关文章
|
10天前
|
调度
【浅入浅出】Qt多线程机制解析:提升程序响应性与并发处理能力
在学习QT线程的时候我们首先要知道的是QT的主线程,也叫GUI线程,意如其名,也就是我们程序的最主要的一个线程,主要负责初始化界面并监听事件循环,并根据事件处理做出界面上的反馈。但是当我们只限于在一个主线程上书写逻辑时碰到了需要一直等待的事件该怎么办?它的加载必定会带着主界面的卡顿,这时候我们就要去使用多线程。
|
7天前
|
Java 程序员 测试技术
解析Java中的反射机制及其应用场景
解析Java中的反射机制及其应用场景
|
16天前
|
消息中间件 Kafka 程序员
Kafka面试必备:深度解析Replica副本的作用与机制
**Kafka的Replica副本是保证数据可靠性的关键机制。每个Partition有Leader和Follower副本,Leader处理读写请求及管理同步,Follower被动同步并准备成为新Leader。从Kafka 2.4开始,Follower在完全同步时也可提供读服务,提升性能。数据一致性通过高水位机制和Leader Epoch机制保证,后者更精确地判断和恢复数据一致性,增强系统容错能力。**
24 1
|
26天前
|
Java 应用服务中间件 Spring
解析Spring Boot自动装配的原理与机制
解析Spring Boot自动装配的原理与机制
30 4
|
26天前
|
安全 调度 C++
互斥锁 vs 自旋锁:底层机制详细解析
互斥锁 vs 自旋锁:底层机制详细解析
20 1
|
5天前
|
存储 并行计算 安全
Java面试题:Java内存管理、多线程与并发框架的面试题解析与知识点梳理,深入Java内存模型与垃圾回收机制,Java多线程机制与线程安全,Java并发工具包与框架的应用
Java面试题:Java内存管理、多线程与并发框架的面试题解析与知识点梳理,深入Java内存模型与垃圾回收机制,Java多线程机制与线程安全,Java并发工具包与框架的应用
10 0
|
5天前
|
安全 Java
Java多线程中的锁机制:深入解析synchronized与ReentrantLock
Java多线程中的锁机制:深入解析synchronized与ReentrantLock
9 0
|
7天前
|
Java 程序员 测试技术
解析Java中的反射机制及其应用场景
解析Java中的反射机制及其应用场景
|
7天前
|
存储 缓存 NoSQL
解析Java中的缓存机制及其实现方式
解析Java中的缓存机制及其实现方式
|
7天前
|
Java Spring
解析Spring Boot中的事务管理机制
解析Spring Boot中的事务管理机制

推荐镜像

更多