首页 > 系统相关 >Qt编写跨平台的推流工具(支持win/linux/mac/嵌入式linux/安卓等)

Qt编写跨平台的推流工具(支持win/linux/mac/嵌入式linux/安卓等)

时间：2023-06-22 19:44:24浏览次数：52  
标签：return Qt formatCtxIn formatCtxOut ret 跨平台 linux debug 推流

一、前言

跨平台的推流工具当属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做推流，核心就是保存文件，只需要将保存文件的地址改成推流地址即可，是不是很简单，最开始没有做过的时候还以为有多复杂，吓得都不敢开工，估计也有不少人和我一样。

二、效果图


三、体验地址

  1. 国内站点：https://gitee.com/feiyangqingyun
  2. 国际站点：https://github.com/feiyangqingyun
  3. 个人作品：https://blog.csdn.net/feiyangqingyun/article/details/97565652
  4. 体验地址：https://pan.baidu.com/s/1d7TH_GEYl5nOecuNlWJJ7g 提取码：01jf 文件名：bin_video_push。

四、功能特点

  1. 支持各种本地视频文件和网络视频文件。
  2. 支持各种网络视频流，网络摄像头，协议包括rtsp、rtmp、http。
  3. 支持将本地摄像头设备推流，可指定分辨率和帧率等。
  4. 支持将本地桌面推流，可指定屏幕区域和帧率等。
  5. 自动启动流媒体服务程序，默认mediamtx（原rtsp-simple-server），可选用srs、EasyDarwin、LiveQing、ZLMediaKit等。
  6. 可实时切换预览视频文件。
  7. 推流的清晰度和质量可调。
  8. 可动态添加文件、目录、地址。
  9. 视频文件自动循环推流，如果视频源是视频流，在掉线后会自动重连。
  10. 网络视频流自动重连，重连成功自动继续推流。
  11. 网络视频流实时性极高，延迟极低，延迟时间大概在100ms左右。
  12. 极低CPU占用，4路主码流推流只需要占用0.2%CPU。理论上常规普通PC机器推100路毫无压力，主要性能瓶颈在网络。
  13. 推流可选推流到rtsp/rtmp两种，推流后的数据支持直接rtsp/rtmp/hls/webrtc四种方式访问，可以直接浏览器打开看实时画面。
  14. 可以推流到外网服务器，然后通过手机、电脑、平板等设备播放对应的视频流。
  15. 每个推流都可以手动指定唯一标识符（方便拉流/用户无需记忆复杂的地址），没有指定则按照策略随机生成hash值。
  16. 自动生成测试网页直接打开播放，可以看到实时效果，自动按照数量对应宫格显示。
  17. 推流过程中可以在表格中切换对应推流项，实时预览正在推流的视频，并可以切换视频文件的播放进度。
  18. 音视频同步推流，符合264/265/aac格式的自动原数据推流，不符合的自动转码再推流（会占用一定CPU）。
  19. 转码策略支持三种，自动处理（符合要求的原数据/不符合的转码），仅限文件（文件类型的转码视频），所有转码。
  20. 表格中实时显示每一路推流的分辨率和音视频数据状态，灰色表示没有输入流，黑色表示没有输出流，绿色表示原数据推流，红色表示转码后的数据推流。
  21. 支持Qt4/Qt5/Qt6任意版本，支持任意系统（windows/linux/macos/android/嵌入式linux等）。

五、相关代码

#include "ffmpegsavesimple.h"

//用法示例(保存文件/推流)
#if 0
FFmpegSaveSimple *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();
#endif

FFmpegSaveSimple::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();
}

标签：return,Qt,formatCtxIn,formatCtxOut,ret,跨平台,linux,debug,推流
From： https://www.cnblogs.com/feiyangqingyun/p/17498196.html

相关文章

  • win下 golang 跨平台编译
    本篇文章是win下的跨平台编译。安装GCC编译器（MinGW）我们需要GCC编译环境,这里我选择的是：MinGW。mac下安装了Xcode自动就带了GCC，win下没有，所以我们用MinGW这个最小化安装的GCC。MinGW官网提供了一种自动在线下载安装的gui小程序，http://sourceforge.net/projects/mingw/files/Install......
  • linux中用crontab定时任务启动jar无效的问题
    原文链接：https://blog.csdn.net/for_the_time_begin/article/details/113940508问题：使用linux系统中的定时任务执行jar包，但是经过测试发现一只不能正常执行，发现定时任务crontab是正常运行的，因为再写一个测试用的定时任务指定时间在指定的目录位置下生成一个文件，或者向文件中追......
  • linux 中printf函数
     001、输出字符串[root@PC1test01]#printf"abcd\n"abcd[root@PC1test01]#printf"%s\n""abcd"##输出字符串abcd 002、指定宽度[root@PC1test01]#printf"%s\n""abcd"abcd[root@PC1test01]#printf&quo......
  • 记一次服务程序调试过程(linux进程打开文件句柄过多问题)
    最近在测试服务程序，对外提供HTTP服务（使用c++调用libevent实现，回调使用curl库）。开始测试几百个请求时，功能一直挺正常。但是加大请求数量后（请求量大于5000），出现很奇怪的现场，每次接收的响应大约在3400个左右时，服务程序不再返回响应。开始怀疑是http服务异常了，使用http工具单独再发请......
  • STM32-mp157-A核Linux
    A核开发环境网卡连接1.NAT虚拟网卡连接互联网2.桥接（真实）网卡连接开发板ubuntu新建NAT网卡；设置桥接模式；搜索vmnet以管理员身份打开；设置桥接网卡为目标usb网卡；打开虚拟机linux网络设置；设置静态IPv4同一网段；ifconfig命令查看；打开windows网络设置；设置静态IPv4同一网段；打开终......
  • Linux系统的CVE该如何确认？学会这个方法不用慌！
    在维护过程中，应用系统免不了被客户做定期的漏扫，运维需要根据客户的扫描结果进行反馈是否涉及和是否能整改，本文主要针对LinuxCVE漏洞进行一个基本的排查。一、什么是CVE漏洞？CVE是CommonVulnerabilitiesandExposures的缩写，意思是“常见漏洞披露”。它是一个由Microsoft、Goog......
  • Linux Nacos2.2.0版本集群搭建，常见报错问题解决
    准备：服务器，nacos，mysql，nginx，java，mavenNacos官网：https://nacos.io下载地址github：https://github.com/alibaba/nacos相关版本问题，见nacos官网手册查看集群配置图：官方的： 本次搭建集群配置图：开始搭建：修改nacos的配置文件“application.properties，cluster.conf.ex......
  • Ubuntu linux 为啥要开始选择ubuntu LINUX
    开头还是介绍一下群，如果感兴趣polardb,mongodb,mysql,postgresql,redis等有问题，有需求都可以加群群内有各大数据库行业大咖，CTO，可以解决你的问题。其实纠结这个问题也是很长时间了，因为一个玩数据库的讨论系统的问题，也是在是不合场景。但没有办法，搞数据库的数据库也的在操作系统......
  • LoadRunner 监控到的Linux服务器CPU的一些主要指标说明
    CPU的主要指标：CPUUtilizationCPU使用率，CPU的使用时间百分比，75%以上就比较高了。在任意时间内,CPU有7个状态:1.idle,表示CPU闲置并等待工作分配.2.user,表示CPU在运行用户的进程3.system,表示CPU在执行kernel工作4.nice,表示CPU花费在被nice改变过优先级的process......
  • Archlinux安装OSX-KVM(无显卡直通)
    0.前期准备qemu虚拟机安装（可以参考Archwiki,或者是我的其他教程）OSX-KVM项目文件下载（这个项目支持macos10-13）https://github.com/kholia/OSX-KVMMacOS的iso镜像（我使用的是macos12Monterey）https://sysin.org1.磁盘文件创建在/var/lib/libvirt/images/创建qcow2磁盘文件,名为......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99