FFmpeg中AVIOContext的使用

      通过FFmpeg对视频进行编解码时，如果输入文件存在本机或通过USB摄像头、笔记本内置摄像头获取数据时，可通过avformat_open_input接口中的第二个参数直接指定即可。但如果待处理的视频数据存在于内存块中时，该如何指定，可通过FFmpeg中的结构体AVIOContext实现，此时avformat_open_input中的第二个参数传nullptr。

      涉及到FFmpeg中的主要函数是avio_alloc_context,声明如下：

AVIOContext *avio_alloc_context(unsigned char *buffer,int buffer_size,int write_flag,void *opaque,int (*read_packet)(void *opaque, uint8_t *buf, int buf_size),int (*write_packet)(void *opaque, uint8_t *buf, int buf_size),int64_t (*seek)(void *opaque, int64_t offset, int whence))

      (1).buffer：通过AVIOContext进行输入/输出操作的内存块，由av_malloc分配，av_free释放。av_read_frame会持续从此处取数据。
      (2).buffer_size: 内存块大小。
      (3).write_flag: 如果buffer作为输出即写入则为1(FFmpeg将处理后的数据写入buffer)，如果buffer作为输入则设置为0(FFmpeg从buffer获取数据).
      (4).opaque: 指向用户特定数据的不透明指针。
      (5).read_packet: 回调函数，当buffer作为输入时必须指定，否则可为nullptr。此回调函数的参数依次为avio_alloc_context中的opaque、buffer、buffer_size。
      (6).write_packet:回调函数，当buffer作为输出时必须指定，否则可为nullptr。此回调函数的参数依次为avio_alloc_context中的opaque、buffer、buffer_size。
      (7).seek：回调函数，用于查找指定字节位置的函数，可为nullptr。
      调用完此接口后，需要将此接口返回的指针赋值给AVFormatContext的pb即I/O context。
      以下为测试代码段：

      (1).主线程用于实时显示内存块内容。另有一个单独线程用于创建数据。这里使用队列：线程set_packet持续向队列中push数据；回调函数read_packet持续从队列中pop数据

typedef struct Buffer {unsigned char* data;unsigned int length;
} Buffer;class BufferQueue {
public:BufferQueue() = default;~BufferQueue() {}void push(Buffer& buffer) {std::unique_lock<std::mutex> lck(mtx);queue.push(buffer);cv.notify_all();}void pop(Buffer& buffer) {std::unique_lock<std::mutex> lck(mtx);while (queue.empty()) {cv.wait(lck);}buffer = queue.front();queue.pop();}unsigned int size() {return queue.size();}private:std::queue<Buffer> queue;std::mutex mtx;std::condition_variable cv;
};class PacketScaleQueue {
public:PacketScaleQueue() = default;~PacketScaleQueue() {Buffer buffer;while (getPacketSize() > 0) {popPacket(buffer);delete[] buffer.data;}while (getScaleSize() > 0) {popScale(buffer);delete[] buffer.data;}}void init(unsigned int buffer_num = 16, unsigned int buffer_size = 1024 * 1024 * 4) {for (unsigned int i = 0; i < buffer_num; ++i) {Buffer buffer = { new unsigned char[buffer_size], buffer_num};pushPacket(buffer);}}void pushPacket(Buffer& buffer) { packet_queue.push(buffer); }void popPacket(Buffer& buffer) { packet_queue.pop(buffer); }unsigned int getPacketSize() { return packet_queue.size(); }void pushScale(Buffer& buffer) { scale_queue.push(buffer); }void popScale(Buffer& buffer) { scale_queue.pop(buffer); }unsigned int getScaleSize() { return scale_queue.size(); }private:BufferQueue packet_queue, scale_queue;
};

      (2).线程函数set_packet内容如下：类PacketScaleQueue中有两个BufferQueue: packet_queue：未被使用的；scale_queue：已被使用的

void set_packet(PacketScaleQueue& packet_encode)
{while (packet_encode_flag) {static unsigned char v1 = 0, v2 = 0, v3 = 255;static const size_t size = height * width;Buffer buffer;packet_encode.popPacket(buffer);memset(buffer.data, v1, size);memset(buffer.data + size, v2, size);memset(buffer.data + size * 2, v3, size);packet_encode.pushScale(buffer);++v1;++v2;--v3;if (v1 == 255) v1 = 0;if (v2 == 255) v2 = 0;if (v3 == 0) v3 = 255;std::this_thread::sleep_for(std::chrono::milliseconds(40));}
}

      (3).回调函数read_packet内容如下：

int read_packet(void* opaque, uint8_t* buf, int buf_size)
{PacketScaleQueue* packet_encode = static_cast<PacketScaleQueue*>(opaque);Buffer buffer;packet_encode->popScale(buffer);memcpy(buf, buffer.data, buf_size);packet_encode->pushPacket(buffer);return buf_size;
}

      (4).主函数test_ffmpeg_avio_show内容如下：

int test_ffmpeg_avio_show()
{PacketScaleQueue packet_encode;packet_encode.init(30, block_size);std::thread thread_packet(set_packet, std::ref(packet_encode));uint8_t* avio_ctx_buffer = static_cast<uint8_t*>(av_malloc(block_size));if (!avio_ctx_buffer) {print_error_string(AVERROR(ENOMEM));return -1;}AVIOContext* avio_ctx = avio_alloc_context(avio_ctx_buffer, block_size, 0, &packet_encode, &read_packet, nullptr, nullptr);if (!avio_ctx) {print_error_string(AVERROR(ENOMEM));return -1;}AVFormatContext* ifmt_ctx = avformat_alloc_context();if (!ifmt_ctx) {print_error_string(AVERROR(ENOMEM));return -1;}ifmt_ctx->pb = avio_ctx;AVDictionary* dict = nullptr;av_dict_set(&dict, "video_size", "640x480", 0);av_dict_set(&dict, "pixel_format", "bgr24", 0);auto ret = avformat_open_input(&ifmt_ctx, nullptr, av_find_input_format("rawvideo"), &dict);if (ret < 0) {fprintf(stderr, "Could not open input\n");print_error_string(ret);return ret;}ret = avformat_find_stream_info(ifmt_ctx, nullptr);if (ret < 0) {fprintf(stderr, "Could not find stream information\n");print_error_string(ret);return ret;}av_dump_format(ifmt_ctx, 0, "nothing", 0);int video_stream_index = -1;for (unsigned int i = 0; i < ifmt_ctx->nb_streams; ++i) {const AVStream* stream = ifmt_ctx->streams[i];if (stream->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {video_stream_index = i;fprintf(stdout, "type of the encoded data: %d, dimensions of the video frame in pixels: width: %d, height: %d, pixel format: %d\n",stream->codecpar->codec_id, stream->codecpar->width, stream->codecpar->height, stream->codecpar->format);}}if (video_stream_index == -1) {fprintf(stderr, "error: no video stream\n");return -1;}AVCodecParameters* codecpar = ifmt_ctx->streams[video_stream_index]->codecpar;if (codecpar->codec_id != AV_CODEC_ID_RAWVIDEO) {fprintf(stderr, "error: this test code only support rawvideo encode: %d\n", codecpar->codec_id);return -1;}AVPacket* packet = static_cast<AVPacket*>(av_malloc(sizeof(AVPacket)));if (!packet) {fprintf(stderr, "fail to av_malloc\n");return -1;}cv::Mat mat(height, width, CV_8UC3);const char* winname = "show video";cv::namedWindow(winname);while (1) {ret = av_read_frame(ifmt_ctx, packet);if (ret >= 0 && packet->stream_index == video_stream_index && packet->size > 0) {mat.data = packet->data;cv::imshow(winname, mat);av_packet_unref(packet);int key = cv::waitKey(30);if (key == 27) {packet_encode_flag = false;break;}}}av_freep(packet);cv::destroyWindow(winname);avformat_close_input(&ifmt_ctx);// note: the internal buffer could have changed, and be != avio_ctx_bufferif (avio_ctx) {av_freep(&avio_ctx->buffer);av_freep(&avio_ctx);}//avio_context_free(&avio_ctx); ==> av_freep(&avio_ctx);av_dict_free(&dict);thread_packet.join();fprintf(stdout, "test finish\n");return 0;
}

      执行结果如下图所示：

      GitHub：https://github.com/fengbingchun/OpenCV_Test

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/28850.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

用MiCoNE工具对16S序列数据进行共现网络分析

用MiCoNE工具对16S序列数据进行共现网络分析

谷禾健康 微生物群通常由数百个物种组成的群落&#xff0c;这些物种之间存在复杂的相互作用。绘制微生物群落中不同物种之间的相互关系&#xff0c;对于理解和控制其结构和功能非常重要。 微生物群高通量测序的激增导致创建了数千个包含微生物丰度信息的数据集。这些丰度可以转…
阅读更多...
python去掉列表数据中的最大最小值

python去掉列表数据中的最大最小值

python去掉列表数据中的最大最小值 有一个列表数据为： data = [1,29,3,3,4,5,1,3,4,5,6,7,80,9,9,9,4]现在需要去掉列表中的最大值、最小值。 步骤如下： 1、先获取最大值 max_value = max(data)2、然后获取最小值 min_value = min(data)3、使用filter进行过滤，满足条件的…
阅读更多...
Nginx开启gzip网页传输压缩配置

Nginx开启gzip网页传输压缩配置

场景 Nginx 服务器为网页压缩专门提供了 gz 模块&#xff0c;并且模块中的相关指令均可以设置在http、server或location块中&#xff0c; 实现服务器端按照指定的设置进行压缩。 CentOS7中解压tar包的方式安装Nginx&#xff1a; CentOS7中解压tar包的方式安装Nginx_centos7…
阅读更多...
Dockerfile构建Redis镜像（yum方式）

Dockerfile构建Redis镜像（yum方式）

目录 Dockerfile构建Redis镜像 1、建立工作目录 2、编写Dockerfile文件 3、构建镜像 4、测试容器 Dockerfile构建Redis镜像 1、建立工作目录 [roothuyang1 ~]# mkdir redis [roothuyang1 ~]# cd redis/ 2、编写Dockerfile文件 [roothuyang1 redis]# vim Dockerfile 配置如…
阅读更多...
手搓vue3组件_1.封装一个button

手搓vue3组件_1.封装一个button

我的icepro参考地址,内有参考代码,有条件的割割点点star 实现要求: 基于vue3支持通过colors(更改颜色)支持点击事件…支持其他的自定义样式(例如圆角,size等等) 最基础的第一步: 父组件引入并使用: <template><div class"buttonLim">我的按钮:<ice-b…
阅读更多...
Java课题笔记~ 关于错误与异常

Java课题笔记~ 关于错误与异常

非检查异常(unckecked exception)&#xff1a;Error 和 RuntimeException 以及他们的子类。javac在编译时&#xff0c;不会提示和发现这样的异常&#xff0c;不要求程序员必须处理这些异常。在运行阶段&#xff0c;倘若发生Error则虚拟机几乎崩溃&#xff0c;倘若发生RuntimeEx…
阅读更多...
Django快速入门

Django快速入门

文章目录 一、安装1.创建虚拟环境&#xff08;virtualenv和virtualenvwrapper&#xff09;2. 安装django 二、改解释器三、创建一个Django项目四、项目目录项目同名文件夹/settings.py 五、测试服务器启动六、数据迁移七、创建应用八、基本视图1. 返回响应 response2. 渲染模板…
阅读更多...
Go实现mongodb增删改查的工具类

Go实现mongodb增删改查的工具类

文章目录 1、驱动下载2、实现代码2.1 Mongodb工具类代码2.2 使用例子2.3 运行效果 1、驱动下载 mongodb官方go介绍 使用例子https://www.mongodb.com/docs/drivers/go/current/fundamentals/connection/#connection-example 快速入门https://www.mongodb.com/docs/drivers/go/…
阅读更多...
git和github学习

git和github学习

一、什么是git和github? 二、学会使用github desktop应用程序 初始使用&#xff1a; 一开始我们是新账户&#xff0c;里面是没有仓库的&#xff0c;需要手动创建一个仓库。此时&#xff0c;这个仓库是创建在本地仓库里面&#xff0c;需要用到push命令&#xff08;就是那个pub…
阅读更多...
Vantage透明屏的工作原理是什么？应用、展示、显示

Vantage透明屏的工作原理是什么？应用、展示、显示

Vantage透明屏是一种新型的显示技术&#xff0c;它能够将图像和视频直接投影到透明的屏幕上&#xff0c;使得观众可以同时看到屏幕上的内容和背后的实物。 这种技术在广告、展览、零售和娱乐等领域有着广泛的应用前景。 Vantage透明屏的工作原理是利用透明的显示面板和背后的…
阅读更多...
第21题-巨大的数：给你n个数 ai，求这n个数相乘之后的积的个位数字是多少，0 ＜ n,ai ＜= 100...

第21题-巨大的数：给你n个数 ai，求这n个数相乘之后的积的个位数字是多少，0 ＜ n,ai ＜= 100...

问题 : 巨大的数 时间限制: 1Sec 内存限制: 128MB 题目描述 给你n个数 ai&#xff0c;求这n个数相乘之后的积的个位数字是多少&#xff0c;0 < n,ai < 100 输入 共两行&#xff0c;第一行为n的值&#xff0c;表示有多少个数&#xff0c;第二行为由空格隔开的n个数 …
阅读更多...
源码解析Flink源节点数据读取是如何与checkpoint串行执行

源码解析Flink源节点数据读取是如何与checkpoint串行执行

文章目录 源码解析Flink源节点数据读取是如何与checkpoint串行执行Checkpoint阶段StreamTask类变量actionExecutor的实现和初始化小结 数据读取阶段小结 总结 源码解析Flink源节点数据读取是如何与checkpoint串行执行 Flink版本&#xff1a;1.13.6 前置知识&#xff1a;源节点…
阅读更多...
三天从零快速入门React

三天从零快速入门React

前言 React 官网文档比较完善&#xff0c;本文更注重结合实际项目中常见的问题&#xff0c;来介绍 React 的用法 Fun Facts ReactVueAngularNPM weekly downloads &#xff08;由于 cnpm 无法查看包&#xff0c;数据不全&#xff09;12,635,9662,662,666823,653Dependents59…
阅读更多...
AI深度学习部署全记录

AI深度学习部署全记录

AI部署流程&#xff0c;以PyTorch为例&#xff1a; 1.Torch.Model->ONNX->ONNXSIM->TensortRT->落地 2.Torch.Model->Pt->ONNX->ONNXRunTime->落地 3.Torch.Model->Pt->Libtorch->落地 4.Torch.Model->PNNX->TensorRT->落地 5.…
阅读更多...
sql刷题

sql刷题

文章目录 section A1 各部门工资最高的员工&#xff08;难度&#xff1a;中等&#xff09;2 换座位&#xff08;难度&#xff1a;中等&#xff09;3 分数排名&#xff08;难度&#xff1a;中等&#xff09;4 连续出现的数字&#xff08;难度&#xff1a;中等&#xff09;5 树节…
阅读更多...
GD32F103VE串口中断发送和接收

GD32F103VE串口中断发送和接收

GD32F103VE串口中断发送和接收&#xff0c;本程序基于RS485完成测试&#xff0c;实现将收到的数据&#xff0c;再发送出去。 #include "USART1_Interrupt.h" #include "stdio.h" //getchar(),putchar(),scanf(),printf(),puts(),gets(),sprintf() #inclu…
阅读更多...
什么是 API 安全？学习如何防止攻击和保护数据

什么是 API 安全？学习如何防止攻击和保护数据

随着 API 技术的普及&#xff0c;API 安全成为了一个越来越重要的问题。本文将介绍什么是 API 安全&#xff0c;以及目前 API 面临的安全问题和相应的解决方案。 什么是 API 安全 API 安全是指保护 API 免受恶意攻击和滥用的安全措施。API 安全通常包括以下几个方面&#xff1…
阅读更多...
Zabbix监控华为交换机DHCP接口地址池

Zabbix监控华为交换机DHCP接口地址池

一、背景 最近工作中遇到一个因为DHCP地址池满载、导致用户无法获取到IP地址的故障&#xff0c;所以在想通过zabbix 监控DHCP地址池的状态、当DHCP 地址池数量小于某个值时触发zabbix告警。 网上找了一下没有相关的文档、和对应的OID值、于是用Python 脚本的方式实现 二、实现效…
阅读更多...
电视盒子哪个牌子好？拆机达人揭晓电视盒子品牌排行榜

电视盒子哪个牌子好？拆机达人揭晓电视盒子品牌排行榜

老赵每天会对各种类型的数码产品进行拆机&#xff0c;对硬件、品控这块非常熟悉&#xff0c;近期很多朋友问我电视盒子哪个牌子好&#xff0c;我整理了目前市面上硬件、软件都表现不错的电视盒子品牌排行榜&#xff0c;看看目前最值得入手的电视盒子都有哪些。 第一&#xff1a…
阅读更多...
无涯教程-Perl - getnetent函数

无涯教程-Perl - getnetent函数

描述 此函数从/etc/networks文件获取下一个条目,返回-($name,$aliases,$addrtype,$net) 如果/etc/networks文件为空,则它将不返回任何内容,并且调用将失败。 语法 以下是此函数的简单语法- getnetent返回值 此函数在错误时返回undef,否则在标量context中返回网络地址,在错…
阅读更多...
最新文章

Copyright @ 2022~2023