一、前言 跨平台的推流工具当属OBS最牛逼,功能也是最强大的,唯一的遗憾就是多路推流需要用到插件,而且CPU占用比较高,默认OBS的规则是将对应画布中的视频画面和设定的音频一起重新编码再推流,意味着肯
跨平台的推流工具当属OBS最牛逼,功能也是最强大的,唯一的遗憾就是多路推流需要用到插件,而且CPU占用比较高,默认OBS的规则是将对应画布中的视频画面和设定的音频一起重新编码再推流,意味着肯定占用不少CPU资源,而很多时候尤其是视频监控行业,往往源头的摄像头的视频流就是标准的264/265/aac格式,其实无需重新编码就可以推流,就相当写文件一样,只需要极低极低的CPU运算资源,一路1080P基本上占用在0.1%以下,而OBS可以直接干到5%,这就差距有点大了,几十倍的差距,毕竟重新编码哪怕是硬编码,肯定需要占用不少的CPU。而用户的真实需求可能是要求500路摄像头推流,用OBS肯定是达不到的,10路都卡成屎,毕竟OBS面对的不是视频监控行业的应用场景,而是视频直播行业,视频直播行业要的是各种特效,画面的自定义,音频的自定义,要求在一路上面可以各种各样的自定义。为此本工具应运而生,主要针对极低资源占用的多路推流,同时能够跨平台运行,包括但不限于windows/linux/Mac/安卓/嵌入式linux/树莓派等。
既然要求跨平台,那用Qt开发是首选,OBS本身也是Qt开发的,在各个平台上也能正常编译运行。只要代码中没有特别依赖对应操作系统的api接口函数的,源码都可以直接在其他平台编译运行。其实用FFmpeg做推流,核心就是保存文件,只需要将保存文件的地址改成推流地址即可,是不是很简单,最开始没有做过的时候还以为有多复杂,吓得都不敢开工,估计也有不少人和我一样。
#include "ffmpegsavesimple.h"//用法示例(保存文件/推流)#if 0FFmpegSaveSimple *f = new FFmpegSaveSimple(this);f->setUrl("f:/mp4/1.mp4", "f:/1.mp4");f->setUrl("f:/mp4/1.mp4", "rtmp://127.0.0.1:6908/stream");f->start();#endifFFmpegSaveSimple::FFmpegSaveSimple(QObject *parent) : QThread(parent){ stopped = false; audioIndex = -1; videoIndex = -1; fORMatCtxIn = NULL; formatCtxOut = NULL; //初始化ffmpeg的库 FFmpegHelper::initLib();}FFmpegSaveSimple::~FFmpegSaveSimple(){ this->stop(); this->close();}void FFmpegSaveSimple::run(){ if (!this->open()) { this->close(); return; } int ret; AVPacket packet; qint64 videoCount = 0; qint64 startTime = av_gettime(); while (!stopped) { //读取一帧 ret = av_read_frame(formatCtxIn, &packet); int index = packet.stream_index; if (ret < 0) { if (ret == AVERROR_EOF || ret == AVERROR_EXIT) { debug(ret, "文件结束"); break; } else { debug(ret, "读取出错"); continue; } } //取出输入输出流的时间基 AVStream *streamIn = formatCtxIn->streams[index]; AVStream *streamOut = formatCtxOut->streams[index]; AVRational timeBaseIn = streamIn->time_base; AVRational timeBaseOut = streamOut->time_base; if (index == videoIndex) { videoCount++; } //纠正有些文件比如h264格式的没有pts if (packet.pts == AV_NOPTS_VALUE) { qreal fps = av_q2d(formatCtxIn->streams[videoIndex]->r_frame_rate); FFmpegHelper::rescalePacket(&packet, timeBaseIn, videoCount, fps); } //延时(防止数据太快给缓存造成太大压力) if (index == videoIndex) { AVRational timeBase = {1, AV_TIME_BASE}; int64_t ptsTime = av_rescale_q(packet.dts, timeBaseIn, timeBase); int64_t nowTime = av_gettime() - startTime; if (ptsTime > nowTime) { av_usleep(ptsTime - nowTime); } } //重新调整时间基准 FFmpegHelper::rescalePacket(&packet, timeBaseIn, timeBaseOut); qDebug() << TIMEMS << "发送一帧" << videoCount << packet.flags << packet.pts << packet.dts; //ret = av_write_frame(formatCtxOut, &packet); ret = av_interleaved_write_frame(formatCtxOut, &packet); if (ret < 0) { debug(ret, "写数据包"); break; } av_packet_unref(&packet); } //写文件尾 av_write_trailer(formatCtxOut); this->close();}bool FFmpegSaveSimple::open(){ if (urlIn.isEmpty() || urlOut.isEmpty()) { return false; } int ret = -1; if ((ret = avformat_open_input(&formatCtxIn, urlIn.toUtf8().constData(), 0, NULL)) < 0) { debug(ret, "打开输入"); return false; } if ((ret = avformat_find_stream_info(formatCtxIn, 0)) < 0) { debug(ret, "无流信息"); return false; } videoIndex = av_find_best_stream(formatCtxIn, AVMEDIA_TYPE_VIDEO, -1, -1, NULL, 0); if (videoIndex < 0) { debug(ret, "无视频流"); return false; } //既可以是保存到文件也可以是推流(对应格式要区分) const char *format = "mp4"; if (urlOut.startsWith("rtmp://")) { format = "flv"; } else if (urlOut.startsWith("rtsp://")) { format = "rtsp"; } QByteArray urlData = urlOut.toUtf8(); const char *url = urlData.constData(); ret = avformat_alloc_output_context2(&formatCtxOut, NULL, format, url); if (!formatCtxOut) { debug(ret, "创建输出"); return false; } //根据输入流创建输出流 for (int i = 0; i < formatCtxIn->nb_streams; i++) { AVStream *streamIn = formatCtxIn->streams[i]; AVStream *streamOut = avformat_new_stream(formatCtxOut, NULL); if (!streamOut) { return false; } //复制各种参数 ret = FFmpegHelper::copyContext(streamIn, streamOut); if (ret < 0) { debug(ret, "复制参数"); return false; } } //打开输出 if (!(formatCtxOut->oformat->flags & AVFMT_NOFILE)) { ret = avio_open(&formatCtxOut->pb, url, AVIO_FLAG_WRITE); if (ret < 0) { debug(ret, "打开输出"); return false; } } //写文件头 ret = avformat_write_header(formatCtxOut, NULL); if (ret < 0) { debug(ret, "写文件头"); return false; } debug(0, QString("打开成功: %1").arg(urlIn)); if (format != "mp4") { debug(0, QString("开始推流: %1").arg(urlOut)); } else { debug(0, QString("开始录像: %1").arg(urlOut)); } return true;}void FFmpegSaveSimple::close(){ stopped = false; if (formatCtxOut) { debug(0, QString("关闭成功: %1").arg(urlIn)); } if (formatCtxIn) { avformat_close_input(&formatCtxIn); formatCtxIn = NULL; } if (formatCtxOut && !(formatCtxOut->oformat->flags & AVFMT_NOFILE)) { avio_close(formatCtxOut->pb); } if (formatCtxOut) { avformat_free_context(formatCtxOut); formatCtxOut = NULL; }}void FFmpegSaveSimple::debug(int ret, const QString &msg){ QString text = (ret < 0 ? QString("%1 错误: %2").arg(msg).arg(FFmpegHelper::getError(ret)) : msg); qDebug() << TIMEMS << text;}void FFmpegSaveSimple::setUrl(const QString &urlIn, const QString &urlOut){ this->urlIn = urlIn; this->urlOut = urlOut;}void FFmpegSaveSimple::stop(){ this->stopped = true; this->wait();}
来源地址:https://blog.csdn.net/feiyangqingyun/article/details/131343675
--结束END--
本文标题: Qt/C++编写跨平台的推流工具(支持win/linux/mac/嵌入式linux/安卓等)
本文链接: https://www.lsjlt.com/news/395300.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0