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

一、前言

    目前市面上有很多开源的流媒体服务器解决方案，常见的有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

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

十一、hadoop应用

十一、hadoop应用

1.上传数据集 27.19.74.143,2015/3/30 17:38,/static/image/common/faq.gif 110.52.250.126,2015/3/30 17:38,/data/cache/style_1_widthauto.css?y7a 27.19.74.143,2015/3/30 17:38,/static/image/common/hot_1.gif 27.19.74.143,2015/3/30 17:38,/static/image/common/hot_2…
阅读更多...
MyBatid动态语句且模糊查询

MyBatid动态语句且模糊查询

目录 什么是MyBtais动态语句&#xff1f;&#xff1f;&#xff1f; MyBatis常用的动态标签和表达式 if标签 Choose标签 where标签 MyBatis模糊查询 #与$的区别 ​编辑 MyBatis映射 resultType resultMap 什么是MyBtais动态语句&#xff1f;&#xff1f;&#xff1f;…
阅读更多...
云LIS云实验室信息管理系统源码，支持IIS独立部署，Docker部署

云LIS云实验室信息管理系统源码，支持IIS独立部署，Docker部署

云LIS技术架构&#xff1a;Asp.NET CORE 3.1 MVC SQLserver Redis等。 云LIS系统是医院信息管理的重要组成部分之一&#xff0c;它是一个基于B/S架构开发的实验室信息管理系统。整个系统的运行基于WEB层面&#xff0c;只需要在对应的工作台安装一个浏览器软件&#xff0c;有外…
阅读更多...
Codeforces Round #894 (Div.3)

Codeforces Round #894 (Div.3)

文章目录 前言A. Gift Carpet题目&#xff1a;输入&#xff1a;输出&#xff1a;思路&#xff1a;代码&#xff1a; B. Sequence Game题目&#xff1a;输入&#xff1a;输出&#xff1a;思路&#xff1a;代码&#xff1a; C. Flower City Fence题目&#xff1a;输入&#xff1a…
阅读更多...
如何开发智慧农牧软件

如何开发智慧农牧软件

【引言】随着科技的不断进步&#xff0c;智慧农牧软件在农业和畜牧业领域发挥着重要作用&#xff0c;帮助农牧业提高生产效率、降低成本、提升农产品质量。本文将深入探讨智慧农牧软件的开发&#xff0c;结合专业性和创新之处&#xff0c;为读者提供一份全面的开发方案。 【…
阅读更多...
微服务 Nacos配置热部署

微服务 Nacos配置热部署

在nacos中添加配置文件 在配置列表中添加配置&#xff0c; 注意&#xff1a;项目的核心配置&#xff0c;需要热更新的配置才有放到nacos管理的必要。基本不会变更的一些配置还是保存在微服务本地比较好。 从微服务拉取配置 微服务要拉取nacos中管理的配置&#xff0c;并且与…
阅读更多...
Android项目如何上传Gitee仓库

Android项目如何上传Gitee仓库

前言 最近Android项目比较多&#xff0c;我都是把Android项目上传到Gitee中去&#xff0c;GitHub的话我用的少&#xff0c;可能我还是更喜欢Gitee吧&#xff0c;毕竟Gitee仓库用起来更加方便 一. 创建Gitee仓库 1. 先创建一个Gitee账号&#xff0c;然后登录上去 2. 创建Androi…
阅读更多...
使用 Amazon Redshift Serverless 和 Toucan 构建数据故事应用程序

使用 Amazon Redshift Serverless 和 Toucan 构建数据故事应用程序

这是由 Toucan 的解决方案工程师 Django Bouchez与亚马逊云科技共同撰写的特约文章。 带有控制面板、报告和分析的商业智能&#xff08;BI&#xff0c;Business Intelligence&#xff09;仍是最受欢迎的数据和分析使用场景之一。它为业务分析师和经理提供企业的过去状态和当前状…
阅读更多...
opencv-全景图像拼接

opencv-全景图像拼接

运行环境 python3.6 opencv 3.4.1.15 stitcher.py import numpy as np import cv2class Stitcher:#拼接函数def stitch(self, images, ratio0.75, reprojThresh4.0,showMatchesFalse):#获取输入图片(imageB, imageA) images#检测A、B图片的SIFT关键特征点&#xff0c;并计算…
阅读更多...
vue 简单实验 自定义组件 独立模块

vue 简单实验 自定义组件 独立模块

1.概要 2.代码 2.1 const Counter {data() {return {counter: 0}},template:<div>Counter: {{ counter }}</div> }export default Counter 2.2 import Counter from ./t2.jsconst app Vue.createApp({components: {component-a: Counter} })app.mount(#count…
阅读更多...
Docker 的数据管理与镜像

Docker 的数据管理与镜像

Docker 的数据管理与镜像 一、Docker 的数据管理1.数据卷2.数据卷容器3.端口映射4.容器互联&#xff08;使用centos镜像&#xff09; 二、Docker 镜像的创建1.基于现有镜像创建2.基于本地模板创建3.基于Dockerfile 创建 三、Dockerfile 操作常用的指令&#xff1a;1.FROM 镜像2…
阅读更多...
科技资讯|三星再申请智能戒指商标，智能穿戴进入更小型化发展

科技资讯|三星再申请智能戒指商标，智能穿戴进入更小型化发展

三星正在积极扩展可穿戴设备生态&#xff0c;近日向英国知识产权局提交了名为“Samsung Curio”的新商标&#xff0c;其分类为“Class 9”&#xff0c;可能会用于未来的智能戒指。 智能戒指&#xff1a; 可穿戴计算机本质上的智能手环、智能项链、智能眼镜和智能戒指&#xff1…
阅读更多...
【实操干货】如何开始用Qt Widgets编程？（三）

【实操干货】如何开始用Qt Widgets编程？（三）

Qt 是目前最先进、最完整的跨平台C开发工具。它不仅完全实现了一次编写&#xff0c;所有平台无差别运行&#xff0c;更提供了几乎所有开发过程中需要用到的工具。如今&#xff0c;Qt已被运用于超过70个行业、数千家企业&#xff0c;支持数百万设备及应用。 在本文中&#xff0…
阅读更多...
三维重建_体素重建_空间雕刻法/体素着色法

三维重建_体素重建_空间雕刻法/体素着色法

目录 1. 三角化和体素重建的区别 2. 空间雕刻法 空间雕刻法的一致性定义 空间雕刻法具体实现 基于八叉树的空间雕刻法具体实现​编辑 空间雕刻法效果展示 3. 体素着色法 体素着色法的缺点&#xff1a;不唯一性​编辑 体素着色法不唯一性解决措施​编辑 体素着色发实验环境与…
阅读更多...
基于 SVG 的图形交互方案实践

基于 SVG 的图形交互方案实践

不知道从什么时候起&#xff0c;人们开始喜欢上数字大屏这种“花里胡哨”的东西&#xff0c;仿佛只要用上“科技蓝”这样神奇的色调&#xff0c;就可以让一家公司焕然一新&#xff0c;瞬间变得科技感满满。不管数字大屏的实际意义&#xff0c;是用来帮助企业监控和决策&#xf…
阅读更多...
PyTorch DataLoader 报错 “DataLoader worker exited unexpectedly“ 的解决方案

PyTorch DataLoader 报错 “DataLoader worker exited unexpectedly“ 的解决方案

注意&#xff1a;博主没有重写d2l的源代码文件&#xff0c;而是创建了一个新的python文件&#xff0c;并重写了该方法。 一、代码运行日志 C:\Users\Administrator\anaconda3\envs\limu\python.exe G:/PyCharmProjects/limu-d2l/ch03/softmax_regression.py Traceback (most r…
阅读更多...
solidity0.8.0的应用案例12：通用可升级合约UUPS

solidity0.8.0的应用案例12：通用可升级合约UUPS

代理合约中选择器冲突（Selector Clash）的另一个解决办法：通用可升级代理（UUPS，universal upgradeable proxy standard）。代码由OpenZeppelin的UUPSUpgradeable简化而成，不应用于生产。 UUPS 作为透明代理的替代方案，UUPS也能解决"选择器冲突"（Selector Cl…
阅读更多...
CSDN编程题-每日一练（2023-08-25）

CSDN编程题-每日一练（2023-08-25）

CSDN编程题-每日一练&#xff08;2023-08-25&#xff09; 一、题目名称&#xff1a;影分身二、题目名称&#xff1a;小鱼的航程(改进版)三、题目名称&#xff1a;排查网络故障 一、题目名称&#xff1a;影分身 时间限制&#xff1a;1000ms内存限制&#xff1a;256M 题目描述&am…
阅读更多...
pnpm无法加载文件 (解决方法 )

pnpm无法加载文件 (解决方法 )

现在要运行一个TS的项目&#xff0c;我的电脑上没有安装pnpm&#xff0c;导致我的vscode一直报错无法加载。 pnpm安装&#xff1a; npm install -g pnpm pnpm : 无法加载文件 pnpm : 无法加载文件 C:\Users\HP\AppData\Roaming\npm\pnpm.ps1&#xff0c;因为在此系统上禁止运…
阅读更多...
adb shell setprop 、开发者选项

adb shell setprop 、开发者选项

App性能调试详解 Android App性能监控工具 更多系统属性参考 一、开启 GPU Render 的profiling bar&#xff1a; Gpu渲染速度 adb shell setprop debug.hwui.profile true adb shell setprop debug.hwui.profile visual_bars adb shell setprop debug.hwui.profile visual…
阅读更多...
最新文章

Copyright @ 2022~2023