音视频学习(二十一)——rtmp收流(tcp方式)

前言

本文主要介绍rtmp协议收流流程，在linux上搭建rtmp服务器，通过自研的rtmp收流库发起取流请求，使用ffmpeg+qt实现视频流的解码与播放。

关于rtmp协议基础介绍可查看：https://blog.csdn.net/www_dong/article/details/131026072

环境搭建

nginx-rtmp-module下载

# 下载地址,下载zip包即可
https://github.com/arut/nginx-rtmp-module

nginx编译与安装

  1. 下载nginx
# 下载地址
http://nginx.org/en/download.html
  1. 解压，将nginx-rtmp-module拷贝至nginx-1.24.0目录，如下所示：

在这里插入图片描述

  1. 配置nginx编译环境
# 步骤1
yum -y install gcc pcre pcre-devel zlib zlib-devel openssl openssl-devel# 步骤2
yum -y install libxml2 libxml2-dev
yum -y install libxslt-devel
  1. 生成Makefile文件
# 在/home/rtmp/nginx-1.24.0下执行如下命令
./configure --add-module=./nginx-rtmp-module-master --with-http_ssl_module --with-http_ssl_module --with-http_xslt_module --with-http_flv_module --with-debug --with-http_gzip_static_module
  1. 修改nginx.conf文件,进入conf/文件夹下，编译nginx.conf在末尾增加如下内容：
rtmp {server {listen 1935;               #监听端口,若被占用,可以更改chunk_size 4000;           #上传flv文件块儿的大小application live {         #创建一个叫live的应用live on;              #开启live的应用allow publish 192.168.191.100;#192.168.191.100为服务器ip allow play all;}}
}
  1. 编译、安装
# 在/home/rtmp/nginx-1.24.0下执行如下命令
make
make install
  1. 启动nginx
# 测试配置文件
cd /usr/local/nginx
./sbin/nginx -t# 有如下打印说明配置正常
[root@localhost nginx]# ./sbin/nginx  -t
nginx: the configuration file /usr/local/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /usr/local/nginx/conf/nginx.conf test is successful# 启动nginx
./sbin/nginx# 查看是否正常启动
ps -aux | grep nginx
  1. 网页访问，出现如下内容说明启动成功

在这里插入图片描述

ffmepg推流

  • 安装ffmepg，将视频文件拷贝至安装路径下，如图所示：

在这里插入图片描述

  • 执行如下命令
ffmpeg -re -stream_loop -1 -i test.h264 -c copy -f flv rtmp://192.168.191.100:1935/live/testrtmp

以上步骤执行完即完成rtmp服务器搭建。

设计

拉流流程

说明：客户端—自研的rtmp收流库，服务器—上述搭建的rtmp服务器

  • 客户端发送tcp握手请求，和服务器完成tcp握手和rtmp握手；
  • 客户端发送命令消息中的“连接”(connect)到服务器，请求与一个服务应用实例建立连接；
  • 客户端发送网络连接命令的“创建流”(createStream)消息到服务端，以创建消息通信的逻辑通道。音频、视频和元数据的发布通过使用createStream命令创建的流通道执行。服务端发送createStream的“应答消息”(_result)；
  • 客户端发送网络流命令中的“播放”(play)到服务端；
  • 服务端发送协议控制消息中的“设置块大小”(Set Chunk Size)到客户端设置chunk大小；
  • 服务器发送另一个协议控制消息（用户控制），指定事件“StreamIsRecorded”和该消息中的流ID。消息在前2字节中携带事件类型，在后4字节中携带流ID；
  • 服务端发送用户控制消息中的“流开始”(StreamBegin)消息到客户端，通知客户端流成功创建，可用于通信；
  • 如果客户端发送的播放命令成功，则服务器发送onStatus命令消息NetStream.Play.Start和NetStream.Play.Reset。仅当客户端发送的播放命令设置了重置标志时，服务器才会发送NetStream.Play.Reset。如果未找到要播放的流，服务器将发送onStatus消息NetStream.Play.StreamNotFound；
  • 服务端发送音视频数据到客户端；

代码设计

  1. 上层url解析
// rtmp://192.168.191.100:1935/live/testrtmp
// appName:"live"
// streamPath: "testrtmp"
// tcurl: "rtmp://192.168.191.100:1935/live"
int CRtmpTcpStreamReceiver::ParseUrl_(std::string& appName, std::string& streamPath, std::string& tcurl)
{if (m_rtmpUrl.empty())return -1;std::string url = m_rtmpUrl;std::string::size_type pos_0 = url.rfind("/");if (std::string::npos == pos_0)return -1;// "testrtmp"streamPath = url.substr(pos_0+1, url.length());// "rtmp://192.168.191.100:1935/live"tcurl = url.substr(0, pos_0);std::string tmpUrl = tcurl;std::string::size_type pos_1 = url.rfind("rtmp://");if (std::string::npos == pos_1)return -1;// ippUrl: "192.168.191.100:1935/live"std::string ippUrl = tmpUrl.substr(pos_1+7, tmpUrl.length());std::string::size_type pos_2 = ippUrl.rfind("/");if (std::string::npos == pos_2)return -1;// "live"appName = ippUrl.substr(pos_2+1, ippUrl.length());// "192.168.191.100:1935"std::string ipp = ippUrl.substr(0, pos_2);std::string::size_type pos_3 = ipp.rfind(":");if (std::string::npos == pos_3)return -1;m_rtmpIP = ipp.substr(0, pos_3);m_rtmpPort = atoi(ipp.substr(pos_3+1, ipp.length()).c_str());return 0;
}
  1. 开始tcp握手和rtmp握手
int CRtmpTcpStreamReceiver::InitRtmpSession_()
{// rtmp url解析std::string appName = "", streamPath = "", turl = "";if (0 != ParseUrl_(appName, streamPath, turl)){return -1;}do{// tcp连接m_tcpClient = std::make_shared<ZDTcpClient>(nullptr, this);if (!m_tcpClient.get()|| 0 != m_tcpClient->TcpCreate()|| 0 != m_tcpClient->TcpConnect(m_rtmpIP.c_str(), m_rtmpPort)|| 0 != m_tcpClient->TcpSetNoBlock(false)|| 0 != m_tcpClient->TcpRecvTimeout(5)){break;}// CRtmpCommand为librtmp库接口封装类m_command = std::make_shared<CRtmpCommand>(m_tcpClient, m_func, m_user);if (!m_command.get()){break;}// 创建接收实例if (0 != m_command->Create(appName, streamPath, turl)|| 0 != m_command->Start(1)){break;}return 0;} while (0);UnInitRtmpSession_();return -1;
}
  1. 启动线程接收数据
void CRtmpTcpStreamReceiver::RtmpWorker()
{std::shared_ptr<char> dataPacket(new char[RTMP_STREAM_DATA_SIZE], std::default_delete<char[]>());memset(dataPacket.get(), 0x00, RTMP_STREAM_DATA_SIZE);int recvLen = 0;while (m_running){// tcp数据接收recvLen = m_tcpClient->TcpRecv(dataPacket.get(), RTMP_STREAM_DATA_SIZE);if (recvLen <= 0) {continue;}// 塞数据if (0 != m_command->InputData(dataPacket.get(), recvLen)){break;}memset(dataPacket.get(), 0x00, RTMP_STREAM_DATA_SIZE);}
}

抓包

在这里插入图片描述

效果

在这里插入图片描述

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

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

相关文章

OpenSSL的源码在哪里下载？

OpenSSL的源码在哪里下载？

官方网站去下载&#xff0c;网址&#xff1a; https://www.openssl.org/source/ 比较老的版本的下载页面地址&#xff1a; https://www.openssl.org/source/old/ 由于某面板的OpenSSL模块的安装配置语句如下&#xff1a; --with-openssl/root/rpmbuild/BUILD/openssl-1.0.2u所…
阅读更多...
概率论复习

概率论复习

第一章&#xff1a;随机概率及其概率 A和B相容就是 AB 空集 全概率公式与贝叶斯公式&#xff1a; 伯努利求概率&#xff1a; 第二章&#xff1a;一维随机变量及其分布&#xff1a; 离散型随机变量求分布律&#xff1a; 利用常规离散性分布求概率&#xff1a; 连续性随机变量…
阅读更多...
风速预测（六）基于Pytorch的EMD-CNN-GRU并行模型

风速预测（六）基于Pytorch的EMD-CNN-GRU并行模型

目录 前言 1 风速数据EMD分解与可视化 1.1 导入数据 1.2 EMD分解 2 数据集制作与预处理 2.1 先划分数据集&#xff0c;按照8&#xff1a;2划分训练集和测试集 2.2 设置滑动窗口大小为96&#xff0c;制作数据集 3 基于Pytorch的EMD-CNN-GRU并行模型预测 3.1 数据加载&a…
阅读更多...
ansible（不能交互）

ansible（不能交互）

1、定义 基于python开发的一个配置管理和应用部署工具&#xff0c;在自动化运维中异军突起&#xff0c;类似于xshell一键输入的工具&#xff0c;不需要每次都切换主机进行操作&#xff0c;只要有一台ansible的固定主机&#xff0c;就可以实现所有节点的操作。不需要agent客户端…
阅读更多...
100GPTS计划-AI写诗PoetofAges

100GPTS计划-AI写诗PoetofAges

地址 https://chat.openai.com/g/g-Cd5daC0s5-poet-of-ages https://poe.com/PoetofAges 测试 创作一首春天诗歌 创作一首夏天诗歌 创作一首秋天诗歌 创作一首冬天诗歌 微调 诗歌风格 语气&#xff1a;古典 知识库
阅读更多...
Arcgis导出为tiff

Arcgis导出为tiff

原有一幅影像&#xff0c;在进行一些操作之后&#xff0c;需要导出为tiff 比如我对他进行一个重采样&#xff0c;48m分辨率变为96m 在重采样后的数据图层上右键&#xff0c;导出数据 为什么有时会导出为.gdb格式的呢&#xff1f; 可能是位置处在一个文件地理数据库.gdb下
阅读更多...
gitlab 安装

gitlab 安装

1.安装依赖 sudo apt updatesudo apt-get upgradesudo apt-get install curl openssh-server ca-certificates postfix安装gitlab curl -s https://packages.gitlab.com/install/repositories/gitlab/gitlab-ce/script.deb.sh | sudo bash官网下载安装包 要选ubuntu focal 安…
阅读更多...
如何实现TensorFlow自定义算子？

如何实现TensorFlow自定义算子？

在上一篇文章中 Embedding压缩之基于二进制码的Hash Embedding&#xff0c;提供了二进制码的tensorflow算子源码&#xff0c;那就顺便来讲下tensorflow自定义算子的完整实现过程。 前言 制作过程基于tensorflow官方的custom-op仓库以及官网教程&#xff0c;并且在Ubuntu和Mac…
阅读更多...
2023_Spark_实验二十八：Flume部署及配置

2023_Spark_实验二十八：Flume部署及配置

实验目的&#xff1a;熟悉掌握Flume部署及配置 实验方法&#xff1a;通过在集群中部署Flume&#xff0c;掌握Flume配置 实验步骤&#xff1a; 一、Flume简介 Flume是一种分布式的、可靠的和可用的服务&#xff0c;用于有效地收集、聚合和移动大量日志数据。它有一个简单灵活…
阅读更多...
redis：六、数据过期删除策略（惰性删除、定期删除）和基于redisson实现的分布式锁（看门狗机制、主从一致性）和面试模板

redis：六、数据过期删除策略（惰性删除、定期删除）和基于redisson实现的分布式锁（看门狗机制、主从一致性）和面试模板

数据过期删除策略 Redis的过期删除策略&#xff1a;惰性删除 定期删除两种策略进行配合使用 惰性删除 惰性删除&#xff1a;设置该key过期时间后&#xff0c;我们不去管它&#xff0c;当需要该key时&#xff0c;我们在检查其是否过期&#xff0c;如果过期&#xff0c;我们就…
阅读更多...
0基础学习VR全景平台篇第129篇：认识单反相机和鱼眼镜头

0基础学习VR全景平台篇第129篇：认识单反相机和鱼眼镜头

上课&#xff01;全体起立~ 大家好&#xff0c;欢迎观看蛙色官方系列全景摄影课程&#xff01; 一、相机 单反和微单 这里说的相机是指可更换镜头的单反/微单数码相机。那两者有何差异呢&#xff1f; 1&#xff09;取景结构差异 两者最直观的区别在于&#xff0c;微单相机…
阅读更多...
06. Python模块

06. Python模块

目录 1、前言 2、什么是模块 3、Python标准库模块 3.1、os模块 3.2、datetime 模块 3.3、random模块 4、自定义模块 4.1、创建和使用 4.2、模块命名空间 4.3、作用域 5、安装第三方依赖 5.1、使用 pip 安装单个依赖 5.2、从 requirements.txt 安装依赖 5.3、安装指…
阅读更多...
华为OS与麒麟OS：华为自研操作系统的对决

华为OS与麒麟OS：华为自研操作系统的对决

导言 在移动操作系统领域&#xff0c;华为OS和麒麟OS代表了华为在自主研发方面的努力。本文将深入探讨这两个操作系统的特点、竞争关系以及它们在用户体验、生态系统建设等方面的差异。 1. 背景与起源 华为OS的诞生&#xff1a; 华为OS是华为公司为应对外部环境而自主…
阅读更多...
Redis设计与实现之订阅与发布

Redis设计与实现之订阅与发布

目录 一、 订阅与发布 1、 频道的订阅与信息发送 2、订阅频道 3、发送信息到频道 4、 退订频道 5、模式的订阅与信息发送 ​编辑 6、 订阅模式 7、 发送信息到模式 8、 退订模式 三、订阅消息断连 1、如果订阅者断开连接了&#xff0c;再次连接会不会丢失之前发布的消…
阅读更多...
【无标题】CTF之SQLMAP

【无标题】CTF之SQLMAP

拿这一题来说 抓个包 复制报文 启动我们的sqlmap kali里边 sqlmap -r 文件路径 --dump --dbs 数据库 --tables 表
阅读更多...
HTML中边框样式、内外边距、盒子模型尺寸计算（附代码图文示例）【详解】

HTML中边框样式、内外边距、盒子模型尺寸计算（附代码图文示例）【详解】

Hi i,m JinXiang ⭐ 前言 ⭐ 本篇文章主要介绍HTML中边框样式、内外边距、盒子模型尺寸计算以及部分理论知识 &#x1f349;欢迎点赞 &#x1f44d; 收藏 ⭐留言评论 &#x1f4dd;私信必回哟&#x1f601; &#x1f349;博主收将持续更新学习记录获&#xff0c;友友们有任何问…
阅读更多...
网络编程『socket套接字 ‖ 简易UDP网络程序』

网络编程『socket套接字 ‖ 简易UDP网络程序』

&#x1f52d;个人主页&#xff1a; 北 海 &#x1f6dc;所属专栏&#xff1a; Linux学习之旅、神奇的网络世界 &#x1f4bb;操作环境&#xff1a; CentOS 7.6 阿里云远程服务器 文章目录 &#x1f324;️前言&#x1f326;️正文1.预备知识1.1.IP地址1.2.端口号1.3.端口号与进…
阅读更多...
详细教程 - 从零开发 Vue 鸿蒙harmonyOS应用 第五节 （基于uni-app封装鸿蒙接口请求库）

详细教程 - 从零开发 Vue 鸿蒙harmonyOS应用 第五节 （基于uni-app封装鸿蒙接口请求库）

随着鸿蒙系统的兴起,越来越多的app会采用鸿蒙开发。而鸿蒙开发必不可少的就是调用各种接口服务。为了简化接口的调用流程,我们通常会做一层封装。今天就来讲解一下,如何用uni-app封装鸿蒙的接口请求库。 一、新建项目 首先我们要新建一个鸿蒙项目啦&#xff01;当然选择第一个…
阅读更多...
R语言【rgbif】——occ_search对待字符长度大于1500的WKT的特殊处理真的有必要吗？

R语言【rgbif】——occ_search对待字符长度大于1500的WKT的特殊处理真的有必要吗？

一句话结论&#xff1a;只要有网有流量&#xff0c;直接用长WKT传递给参数【geometry】、参数【limit】配合参数【start】获取所有记录。 当我在阅读 【rgbif】 给出的用户手册时&#xff0c;注意到 【occ_search】 强调了 参数 【geometry】使用的wkt格式字符串长度。 文中如…
阅读更多...
【node】 地址标准化 解析手机号、姓名、行政区

【node】 地址标准化 解析手机号、姓名、行政区

地址标准化 解析手机号、姓名、行政区 实现效果链接源码 实现效果 将东光县科技园南路444号马晓姐13243214321 解析为 东光县科技园南路444号 13243214321 河北省;沧州市;东光县;东光镇 马晓姐 console.log(address, phone, divisions,name);链接 API概览 源码 https://gi…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023