流媒体服务器SRS的搭建及QT下RTMP推流客户端的编写

news2024/11/24 2:14:42

一、前言

    目前市面上有很多开源的流媒体服务器解决方案，常见的有SRS、EasyDarwin、ZLMediaKit和Monibuca。这几种的对比如下：
在这里插入图片描述
（本图来源：https://www.ngui.cc/zz/1781086.html?action=onClick）

二、SRS的介绍

    SRS（Simple Real-time Server）是一个开源的流媒体服务器，它支持RTMP、HLS、HTTP-FLV等多种流媒体协议。SRS提供了丰富的功能，包括推流、拉流、转码、录制、转发等，并且具有高性能、低延迟的特点。使用SRS可以搭建自己的流媒体服务器，实现音视频的实时传输和播放。你可以通过SRS推送音视频流到服务器，也可以从SRS服务器拉取音视频流进行播放或者转发给其他客户端。SRS支持多线程推拉流，可以利用多核处理器的优势，提高处理能力和并发性能。在使用多线程推拉流时，需要注意线程同步和数据共享的问题。

三、SRS的搭建

3.1 下载

虚拟机环境：CentOS 7 64位

SRS下载地址：https://gitcode.net/mirrors/ossrs
（SRS 4.0以上版本,4.0版本以下不支持GB/28181协议）

3.2 配置、编译、运行

下载后，解压到CentOS 7目录下（注意不要在共享目录下操作不然会出现ln软链接错误问题）。

1）执行配置命令：

cd srs/trunk
./configure

在这里插入图片描述

2）执行编译命令：

make

在这里插入图片描述

3）执行运行命令：

./etc/init.d/srs start

在这里插入图片描述
配置文件位置在：conf/srs.conf，可修改配置文件内容：
在这里插入图片描述

4）检查srs服务启动是否正常：

ps -ef | grep srs

在这里插入图片描述

3.3 网页登录

（默认端口8080） 红框中的为推流地址
在这里插入图片描述

四、QT下推流客户端

    本客户端基于我的博客：https://blog.csdn.net/linyibin_123/article/details/132107948 开发的播放器下新增RTMP推流。
播放器可以支持软硬解码，截图、录像等功能，详细功能看该博客。本客户端支持读取文件解码后推流，也支持拉取网络流解码后进行推流。推流地址为前面搭建的RTMP流媒体服务器，推流成功后，通过VLC播放器从RTMP服务器上拉流下来播放。

4.1 读取本地文件解码后推流：

在这里插入图片描述

4.2 拉取网络流解码后推流：

在这里插入图片描述

4.3 相关代码：

初始化推流：

bool ctFFmpeg::initPushStream()
{
    if(m_bEnablePush)
    {
        int nRet = avformat_alloc_output_context2(&m_pOfmtCtx, nullptr, "flv", m_sRtmpServerAddr.toUtf8().data());
        if(!m_pOfmtCtx || nRet < 0)
        {
            MY_DEBUG << "avformat_alloc_output_context2 failed";
            return false;
        }

        m_pOvCodec = avcodec_find_encoder(AV_CODEC_ID_H264);
        if(!m_pOvCodec)
        {
            MY_DEBUG << "avcodec_find_encoder failed";
            return false;
        }

        m_pOvCodecCtx = avcodec_alloc_context3(m_pOvCodec);
        if(!m_pOvCodecCtx)
        {
            MY_DEBUG << "avcodec_alloc_context3 failed";
            return false;
        }

        m_pOvCodecCtx->pix_fmt = AV_PIX_FMT_YUV420P;
        m_pOvCodecCtx->width = m_nVideoW;
        m_pOvCodecCtx->height = m_nVideoH;
        m_pOvCodecCtx->time_base.num = 1;
        m_pOvCodecCtx->time_base.den = 25;
        m_pOvCodecCtx->bit_rate = 300000;
        m_pOvCodecCtx->gop_size = 250;

        //Some formats want stream headers to be separate.
        if (m_pOfmtCtx->oformat->flags & AVFMT_GLOBALHEADER)
            m_pOvCodecCtx->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;

        m_pOvCodecCtx->qmin = 10;
        m_pOvCodecCtx->qmax = 51;
        m_pOvCodecCtx->max_b_frames = 0;

        AVDictionary *param = 0;
        av_dict_set(&param, "preset", "fast", 0);
        av_dict_set(&param, "tune", "zerolatency", 0);

        if (avcodec_open2(m_pOvCodecCtx, m_pOvCodec, &param) < 0)
        {
            MY_DEBUG << "avcodec_open2 failed.";
            return false;
        }

        m_pVideoSt = avformat_new_stream(m_pOfmtCtx, m_pOvCodec);
        if (nullptr == m_pVideoSt)
        {
            MY_DEBUG << "avformat_new_stream failed.";
            return false;
        }

        m_pVideoSt->time_base.num = 1;
        m_pVideoSt->time_base.den = 30;

        avcodec_parameters_from_context(m_pVideoSt->codecpar, m_pOvCodecCtx);
        av_dump_format(m_pOfmtCtx, 0, m_sRtmpServerAddr.toLatin1().data(), 1);

        //Open output URL
        if (!(m_pOfmtCtx->oformat->flags & AVFMT_NOFILE))
        {
            nRet = avio_open(&m_pOfmtCtx->pb, m_sRtmpServerAddr.toLatin1().data(), AVIO_FLAG_READ_WRITE);
            if (nRet < 0)
            {
                MY_DEBUG << "avio_open failed. url:" << m_sRtmpServerAddr;
                return false;
            }
        }

        m_pOfmtCtx->video_codec_id = m_pOfmtCtx->oformat->video_codec;

        nRet = avformat_write_header(m_pOfmtCtx, NULL);
        if (nRet < 0)
        {
            MY_DEBUG << "avformat_write_header failed. nRet：" << nRet;
            return false;
        }

        m_pOutFrameYUV = av_frame_alloc();

        int nBufferSize = av_image_get_buffer_size(AV_PIX_FMT_YUV420P, m_nVideoW, m_nVideoH, 1);

        m_pOutDstBuffer = (unsigned char*)av_malloc(nBufferSize);
        if (!m_pOutDstBuffer)
        {
            return false;
        }

        MY_DEBUG << "storeAvFrame 111";

        nRet = av_image_fill_arrays(m_pOutFrameYUV->data, m_pOutFrameYUV->linesize,
                                        m_pOutDstBuffer, AV_PIX_FMT_YUV420P, m_nVideoW, m_nVideoH, 1);
        if(nRet < 0)
        {
            return false;
        }

        m_pImgConvertCtx = sws_getContext(m_pVideoCodecCxt->width, m_pVideoCodecCxt->height,
                                          m_pVideoCodecCxt->pix_fmt, m_pVideoCodecCxt->width,
                                          m_pVideoCodecCxt->height, AV_PIX_FMT_YUV420P, SWS_BICUBIC, NULL, NULL, NULL);

        m_nStartTime = av_gettime();
        m_nFramecnt = 0;

        return true;
    }
    return false;
}

推流过程：

void ctFFmpeg::pushStream()
{
    if(m_bEnablePush && m_bSupportPush && m_pYuvFrame)
    {
        sws_scale(m_pImgConvertCtx, (const uint8_t* const*)m_pYuvFrame->data, m_pYuvFrame->linesize, 0,
                  m_pVideoCodecCxt->height, m_pOutFrameYUV->data, m_pOutFrameYUV->linesize);

        m_pOutFrameYUV->width = m_pYuvFrame->width;
        m_pOutFrameYUV->height = m_pYuvFrame->height;
        m_pOutFrameYUV->format = AV_PIX_FMT_YUV420P;

        m_encPkt.data = NULL;
        m_encPkt.size = 0;
        av_init_packet(&m_encPkt);

        int nRet = avcodec_send_frame(m_pOvCodecCtx, m_pOutFrameYUV);
        while(nRet >= 0)
        {
            nRet = avcodec_receive_packet(m_pOvCodecCtx, &m_encPkt);
            if (nRet == AVERROR(EAGAIN) || nRet == AVERROR_EOF || nRet < 0)
            {
                //MY_DEBUG << "avcodec_receive_packet nRet == AVERROR(EAGAIN) || nRet == AVERROR_EOF";
                break;
            }

            m_nFramecnt++;
            m_encPkt.stream_index = m_pVideoSt->index;

            //av_packet_rescale_ts(&pkt, m_pOvCodecCtx->time_base, m_pVideoSt->time_base);

            AVRational time_base = m_pOfmtCtx->streams[0]->time_base;//{ 1, 1000 };
            AVRational time_base_q = {1, AV_TIME_BASE};
            AVRational rFramerate1 = m_pAVFmtCxt->streams[0]->r_frame_rate;
            int64_t nCalcDuration = (double)(AV_TIME_BASE)*(1 / av_q2d(rFramerate1));	//内部时间戳
            //Parameters
            m_encPkt.pts = av_rescale_q(m_nFramecnt*nCalcDuration, time_base_q, time_base);
            m_encPkt.dts = m_encPkt.pts;
            m_encPkt.duration = av_rescale_q(nCalcDuration, time_base_q, time_base);
            m_encPkt.pos = -1;

            //MY_DEBUG << "m_encPkt.pts:" << m_encPkt.pts;

            int64_t pts_time = av_rescale_q(m_encPkt.pts, time_base, time_base_q);
            int64_t now_time = av_gettime() - m_nStartTime;
            if ((pts_time > now_time))
                av_usleep(pts_time - now_time);

            nRet = av_interleaved_write_frame(m_pOfmtCtx, &m_encPkt);
            if(nRet < 0)
            {
                MY_DEBUG << "av_interleaved_write_frame fail nRet:" << nRet;
            }
            av_packet_unref(&m_encPkt);
        }
    }
}

结束推流：

void ctFFmpeg::endPushStream()
{
    if(m_bEnablePush && m_bSupportPush)
    {
        av_write_trailer(m_pOfmtCtx);

        if (m_pOfmtCtx && !(m_pOfmtCtx->oformat->flags & AVFMT_NOFILE))
            avio_close(m_pOfmtCtx->pb);

        avformat_free_context(m_pOfmtCtx);

        if(nullptr != m_pOvCodecCtx)
        {
            avcodec_free_context(&m_pOvCodecCtx);
            m_pOvCodecCtx = nullptr;
        }

        if(m_pOutDstBuffer)
            av_free(m_pOutDstBuffer);
    }
}

五、客户端下载：

https://download.csdn.net/download/linyibin_123/88237527

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

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

相关文章

没有抛出任何异常突然报错是怎么回事—多线程异常没有抛出

没有抛出任何异常突然报错是怎么回事—多线程异常没有抛出

工作内容&#xff0c;不对外开放
阅读更多...
SSRF 服务器端请求伪造

SSRF 服务器端请求伪造

文章目录 SSRF(curl)网址访问通过file协议访问本地文件dict协议扫描内网主机开放端口 SSRF(file_get_content)网站访问http协议请求内网资源通过file协议访问本地文件 SSRF(Server-Side Request Forgery:服务器端请求伪造) 其形成的原因大都是由于服务端提供了从其他服务器应用…
阅读更多...
FastJson在Java后端方面解析使用(二)

FastJson在Java后端方面解析使用(二)

​ JSON现在常用来做前后端数据交互&#xff0c;两个蝴蝶飞只是简单的对JSON做一下讲解和简单使用。关于JSON,我还了解的远远不够。由于本人经验有限&#xff0c;嘴皮子不溜&#xff0c;所以学术性&#xff0c;概念性&#xff0c;底层性的知识点暂时不做介绍。文章中有错误之处…
阅读更多...
教育行业选择CRM系统需具备的四大功能

教育行业选择CRM系统需具备的四大功能

教育行业的发展一波三折&#xff0c;要想在激烈的赛道脱颖而出&#xff0c;就需要有一套有效的CRM系统&#xff0c;来帮助教育机构提升招生效率、增加学员留存、提高教学质量。那么&#xff0c;教育行业的CRM系统要具备哪些功能&#xff1f; 招生管理&#xff1a; 教育机构的…
阅读更多...
STM32入门——SPI通讯

STM32入门——SPI通讯

江科大STM32学习记录 SPI通信 SPI&#xff08;Serial Peripheral Interface&#xff09;是由Motorola公司开发的一种通用数据总线四根通信线&#xff1a;SCK&#xff08;Serial Clock&#xff09;、MOSI&#xff08;Master Output Slave Input&#xff09;、MISO&#xff08;…
阅读更多...
log4j2配置文件的加载顺序

log4j2配置文件的加载顺序

文章目录 如果同时存在 log4j2-test.xml 和 log4j2.xml 文件 那么默认先加载 log4j2-test.xml&#xff0c;而不是log4j2.xml 官方文档介绍&#xff1a;https://logging.apache.org/log4j/2.x/manual/configuration.html 以下内容来自官方文档翻译&#xff1a; Log4j 2 的配置…
阅读更多...
淘宝商品详情采集接口item_get-获得淘宝商品详情（可高并发线程）

淘宝商品详情采集接口item_get-获得淘宝商品详情（可高并发线程）

获得淘宝商品详情页面数据采集如下&#xff1a; taobao.item_get 公共参数 名称类型必须描述keyString是调用key&#xff08;必须以GET方式拼接在URL中&#xff09;注册key账号接入secretString是调用密钥api_nameString是API接口名称&#xff08;包括在请求地址中&#xff0…
阅读更多...
动手学深度学习—深度卷积神经网络AlexNet（代码详解）

动手学深度学习—深度卷积神经网络AlexNet（代码详解）

AlexNet 1. 学习表征1.1 缺少的成分&#xff1a;数据1.2 缺少的成分&#xff1a;硬件 2. AlexNet2.1 模型设计2.2 激活函数2.3 容量控制和预处理 3. 读取数据集4. 训练AlexNet ImageNet classification with deep convolutional neural networks 原文链接&#xff1a;https://d…
阅读更多...
尚品汇项目（Day1）

尚品汇项目（Day1）

项目结构介绍 vue-cli 脚手架初始化项目 node webpack 淘宝镜像 node_modules文件夹&#xff1a;项目依赖文件夹 public文件夹&#xff1a;一般放置静态资源&#xff08;图片&#xff09;&#xff0c;需要注意&#xff1a;放在public文件夹中的静态资源&#xff0c;webpac…
阅读更多...
套接字属性设置

套接字属性设置

基本概念 设置套接字的选项对套接字进行控制除了设置选项外&#xff0c;还可以获取选项选项的概念相当于属性&#xff0c;所以套接字选项也可说是套接字属性有些选项&#xff08;属性&#xff09;只可获取&#xff0c;不可设置有些选项既可设置也可获取 选项级别 SOL_SOCKET的…
阅读更多...
功能性需求与非功能性需求的区别

功能性需求与非功能性需求的区别

如果你曾经负责过软件项目开展的全过程&#xff0c;就会知道需求定义在项目后期的重要性。清晰、明确的需求定义不仅有助于有效地管理客户期望&#xff0c;也有助于指导项目的顺利开展。 在项目前期阶段&#xff0c;如果需求定义不清晰&#xff0c;就会导致项目范围和成果定义…
阅读更多...
Prompt-“设计提示模板：用更少数据实现预训练模型的卓越表现，助力Few-Shot和Zero-Shot任务”

Prompt-“设计提示模板：用更少数据实现预训练模型的卓越表现，助力Few-Shot和Zero-Shot任务”

Prompt任务&#xff08;Prompt Tasks&#xff09; 通过设计提示&#xff08;prompt&#xff09;模板&#xff0c;实现使用更少量的数据在预训练模型&#xff08;Pretrained Model&#xff09;上得到更好的效果&#xff0c;多用于&#xff1a;Few-Shot&#xff0c;Zero-Shot 等…
阅读更多...
java.net.UnknownHostException 解决方法

java.net.UnknownHostException 解决方法

原文链接&#xff1a;https://blog.csdn.net/qq_39390545/article/details/108755289 以下为复盘这里笔记 一般原因 1.服务器没网&#xff0c;调不到公网域名&#xff0c;无法解析出IP&#xff0c;从而无法识别host&#xff0c;导致无法连接&#xff1b; 2.网络端口映射做了…
阅读更多...
最长有效括号——力扣32

最长有效括号——力扣32

int longestValidParentheses(string s){int res=0, n=s.size();int left=0
阅读更多...
并查集 rank 的优化（Java 实例代码）

并查集 rank 的优化（Java 实例代码）

目录 并查集 rank 的优化 Java 实例代码 UnionFind3.java 文件代码&#xff1a; 并查集 rank 的优化 上一小节介绍了并查集基于 size 的优化&#xff0c;但是某些场景下&#xff0c;也会存在某些问题&#xff0c;如下图所示&#xff0c;操作 union(4,2)。 根据上一小节&…
阅读更多...
三层架构实验

三层架构实验

6 / 100 撤消 重做历史标题 加粗 颜色 背景其他列表对齐 水平线 块引用代码 资源绑定 表格 图像 视频 公式 链接 模版 目录 投票 宽屏 使用 MD 编辑器 文章标签 经验分享 添加文章标签 添加封面 标签图热门VIP 本地上传 思路&#xff1a;先配三层交换机&#xff0c;绑通道…
阅读更多...
Pyqt5-开源工具分解功能(配置文件+快捷写入)

Pyqt5-开源工具分解功能(配置文件+快捷写入)

开源第五篇，配置文件及参数配置，先来看个图： 上述是自动化电池监测的简图。会根据json文件中的数据从而自动写入数据。 如何自动写入数据 从GIF中可以看到，选中的输入的标签都是QLineEdit，而QLineEdit的写入文本方法是.setText(str)，注意这里是写入的文本是text，字符串。…
阅读更多...
smiley-http-proxy-servlet 实现springboot 反向代理，项目鉴权，安全的引入第三方项目服务

smiley-http-proxy-servlet 实现springboot 反向代理，项目鉴权，安全的引入第三方项目服务

背景&#xff1a; 项目初期 和硬件集成&#xff0c;实现了些功能服务&#xff0c;由于是局域网环境&#xff0c;安全问题当时都可以最小化无视。随着对接的服务越来越多&#xff0c;部分功能上云&#xff0c;此时就需要有一种手段可以控制到其他项目/接口的访问权限。 无疑 反向…
阅读更多...
亿赛通电子文档安全管理系统 RCE漏洞复现(QVD-2023-19262)

亿赛通电子文档安全管理系统 RCE漏洞复现(QVD-2023-19262)

0x01 产品简介 亿赛通电子文档安全管理系统&#xff08;简称&#xff1a;CDG&#xff09;是一款电子文档安全加密软件&#xff0c;该系统利用驱动层透明加密技术&#xff0c;通过对电子文档的加密保护&#xff0c;防止内部员工泄密和外部人员非法窃取企业核心重要数据资产&…
阅读更多...
wifi-RTL8723-RK3568

wifi-RTL8723-RK3568

文章目录 前言一、RTL8723DU二、原理图三、设备树四、修改drivers/net/wireless/rockchip_wlan目录下文件五、修改RTL8723DU代码工程修改Makefile文件修改驱动入口函数其他说明效果前言 本文主要介绍如何在RK3568平台下，参考官方文档移植RTL8723DU这款wifi模块 提示：以下是本…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023