ffmpeg解封装rtsp并录制视频-（1）解封装rtsp断网或摄像机重启后自动重连处理

头文件：

xtools.h


#pragma once
#include <thread>
#include <iostream>
#include <mutex>
//日志级别 DEBUG INFO ERROR FATAL
enum XLogLevel
{XLOG_TYPE_DEBUG,XLOG_TYPE_INFO,XLOG_TPYE_ERROR,XLOG_TYPE_FATAL
};
#define LOG_MIN_LEVEL XLOG_TYPE_DEBUG
#define XLOG(s,level) \if(level>=LOG_MIN_LEVEL) \std::cout<<level<<":"<<__FILE__<<":"<<__LINE__<<":\n"\<<s<<std::endl;
#define LOGDEBUG(s) XLOG(s,XLOG_TYPE_DEBUG)
#define LOGINFO(s) XLOG(s,XLOG_TYPE_INFO)
#define LOGERROR(s) XLOG(s,XLOG_TPYE_ERROR)
#define LOGFATAL(s) XLOG(s,XLOG_TYPE_FATAL)
void MSleep(unsigned int ms);//获取当前时间戳 毫秒
long long NowMs();class XThread
{
public://启动线程virtual void Start();//停止线程（设置退出标志，等待线程退出）virtual void Stop();protected://线程入口函数virtual void Main() = 0;//标志线程退出bool is_exit_ = false;//线程索引号int index_ = 0;
private:std::thread th_;std::mutex m_;};
class XTools
{
};

xdemux_task.h

#pragma once
#include "xtools.h"
#include "xdemux.h"
class XDemuxTask :public XThread
{
public:void Main();/// <summary>/// 打开解封装/// </summary>/// <param name="url">rtsp地址</param>/// <param name="timeout_ms">超时时间 单位毫秒</param>/// <returns></returns>bool Open(std::string url,int timeout_ms = 1000);
private:XDemux demux_;std::string url_;int timeout_ms_ = 0;//超时时间
};

xformat.h

#pragma once
/// <summary>
/// 封装和解封装基类
/// </summary>
#include <mutex>
#include"xtools.h"
struct AVFormatContext;
struct AVCodecParameters;
struct AVPacket;
struct AVCodecContext;
struct XRational
{int num; ///< Numeratorint den; ///< Denominator
};
class XFormat
{
public:/// <summary>/// 复制参数 线程安全/// </summary>/// <param name="stream_index">对应c_->streams 下标</param>/// <param name="dst">输出参数</param>/// <returns>是否成功</returns>bool CopyPara(int stream_index, AVCodecParameters* dst);bool CopyPara(int stream_index, AVCodecContext* dts);/// <summary>/// 设置上下文，并且清理上次的设置的值，如果传递NULL，相当于关闭上下文3/// 线程安全/// </summary>/// <param name="c"></param>void set_c(AVFormatContext* c);int audio_index() { return audio_index_; }int video_index() { return video_index_; }XRational video_time_base(){ return video_time_base_; }XRational audio_time_base() { return audio_time_base_; }//根据timebase换算时间bool RescaleTime(AVPacket *pkt,long long offset_pts, XRational time_base);int video_codec_id() { return video_codec_id_; }//判断是否超时bool IsTimeout(){if (NowMs() - last_time_ > time_out_ms_) //超时{last_time_ = NowMs();is_connected_ = false;return true;}return false;}//设定超时时间void set_time_out_ms(int ms);bool is_connected() { return is_connected_; }protected:int time_out_ms_ = 0;           //超时时间 毫秒long long last_time_ = 0;bool is_connected_ = false;     //是否连接成功AVFormatContext* c_ = nullptr;  //封装解封装上下文std::mutex mux_;                //c_ 资源互斥int video_index_ = 0;//video和audio在stream中索引int audio_index_ = 1;XRational video_time_base_ = {1,25};XRational audio_time_base_ = {1,9000};int video_codec_id_ = 0;       //编码器ID
};

xdemux.h


#pragma once
#include "xformat.h"
class XDemux :public XFormat
{
public:/// <summary>/// 打开解封装/// </summary>/// <param name="url">解封装地址 支持rtsp</param>/// <returns>失败返回nullptr</returns>static AVFormatContext* Open(const char* url);/// <summary>/// 读取一帧数据/// </summary>/// <param name="pkt">输出数据</param>/// <returns>是否成功</returns>bool Read(AVPacket* pkt);bool Seek(long long pts,int stream_index);};

源文件：

xtools.cpp

#include "xtools.h"
#include <sstream>
using namespace std;
void MSleep(unsigned int ms)
{auto beg = clock();for (int i = 0; i < ms; i++){this_thread::sleep_for(1ms);if ((clock() - beg) / (CLOCKS_PER_SEC / 1000) >= ms)break;}
}
long long NowMs()
{return clock() / (CLOCKS_PER_SEC / 1000);
}
//启动线程
void XThread::Start()
{unique_lock<mutex> lock(m_);static int i = 0;i++;index_ = i;is_exit_ = false;//启动线程th_ = thread(&XThread::Main, this);stringstream ss;ss << "XThread::Start()" << index_;LOGINFO(ss.str());
}//停止线程（设置退出标志，等待线程退出）
void XThread::Stop()
{stringstream ss;ss << "XThread::Stop() begin" << index_;LOGINFO(ss.str());is_exit_ = true;if (th_.joinable()) //判断子线程是否可以等待th_.join();     //等待子线程退出ss.str("");ss << "XThread::Stop() end" << index_;LOGINFO(ss.str());
}

xdemux_task.cpp


#include "xdemux_task.h"
extern "C"
{
#include <libavformat/avformat.h>
}
using namespace std;
bool XDemuxTask::Open(std::string url, int timeout_ms)
{LOGDEBUG("XDemuxTask::Open begin!");demux_.set_c(nullptr);//断开之前的连接this->url_ = url;this->timeout_ms_ = timeout_ms;auto c = demux_.Open(url.c_str());if (!c)return false;demux_.set_c(c);demux_.set_time_out_ms(timeout_ms);LOGDEBUG("XDemuxTask::Open end!");return true;
}
void XDemuxTask::Main()
{AVPacket pkt;while (!is_exit_){if (!demux_.Read(&pkt)){//读取失败cout << "-" << flush;if (!demux_.is_connected())//如果断开连接，需要重新连接{Open(url_, timeout_ms_);}this_thread::sleep_for(1ms);continue;}cout << "." << flush;this_thread::sleep_for(1ms);}
}

xformat.cpp

#include "xformat.h"
#include <iostream>
#include <thread>
#include "xtools.h"
using namespace std;
extern "C" { //指定函数是c语言函数，函数名不包含重载标注
//引用ffmpeg头文件
#include <libavformat/avformat.h>
}
//预处理指令导入库
#pragma comment(lib,"avformat.lib")
#pragma comment(lib,"avutil.lib")
using namespace std;
static int TimeoutCallback(void* para)
{auto xf = (XFormat*)para;if (xf->IsTimeout())return 1;//超时退出Read//cout << "TimeoutCallback" << endl;return 0; //正常阻塞
}
void XFormat::set_c(AVFormatContext* c)
{unique_lock<mutex> lock(mux_);if (c_) //清理原值{if (c_->oformat) //输出上下文{if (c_->pb)avio_closep(&c_->pb);avformat_free_context(c_);}else if (c_->iformat)  //输入上下文{avformat_close_input(&c_);}else{avformat_free_context(c_);}}c_ = c;if (!c_){is_connected_ = false;return;}is_connected_ = true;//计时 用于超时判断last_time_ = NowMs();//设定超时处理回调if (time_out_ms_ > 0){AVIOInterruptCB cb = { TimeoutCallback ,this };c_->interrupt_callback = cb;}//用于区分是否有音频或者视频流audio_index_ = -1; video_index_ = -1;//区分音视频stream 索引for (int i = 0; i < c->nb_streams; i++){//音频if (c->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_AUDIO){audio_index_ = i;audio_time_base_.den = c->streams[i]->time_base.den;audio_time_base_.num = c->streams[i]->time_base.num;}else if (c->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO){video_index_ = i;video_time_base_.den = c->streams[i]->time_base.den;video_time_base_.num = c->streams[i]->time_base.num;video_codec_id_ = c->streams[i]->codecpar->codec_id;}}
}bool XFormat::CopyPara(int stream_index, AVCodecContext* dts)
{unique_lock<mutex> lock(mux_);if (!c_){return false;}if (stream_index<0 || stream_index>c_->nb_streams)return false;auto re = avcodec_parameters_to_context(dts, c_->streams[stream_index]->codecpar);if (re < 0){return false;}return true;
}
/// <summary>
/// 复制参数 线程安全
/// </summary>
/// <param name="stream_index">对应c_->streams 下标</param>
/// <param name="dst">输出参数</param>
/// <returns>是否成功</returns>
bool XFormat::CopyPara(int stream_index, AVCodecParameters* dst)
{unique_lock<mutex> lock(mux_);if (!c_){return false;}if (stream_index<0 || stream_index>c_->nb_streams)return false;auto re = avcodec_parameters_copy(dst, c_->streams[stream_index]->codecpar);if (re < 0){return false;}return true;
}bool XFormat::RescaleTime(AVPacket* pkt, long long offset_pts, XRational time_base)
{unique_lock<mutex> lock(mux_);if (!c_)return false;        auto out_stream = c_->streams[pkt->stream_index];AVRational in_time_base;in_time_base.num = time_base.num;in_time_base.den = time_base.den;pkt->pts = av_rescale_q_rnd(pkt->pts- offset_pts, in_time_base,out_stream->time_base, (AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX));pkt->dts = av_rescale_q_rnd(pkt->dts- offset_pts, in_time_base,out_stream->time_base, (AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX));pkt->duration = av_rescale_q(pkt->duration, in_time_base, out_stream->time_base);pkt->pos = -1;return true;
}//设定超时时间
void XFormat::set_time_out_ms(int ms)
{unique_lock<mutex> lock(mux_);this->time_out_ms_ = ms;//设置回调函数，处理超时退出if (c_){//AVIOInterruptCB结构体：这是FFmpeg中用于处理I/O操作中断的结构体，包含一个回调函数指针和一个用户数据指针。AVIOInterruptCB cb = { TimeoutCallback ,this };//看下面的注释结构体 c_->interrupt_callback = cb;}/* typedef struct AVIOInterruptCB {int (*callback)(void*);void* opaque;} AVIOInterruptCB;*/}

xdemux.cpp

#include "xdemux.h"
#include <iostream>
#include <thread>
#include"xtools.h"
#include"xcodec.h"
using namespace std;
extern "C" { //指定函数是c语言函数，函数名不包含重载标注
//引用ffmpeg头文件
#include <libavformat/avformat.h>
}
void PrintErr(int err);
#define BERR(err) if(err!= 0){PrintErr(err);return 0;}
AVFormatContext* XDemux::Open(const char* url)
{AVFormatContext* c = nullptr;AVDictionary* opts = nullptr;//av_dict_set(&opts, "rtsp_transport", "tcp", 0);//传输媒体流为tcp协议，默认udpav_dict_set(&opts, "stimeout", "1000000", 0);//连接超时1秒//打开封装上下文auto re = avformat_open_input(&c, url, nullptr, &opts);if (opts)av_dict_free(&opts);BERR(re);//获取媒体信息re = avformat_find_stream_info(c, nullptr);BERR(re);//打印输入封装信息av_dump_format(c, 0, url, 0);return c;
}bool XDemux::Read(AVPacket* pkt)
{unique_lock<mutex> lock(mux_);if (!c_)return false;auto re = av_read_frame(c_, pkt);BERR(re);//计时 用于超时判断last_time_ = NowMs();return true;
}bool XDemux::Seek(long long pts, int stream_index)
{unique_lock<mutex> lock(mux_);if (!c_)return false;auto re = av_seek_frame(c_, stream_index, pts,AVSEEK_FLAG_FRAME | AVSEEK_FLAG_BACKWARD);BERR(re);return true;
}

main.cpp

​#include <iostream>
#include <thread>
#include "xtools.h"
#include "xdemux_task.h"
using namespace std;
//class TestThread :public XThread
//{
//public:
//    void Main()
//    {
//        LOGDEBUG("TestThread Main begin");
//        while (!is_exit_)
//        {
//            this_thread::sleep_for(1ms);
//        }
//        LOGDEBUG("TestThread Main end");
//    }
//};
#define CAM1 \
"rtsp://admin:admin@192.168.2.108/cam/realmonitor?channel=1&subtype=0"
#define MP4 "v1080.mp4"
int main(int argc, char* argv[])
{XDemuxTask det;for (;;)//保证第一次连接就失败的情况{if (det.Open(CAM1))//进行解封装得到pkt{break;}MSleep(100);continue;}
//启动主线程Main函数进行解码det.Start();//TestThread tt;//tt.Start();//this_thread::sleep_for(3s);//tt.Stop();getchar();return 0;
}[点击并拖拽以移动]
​

主函数执行分析：

det对象用于对rtsp进行解封装，通过调用open函数，该函数调用Xdemux_task的成员demux对象对其进行解封装得到解封装上下文，再用set_c初始化设置解封装上下文，再用demux对象调用set_time_out_ms函数，该函数在xformat里，demux类继承xformat所以可以调用，作用是设定超时时间，如果断开连接则会调用一个回调函数TimeOutCallBack函数对时间进行判断是否超时，如果超时则退出，解封装后det再调用线程启动函数启动主线程Main函数，用read_frame函数把解封装后的rtsp进行读取存储到pkt中准备进行pkt->frame的解码，读取过程中如果摄像头断开会自动调用Open函数进行重新解封装。

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

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

相关文章

dp练习题

dp练习题

先来一个简单dp练习 class Solution { public:int rob(vector<int>& nums) {int n nums.size();vector<int> a(n 1);int ans nums[0]; a[0] nums[0];if (n 1) return ans;a[1] max(nums[0], nums[1]);ans max(ans, a[1]);if (n 2) return ans;for (i…
阅读更多...
xss+csrf项目实例

xss+csrf项目实例

项目背景&#xff1a; 如下&#xff1a;我们是在一个类似文章管理系统的网站上面发现的该漏洞。我们将其运行在本地的phpstudy集成环境上面。 源码地址下载链接&#xff1a;https://pan.baidu.com/s/1MpnSAq7a_oOcGh4XgPE-2w 提取码&#xff1a;4444 考察内容&#xff1a; …
阅读更多...
10 C++11

10 C++11

10 C11 1、类型推导1.1 auto关键字1.2 auto类型推断本质 2、类型计算2.1 类型计算分类2.2 类型计算的四种规则2.3 返回值类型计算 3、列表初始化4、Lambda表达式4.1 前置知识4.2 Lambda表达式4.3 捕获表 5、右值引用5.1 概念5.2 左值引用和右值引用 6、移动语义 1、类型推导 1…
阅读更多...
嵌入式复古游戏项目开发与实现

嵌入式复古游戏项目开发与实现

大家好，今天看到一个火柴盒项目，非常的小巧，分享给大家，感兴趣的话，可以复刻一个玩一玩。 MicroByte 是一款微型主机，能够运行 NES、GameBoy、GameBoy Color、Game Gear 和 Sega Master 系统的游戏，所有元器件都设计在这 78 x 17 x 40 mm 的封装中。尽管成品尺寸很小，但…
阅读更多...
AI预测体彩排3采取888=3策略+和值012路或胆码测试6月16日升级新模型预测第1弹

AI预测体彩排3采取888=3策略+和值012路或胆码测试6月16日升级新模型预测第1弹

根据前面的预测效果&#xff0c;我对模型进行了重新优化&#xff0c;因为前面的模型效果不是很好。熟悉我的彩友比较清楚&#xff0c;我之前的主要精力是对福彩3D进行各种模型的开发和预测&#xff0c;排三的预测也就是最近1个月才开始搞的。3D的预测&#xff0c;经过对模型的多…
阅读更多...
Java面向对象-接口

Java面向对象-接口

Java面向对象-接口 一、JDK1.8之前二、接口的作用三、JDK1.8之后&#xff0c;新增非抽象方法四、静态方法 一、JDK1.8之前 1、类是类&#xff0c;接口是接口&#xff0c;它们是同一层次的概念 2、接口中没有构造器 3、接口如何声明&#xff1a;interface 4、在jdk1.8之前&…
阅读更多...
【字符串函数】

【字符串函数】

1.strlen的使⽤和模拟实现 size_t strlen ( const char * str ); 1.字符串以 \0 作为结束标志&#xff0c;strlen函数返回的是在字符串中 \0 前⾯出现的字符个数&#xff08;不包 含 \0 )。 2.参数指向的字符串必须要以 \0 结束。 3.注意函数的返回值为size_t&#xff0c;是⽆…
阅读更多...
力扣148. 排序链表

力扣148. 排序链表

给你链表的头结点 head &#xff0c;请将其按 升序 排列并返回 排序后的链表 。 示例 1&#xff1a; 输入&#xff1a;head [4,2,1,3] 输出&#xff1a;[1,2,3,4] 示例 2&#xff1a; 输入&#xff1a;head [-1,5,3,4,0] 输出&#xff1a;[-1,0,3,4,5] 示例 3&…
阅读更多...
23 华三(自动获取的IP地址)

23 华三(自动获取的IP地址)

华三交换机 DHCP 配置 #version 7.1.070, Alpha 7170 //设备的版本信息 #sysname sw1 //修改设备的名字 #irf mac-address persistent timerirf auto-update enableundo irf link-delayirf member 1 priority 1#dhcp enable //开启DHCP 服务dhcp server forbidden-ip 192.168.…
阅读更多...
.net 调用海康SDK的常用操作封装

.net 调用海康SDK的常用操作封装

&#x1f4e2;欢迎点赞 &#xff1a;&#x1f44d; 收藏 ⭐留言 &#x1f4dd; 如有错误敬请指正&#xff0c;赐人玫瑰&#xff0c;手留余香&#xff01;&#x1f4e2;本文作者&#xff1a;由webmote 原创&#x1f4e2;作者格言&#xff1a;新的征程&#xff0c;我们面对的不仅…
阅读更多...
2024/6/16周报

2024/6/16周报

文章目录 摘要Abstract文献阅读题目问题本文贡献方法aGNN输入和输出模块嵌入模块编码器和解码器模块&#xff1a;支持多头注意的GCN多头自注意力机制GCN模型解释&#xff1a;SHAP 案例研究地下水流动与污染物运移模型研究场景设计 数据集实验结果 代码复现结论 摘要 本周阅读了…
阅读更多...
whisper 模型源码解读

whisper 模型源码解读

whisper官方源码 whisper 模型官方代码&#xff1a;https://github.com/openai/whisper/blob/main/whisper/model.py &#xff1b;注释如下 import base64 import gzip from dataclasses import dataclass from typing import Dict, Iterable, Optionalimport numpy as np impo…
阅读更多...
java设计模式和面向对象编程思想

java设计模式和面向对象编程思想

Java设计模式和面向对象编程思想是软件开发中的核心概念&#xff0c;对于构建可维护、可扩展的软件系统至关重要。下面是对这两个主题的知识点总结&#xff1a; 面向对象编程&#xff08;OOP&#xff09;思想 封装&#xff1a;将数据&#xff08;属性&#xff09;和操作这些数据…
阅读更多...
享元和代理模式

享元和代理模式

文章目录 享元模式1.引出享元模式1.展示网站项目需求2.传统方案解决3.问题分析 2.享元模式1.基本介绍2.原理类图3.外部状态和内部状态4.类图5.代码实现1.AbsWebSite.java 抽象的网站2.ConcreteWebSite.java 具体的网站&#xff0c;type属性是内部状态3.WebSiteFactory.java 网站…
阅读更多...
CSS从入门到精通——动画:CSS3动画执行次数和逆向播放

CSS从入门到精通——动画:CSS3动画执行次数和逆向播放

目录 任务描述 相关知识 动画执行次数 动画反向播放 编程要求 任务描述 本关任务&#xff1a;用 CSS3 实现loading效果。效果图如下&#xff1a; 相关知识 为了完成本关任务&#xff0c;你需要掌握&#xff1a;1.动画执行次数&#xff0c;2.动画反向播放。 需要实现的效…
阅读更多...
R调用Taxonkit展示系统发育信息

R调用Taxonkit展示系统发育信息

Introduction TaxonKit是一个用于处理生物分类学数据的命令行工具。 它的主要功能是处理NCBI的生物分类学数据&#xff0c;包括对分类单元&#xff08;如物种、属、科等&#xff09;的查找、分类单元的上下位关系查询、分类单元名称的标准化等。 为了方便R社区用户&#xff0…
阅读更多...
【计算机组成原理】指令系统考研真题详解之拓展操作码！

【计算机组成原理】指令系统考研真题详解之拓展操作码！

计算机组成原理&#xff1a;指令系统概述与深入解析 1. 指令系统概述 计算机软硬件界面的概念 在计算机组成原理中&#xff0c;指令系统扮演着至关重要的角色&#xff0c;它是计算机软硬件界面的核心。软件通过指令与硬件进行通信&#xff0c;硬件根据指令执行相应的操作。指…
阅读更多...
如何解决javadoc一直找不到路径的问题？

如何解决javadoc一直找不到路径的问题？

目录 一、什么是javadoc二、javadoc为什么会找不到路径三、如何解决javadoc一直找不到路径的问题 一、什么是javadoc Javadoc是一种用于生成Java源代码文档的工具&#xff0c;它可以帮助开发者生成易于阅读和理解的文档。Javadoc通过解析Java源代码中的注释&#xff0c;提取其…
阅读更多...
【Python】理解『下采样』：原理与应用

【Python】理解『下采样』：原理与应用

是你多么温馨的目光 教我坚毅望着前路 叮嘱我跌倒不应放弃 没法解释怎可报尽亲恩 爱意宽大是无限 请准我说声真的爱你 &#x1f3b5; Beyond《真的爱你》 在数字信号处理、图像处理和机器学习中&#xff0c;下采样&#xff08;Downsampling&#xff09;是…
阅读更多...
42 mysql “+“ 操作符的实现

42 mysql “+“ 操作符的实现

前言 问题来自于 chinaunix, mysql select 子句的小白问题 mysql 的一些基础的 算术运算符 的计算的实现 这里 整理如下 case, 执行之前 设置如下变量 set a 2; set b 3;select a b; select a b; select 1 3; select 1 3; select a b; select a b; select a b; …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023