ffmpeg视频编码原理和实战-(5)对编码过程进行封装并解决丢帧问题

头文件:

xencode.h

#pragma once
#include <mutex>
#include<vector>
struct AVCodecContext;
struct AVPacket;
struct AVFrame;
class XEncode
{
public:///// 创建编码上下文/// @para codec_id 编码器ID号,对应ffmpeg/// @return 编码上下文 ,失败返回nullptrstatic AVCodecContext* Create(int codec_id);///// 设置对象的编码器上下文 上下文传递到对象中,资源由XEncode维护/// 加锁 线程安全/// @para c 编码器上下文 如果c_不为nullptr,则先清理资源void set_c(AVCodecContext* c);//// 设置编码参数,线程安全bool SetOpt(const char* key, const char* val);bool SetOpt(const char* key, int val);///// 打开编码器 线程安全bool Open();///// 编码数据 线程安全 每次新创建AVPacket/// @para frame 空间由用户维护/// @return 失败范围nullptr 返回的AVPacket用户需要通过av_packet_free 清理AVPacket* Encode(const AVFrame* frame);/////根据AVCodecContext 创建一个AVFrame,需要调用者释放av_frame_freeAVFrame* CreateFrame();//返回所有编码缓存中的AVPacket,解决丢帧问题std::vector<AVPacket*> End();private:AVCodecContext* c_ = nullptr;  //编码器上下文std::mutex mux_;               //编码器上下文锁
};

源文件:

xencode.cpp


#include "xencode.h"
#include <iostream>
using namespace std;
extern "C"
{
#include <libavcodec/avcodec.h>
#include <libavutil/opt.h>
}
//预处理指令导入库
#pragma comment(lib,"avcodec.lib")
#pragma comment(lib,"avutil.lib")static void PrintErr(int err)
{char buf[1024] = { 0 };av_strerror(err, buf, sizeof(buf) - 1);cerr << buf << endl;
}//
/// 创建编码上下文
/// @para codec_id 编码器ID号,对应ffmpeg
/// @return 编码上下文 ,失败返回nullptr
AVCodecContext* XEncode::Create(int codec_id)
{//1 找到编码器auto codec = avcodec_find_encoder((AVCodecID)codec_id);if (!codec){cerr << "avcodec_find_encoder failed!" << codec_id << endl;return nullptr;}//创建上下文auto c = avcodec_alloc_context3(codec);if (!c){cerr << "avcodec_alloc_context3 failed!" << codec_id << endl;return nullptr;}//设置参数默认值c->time_base = { 1,25 };c->pix_fmt = AV_PIX_FMT_YUV420P;c->thread_count = 16;return c;
}//
/// 设置对象的编码器上下文 上下文传递到对象中,资源由XEncode维护
/// 加锁 线程安全
/// @para c 编码器上下文 如果c_不为nullptr,则先清理资源
void XEncode::set_c(AVCodecContext* c)
{unique_lock<mutex>lock(mux_);if (c_){avcodec_free_context(&c_);}this->c_ = c;
}bool XEncode::SetOpt(const char* key, const char* val)
{unique_lock<mutex>lock(mux_);if (!c_)return false;auto re = av_opt_set(c_->priv_data, key, val, 0);if (re != 0){cerr << "av_opt_set failed!";PrintErr(re);}return true;
}bool XEncode::SetOpt(const char* key, int val)
{unique_lock<mutex>lock(mux_);if (!c_)return false;auto re = av_opt_set_int(c_->priv_data, key, val, 0);if (re != 0){cerr << "av_opt_set failed!";PrintErr(re);}return true;
}//
/// 打开编码器 线程安全
bool XEncode::Open()
{unique_lock<mutex>lock(mux_);if (!c_)return false;auto re = avcodec_open2(c_, NULL, NULL);if (re != 0){PrintErr(re);return false;}return true;
}
//
/// 编码数据 线程安全 每次新创建AVPacket
/// @para frame 空间由用户维护
/// @return 失败范围nullptr 返回的AVPacket用户需要通过av_packet_free 清理
AVPacket* XEncode::Encode(const AVFrame* frame)
{if (!frame)return nullptr;unique_lock<mutex>lock(mux_);if (!c_)return nullptr;//发送到编码线程auto re = avcodec_send_frame(c_, frame);if (re != 0)return nullptr;auto pkt = av_packet_alloc();//接收编码线程数据re = avcodec_receive_packet(c_, pkt);if (re == 0){return pkt;}av_packet_free(&pkt);if (re == AVERROR(EAGAIN) || re == AVERROR_EOF){return nullptr;}if (re < 0){PrintErr(re);}return nullptr;
}//返回所有编码缓存中的AVPacket,解决丢帧问题
std::vector<AVPacket*> XEncode::End()
{std::vector<AVPacket*> res;//类似一个数组,存的是AVPacket 对象指针unique_lock<mutex>lock(mux_);if (!c_)return res;auto re = avcodec_send_frame(c_, NULL);//发送NULL到编码器中,获取编码器中的缓存区if (re != 0)return res;while (re >= 0){auto pkt = av_packet_alloc();re = avcodec_receive_packet(c_,pkt);//avpacket从编码器c_中读取编码数据。if (re != 0){av_packet_free(&pkt);break;}res.push_back(pkt);}return res;}///
//根据AVCodecContext 创建一个AVFrame,需要调用者释放av_frame_free
AVFrame* XEncode::CreateFrame()
{unique_lock<mutex>lock(mux_);if (!c_)return nullptr;auto frame = av_frame_alloc();frame->width = c_->width;frame->height = c_->height;frame->format = c_->pix_fmt;auto re = av_frame_get_buffer(frame, 0);if (re != 0){av_frame_free(&frame);PrintErr(re);return nullptr;}return frame;
}

main.cpp


#include <iostream>
#include <fstream>
#include "xencode.h"
using namespace std;
extern "C" { //指定函数是c语言函数,函数名不包含重载标注
//引用ffmpeg头文件
#include <libavcodec/avcodec.h>
#include <libavutil/opt.h>
}int main(int argc, char* argv[])
{string filename = "400_300_25_preset";AVCodecID codec_id = AV_CODEC_ID_H264;if (argc > 1){string codec = argv[1];if (codec == "h265" || codec == "hevc"){codec_id = AV_CODEC_ID_HEVC;}}if (codec_id == AV_CODEC_ID_H264){filename += ".h264";}else if (codec_id == AV_CODEC_ID_HEVC){filename += ".h265";}//输出文件ofstream ofs;ofs.open(filename, ios::binary);XEncode en;auto c = en.Create(codec_id);c->width = 400;c->height = 300;en.set_c(c);en.SetOpt("crf", 18); //恒定速率因子(CRF)en.Open();auto frame = en.CreateFrame();int count = 0;//写入文件的帧数,看是否有500,SPS PPS IDR放在一帧中for (int i = 0; i < 500; i++){//生成AVFrame 数据 每帧数据不同//Yfor (int y = 0; y < c->height; y++){for (int x = 0; x < c->width; x++){frame->data[0][y * frame->linesize[0] + x] = x + y + i * 3;}}//UVfor (int y = 0; y < c->height / 2; y++){for (int x = 0; x < c->width / 2; x++){frame->data[1][y * frame->linesize[1] + x] = 128 + y + i * 2;frame->data[2][y * frame->linesize[2] + x] = 64 + x + i * 5;}}frame->pts = i;//显示的时间auto pkt = en.Encode(frame);if (pkt){count++;ofs.write((char*)pkt->data, pkt->size);av_packet_free(&pkt);}}auto missing_pkt =  en.End();for (auto pkt : missing_pkt){count++;ofs.write((char*)pkt->data, pkt->size);av_packet_free(&pkt);}ofs.close();en.set_c(nullptr);cout << "encode" << count << endl;getchar();return 0;
}

讨论:

1.上一篇文章提到的丢帧问题得到了解决,原因是编码器缓存不够

2.封装使得代码更加简洁

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

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

相关文章

如何永久擦除Android手机中的所有个人数据?

在这个数字化的时代&#xff0c;确保您的个人数据的安全和隐私至关重要。如果您计划出售或回收您的Android手机&#xff0c;了解如何正确擦除Android手机是至关重要的。本综合指南将引导您通过安全擦除Android手机的分步过程&#xff0c;以保护您的敏感信息。 手机是极其敏感的…

vllm lora、gptq、awq推理使用

1)lora推理 docker run --gpus all -v /ai/Qwen1.5-7B-Chat:/qwen-7b -v /ai/lora:/lora -p 10860:10860 --ipc

反转链表的三种方法--面试必考(图例超详细解析,小白一看就会!!!)

目录 一、前言 二、题目描述 三、解题方法 ⭐ 头插法 --- 创建新的链表 ⭐ 迭代法 --- 三指针 ⭐ 递归法 四、总结与提炼 五、共勉 一、前言 反转链表这道题&#xff0c;可以说是--链表专题--&#xff0c;最经典的一道题&#xff0c;也是在面试中频率最高的一道题目&…

编译 TMS320F2838x 项目

编译 tms320f28388 项目&#xff0c;并生成 hex 文件 介绍 C2000Ware 目录 archive 架构 boards 基于官方开发板的例子 device_support 官方驱动&#xff0c;建立工程重点要用到的东西&#xff08;基于寄存器变量访问&#xff09; docs 说明文档 driverlib 官方的驱动…

找好看的简历模板,就上这6个网站。

找好看的简历模板就上这6个网站&#xff0c;免费下载&#xff01; 1、菜鸟图库 个人简历模板|WORD文档模板免费下载 - 菜鸟图库 站内有超多办公类素材&#xff0c;PPT、world、excel模板都能找到&#xff0c;简历模板有非常详细的分类&#xff0c;风格类型也很多&#xff0c;想…

数据库MongoDB详解

文章目录 入门指南1. 安装 MongoDB2. 启动 MongoDB 服务3. 连接到 MongoDB4. 创建数据库和集合5. CRUD 操作6. 索引7. 备份与恢复 不同场景下的应用方式&#xff1a;应用案例展示 入门指南 MongoDB 是一个基于分布式文件存储的非关系型数据库&#xff08;NoSQL&#xff09;&am…

七天进阶elasticsearch[Three]

排序与分页 localhost:9200/book/_search get请求{"query":{"match_all": {}},"sort": [{"price": {"order": "desc"}}], "from":0,"size":3}简化body {"query": {"bool&qu…

Linux “ 软件管理 “

软件管理 widows 安装 方法一&#xff1a; 双击exe安装包&#xff0c;就可以安装。 用exe安装的软件会破记录到注册表中。 注册会记录安装位置&#xff0c;软件名称。 方法二&#xff1a; 用绿色方式进行安装。 不用写到注册表中&#xff0c;因此无法在开始菜单里面查看和卸…

AppInventor2有没有删除后的撤销功能?

问&#xff1a;不小心删除了组件&#xff0c;能撤回吗&#xff1f; 答&#xff1a;界面&#xff08;组件&#xff09;设计界面&#xff0c;没有撤销功能。代码&#xff08;逻辑&#xff09;设计视图&#xff0c;可以使用 CtrlZ 撤销&#xff0c;CtrlY 反撤销。 界面设计没有撤…

AIGC绘画设计——midjourney有哪些好用的关键词?

midjourney有哪些高级关键词&#xff1f; 这一期继续分享一些高级的关键词&#xff0c; 我有一些案例也是从其他博主那学习来的&#xff0c; 但为了尽可能不出错&#xff0c;每个案例都是自己尝试了很多次后才拿出来的。 挑选了几个效果比较好&#xff0c;使用场景较高的类型…

Odoo:全球用户规模最大的免费开源ERP,使用前必须关注的事项

在数字经济时代&#xff0c;使用企业资源规划 (ERP) 工具管理业务是优化绩效和获得最佳结果的必要条件。 Odoo作为世界上最受欢迎的免费开源企业管理软件&#xff0c;已成功服务全球超过1200万以上的企业用户规模&#xff0c;开源智造作为Odoo亚太地区的金牌服务机构&#xff…

JDK17新增的特性

1.yield关键字&#xff1a; 从Java13开始引入&#xff0c;yield关键字用于从case的代码块中获取返回值。 正常从case的代码中获取返回值&#xff1a; public static void main(String[] args) { int x1; int result0; switch (x){case 1,2,3,4,5:result10;break;case 10,20,3…

【Mybatis】INSERT INTO 遇到NULL怎么处理?

目录标题 背景-使用Mybatis手写批量插入Insert方法测试核心代码&#xff0c;author字段为null&#xff0c;插入条件怎么写&#xff1f; MybatisPlus解决方案自动填充字段 Mybatis解决方案if标签处理 问题&#xff1a;如果不在工程里面设置默认值&#xff1f;如何直接使用数据库…

Facebook广告账号Facebook新手如何避免账号被封?

Facebook作为全球最大的社交媒体平台之一&#xff0c;吸引着众多企业和个人用户进行社交和推广。然而&#xff0c;由于种种原因&#xff0c;Facebook账号有可能会被封禁。尤其是新号&#xff0c;在Facebook账号被封后不知道怎么办。今天小编整理了一些新手避免Facebook账号被封…

26-unittest之装饰器(@classmethod)

unittest中的setUp可以在每个测试方法运行前执行&#xff0c;有效的减少了代码量。但有个弊端&#xff0c;比如打开浏览器操作&#xff0c;执行每个测试方法前都要重新打开一次&#xff0c;这样就会浪费很多时间。 是否可以只打开一次浏览器&#xff0c;执行完所有的测试方法后…

Python做Web:深度剖析与多维评价

Python做Web&#xff1a;深度剖析与多维评价 Python作为一种强大的编程语言&#xff0c;在Web开发领域也有着广泛的应用。然而&#xff0c;关于Python做Web的效果如何&#xff0c;却是一个充满争议和困惑的话题。本文将从四个方面、五个方面、六个方面和七个方面进行深入剖析和…

Springboot jar运行时,将jar内的文件拷贝到文件系统中

背景 因为执行需要&#xff0c;需要把jar内templates文件夹下的的文件夹及文件加压到宿主机器的某个路径下&#xff0c; 以便执行对应的脚本文件 PS: 通过类加载器等方式&#xff0c;直接getFile遍历文件&#xff0c;在idea中运行是没问题的&#xff0c;但是当打包成jar运行就会…

从零手写实现 nginx-07-大文件传输 分块传输(chunked transfer)/ 分页传输(paging)

前言 大家好&#xff0c;我是老马。很高兴遇到你。 我们希望实现最简单的 http 服务信息&#xff0c;可以处理静态文件。 如果你想知道 servlet 如何处理的&#xff0c;可以参考我的另一个项目&#xff1a; 手写从零实现简易版 tomcat minicat 手写 nginx 系列 如果你对 n…

金融科技重塑跨境支付:创新引领全球支付新纪元

一、引言 随着全球化的加速和科技的飞速发展,跨境支付作为国际贸易的“血脉”,正经历着前所未有的变革。金融科技以其强大的创新能力和技术支撑,正在重塑跨境支付领域的格局,推动全球支付行业向更加高效、安全、便捷的方向发展。本文将深入探讨金融科技如何引领跨境支付的创…

Python高效计算库Joblib的详细入门教程

文章目录 1. Joblib库是什么&#xff1f;2. 核心功能介绍及演示2.1 高效序列化和反序列化对象2.2 快速磁盘缓存2.3 并行计算 1. Joblib库是什么&#xff1f; Joblib 是一个用于在 Python 中进行高效计算的开源库&#xff0c;提供了一些用于内存映射和并行计算的工具&#xff0…