最简单的基于 FFmpeg 的收流器(以接收 RTMP 为例)

最简单的基于 FFmpeg 的收流器(以接收 RTMP 为例)

最简单的基于 FFmpeg 的收流器(以接收 RTMP 为例)

参考雷霄骅博士的文章,链接:最简单的基于FFMPEG的推流器附件:收流器

正文

出于对 最简单的基于 FFmpeg 的推流器(以推送 RTMP 为例)的补充,本文记录一个最简单的基于 FFmpeg 的收流器。

收流器和推流器的作用正好相反:推流器用于将本地文件以流媒体的形式发送出去,而收流器用于将流媒体内容保存为本地文件。

本文记录的推流器可以将 RTMP 流媒体保存成为一个本地的 FLV 文件。由于 FFmpeg 本身支持很多的流媒体协议和封装格式,所以也支持其它的封装格式和流媒体协议。

源程序:

// Simplest FFmpeg Receiver.cpp : 定义控制台应用程序的入口点。
///**
* 最简单的基于 FFmpeg 的收流器(接收 RTMP)
* Simplest FFmpeg Receiver (Receive RTMP)
*
* 源程序:
* 雷霄骅 Lei Xiaohua
* leixiaohua1020@126.com
* 中国传媒大学/数字电视技术
* Communication University of China / Digital TV Technology
* http://blog.csdn.net/leixiaohua1020
*
* 修改:
* 刘文晨 Liu Wenchen
* 812288728@qq.com
* 电子科技大学/电子信息
* University of Electronic Science and Technology of China / Electronic and Information Science
* https://blog.csdn.net/ProgramNovice
*
* 本例子将流媒体数据(以 RTMP 为例)保存成本地文件。
* 是使用 FFmpeg 进行流媒体接收最简单的教程。
*
* This example saves streaming media data (Use RTMP as example)
* as a local file.
* It's the simplest FFmpeg stream receiver.
*/#include "stdafx.h"#include <stdio.h>
#include <stdlib.h>// 解决报错:'fopen': This function or variable may be unsafe.Consider using fopen_s instead.
#pragma warning(disable:4996)// 解决报错:无法解析的外部符号 __imp__fprintf,该符号在函数 _ShowError 中被引用
#pragma comment(lib, "legacy_stdio_definitions.lib")
extern "C"
{// 解决报错:无法解析的外部符号 __imp____iob_func,该符号在函数 _ShowError 中被引用FILE __iob_func[3] = { *stdin, *stdout, *stderr };
}#define __STDC_CONSTANT_MACROS#ifdef _WIN32
// Windows
extern "C"
{
#include "libavformat/avformat.h"
#include "libavutil/mathematics.h"
#include "libavutil/time.h"
};
#else
// Linux...
#ifdef __cplusplus
extern "C"
{
#endif
#include <libavformat/avformat.h>
#include <libavutil/mathematics.h>
#include <libavutil/time.h>
#ifdef __cplusplus
};
#endif
#endif// 1: Use H.264 Bitstream Filter 
#define USE_H264BSF 0int main(int argc, char* argv[])
{AVOutputFormat *ofmt = NULL;// Input AVFormatContext and Output AVFormatContextAVFormatContext *ifmt_ctx = NULL, *ofmt_ctx = NULL;AVPacket pkt;const char *in_filename, *out_filename;int ret, i;int videoindex = -1;int frame_index = 0;// RTMPin_filename = "rtmp://liteavapp.qcloud.com/live/liteavdemoplayerstreamid";// UDP// in_filename  = "rtp://233.233.233.233:6666";out_filename = "receive.flv";// out_filename = "receive.ts";// out_filename = "receive.mkv";av_register_all();// Init networkavformat_network_init();// Inputif ((ret = avformat_open_input(&ifmt_ctx, in_filename, 0, 0)) < 0){printf("Could not open input file.");goto end;}if ((ret = avformat_find_stream_info(ifmt_ctx, 0)) < 0){printf("Failed to retrieve input stream information");goto end;}for (i = 0; i < ifmt_ctx->nb_streams; i++)if (ifmt_ctx->streams[i]->codec->codec_type == AVMEDIA_TYPE_VIDEO){videoindex = i;break;}// Print some input informationav_dump_format(ifmt_ctx, 0, in_filename, 0);// Outputavformat_alloc_output_context2(&ofmt_ctx, NULL, NULL, out_filename); // RTMPif (ofmt_ctx == NULL){printf("Could not create output context.\n");ret = AVERROR_UNKNOWN;goto end;}ofmt = ofmt_ctx->oformat;for (i = 0; i < ifmt_ctx->nb_streams; i++){// Create output AVStream according to input AVStreamAVStream *in_stream = ifmt_ctx->streams[i];AVStream *out_stream = avformat_new_stream(ofmt_ctx, in_stream->codec->codec);if (out_stream == NULL){printf("Failed allocating output stream.\n");ret = AVERROR_UNKNOWN;goto end;}// Copy the settings of AVCodecContextret = avcodec_copy_context(out_stream->codec, in_stream->codec);if (ret < 0){printf("Failed to copy context from input to output stream codec context.\n");goto end;}out_stream->codec->codec_tag = 0;if (ofmt_ctx->oformat->flags & AVFMT_GLOBALHEADER){out_stream->codec->flags |= CODEC_FLAG_GLOBAL_HEADER;}}// Print some output informationav_dump_format(ofmt_ctx, 0, out_filename, 1);// Open output URLif (!(ofmt->flags & AVFMT_NOFILE)){ret = avio_open(&ofmt_ctx->pb, out_filename, AVIO_FLAG_WRITE);if (ret < 0){printf("Could not open output URL '%s'.\n", out_filename);goto end;}}// Write file headerret = avformat_write_header(ofmt_ctx, NULL);if (ret < 0){printf("Error occurred when opening output URL.\n");goto end;}#if USE_H264BSFAVBitStreamFilterContext* h264bsfc = av_bitstream_filter_init("h264_mp4toannexb");
#endifwhile (1){AVStream *in_stream, *out_stream;// Get an AVPacketret = av_read_frame(ifmt_ctx, &pkt);if (ret < 0){break;}in_stream = ifmt_ctx->streams[pkt.stream_index];out_stream = ofmt_ctx->streams[pkt.stream_index];// copy packet// Convert PTS/DTSpkt.pts = av_rescale_q_rnd(pkt.pts, in_stream->time_base, out_stream->time_base,(AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX));pkt.dts = av_rescale_q_rnd(pkt.dts, in_stream->time_base, out_stream->time_base,(AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX));pkt.duration = av_rescale_q(pkt.duration, in_stream->time_base, out_stream->time_base);pkt.pos = -1;if (pkt.stream_index == videoindex){printf("Receive %8d video frames from input URL.\n", frame_index);frame_index++;#if USE_H264BSFav_bitstream_filter_filter(h264bsfc, in_stream->codec, NULL, &pkt.data, &pkt.size, pkt.data, pkt.size, 0);
#endif}// ret = av_write_frame(ofmt_ctx, &pkt);ret = av_interleaved_write_frame(ofmt_ctx, &pkt);if (ret < 0){printf("Error muxing packet.\n");break;}av_free_packet(&pkt);
}#if USE_H264BSFav_bitstream_filter_close(h264bsfc);
#endif// Write file trailerav_write_trailer(ofmt_ctx);
end:avformat_close_input(&ifmt_ctx);// Close outputif (ofmt_ctx && !(ofmt->flags & AVFMT_NOFILE)){avio_close(ofmt_ctx->pb);}avformat_free_context(ofmt_ctx);if (ret < 0 && ret != AVERROR_EOF){printf("Error occurred.\n");return -1;}system("pause");return 0;
}

结果

运行程序,输出如下:

在这里插入图片描述

程序运行之后,即可获取流媒体数据并且在本地保存成一个视频文件 “receive.flv”。

在这里插入图片描述

工程文件下载

GitHub:UestcXiye / Simplest-FFmpeg-Receiver

CSDN:Simplest FFmpeg Receiver.zip

参考链接

  1. 最简单的基于 FFmpeg 的推流器(以推送 RTMP 为例)

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

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

相关文章

蓝凌OA frpt_listreport_definefield.aspx接口存在SQL注入漏洞

免责声明&#xff1a;文章来源互联网收集整理&#xff0c;请勿利用文章内的相关技术从事非法测试&#xff0c;由于传播、利用此文所提供的信息或者工具而造成的任何直接或者间接的后果及损失&#xff0c;均由使用者本人负责&#xff0c;所产生的一切不良后果与文章作者无关。该…

DevStack 部署 OpenStack

Devstack 简介 DevStack 是一系列可扩展的脚本&#xff0c;用于基于 git master 的最新版本快速调出完整的 OpenStack 环境。devstack 以交互方式用作开发环境和 OpenStack 项目大部分功能测试的基础。 devstack 透过执行 stack.sh 脚本&#xff0c;搭建 openstack 环境&…

lv20 QT主窗口4

熟悉创建主窗口项目 1 QAction 2 主窗口 菜单栏&#xff1a;fileMenu menuBar()->addMenu(tr("&File")); 工具栏&#xff1a;fileToolBar addToolBar(tr("File")); 浮动窗&#xff1a;QDockWidget *dockWidget new QDockWidget(tr("Dock W…

Threejs之精灵模型Sprite

参考资料 精灵模型Sprite…Sprite模拟下雨、下雪 知识点 注&#xff1a;基于Three.jsv0.155.0 精灵模型Sprite精灵模型标注场景(贴图)Sprite模拟下雨、下雪 精灵模型Sprite Three.js的精灵模型Sprite和Threejs的网格模型Mesh一样都是模型对象&#xff0c;父类都是Object3…

【设计者模式】单例模式

文章目录 1、模式定义2、代码实现&#xff08;1&#xff09;双重判空加锁方式两次判空的作用&#xff1f;volatile 关键字的作用&#xff1f;构造函数私有&#xff1f; &#xff08;2&#xff09;静态内部类【推荐】&#xff08;3&#xff09;Kotlin中的单例模式lateinit 和 by…

Matlab 最小二乘插值(曲线拟合)

文章目录 一、简介二、实现代码三、实现效果参考资料一、简介 在多项式插值时,当数据点个数较多时,插值会导致多项式曲线阶数过高,带来不稳定因素。因此我们可以通过固定幂基函数的最高次数 m(m < n),来对我们要拟合的曲线进行降阶。之前的函数形式就可以变为: 二、实现…

spring Boot 报错RedisConnectionFailureException

错误描述&#xff1a; 错误重点&#xff1a;&#xff08;图片中蓝色区域&#xff09; Unable to connect to Redis; 无法连接到Redis Unable to connect to 127.0.0.1 无法连接到本地服务器 所以&#xff0c;错误是本地服务器没有连接上Redis所引起的 错误解析…

vue3中的父传子,子传父

在Vue 3中&#xff0c;父组件向子组件传递数据和子组件向父组件通信的方式与Vue 2非常相似&#xff0c;但Vue 3提供了Composition API和更多的响应式API&#xff0c;为组件间的通信提供了更多的可能性。下面是父传子和子传父的基本方法&#xff1a; ### 父组件传递数据给子组件…

【InternLM 实战营笔记】使用SDK接口上传模型到OpenXLab

概述 浦源内容平台-模型中心的Python SDK旨在为开发人员提供编程方式来管理和操作模型中心平台的功能&#xff0c;以便他们可以轻松地与模型中心进行交互和模型管理。通过Python SDK提供的推理接口&#xff0c;开发人员能够高效地调用不同的模型&#xff0c;实现模型应用的开发…

递归实现排列型枚举(c++题解)

题目描述 把 1~n 这 n(n<10) 个整数排成一行后随机打乱顺序&#xff0c;输出所有可能的次序。 输入格式 一个整数n。 输出格式 按照从小到大的顺序输出所有方案&#xff0c;每行1个。 首先&#xff0c;同一行相邻两个数用一个空格隔开。其次&#xff0c;对于两个不同的…

Linux——进程控制(二)进程等待

目录 前言 一、进程等待 二、如何进行进程等待 1.wait 2.waitpid 2.1第二个参数 2.2第三个参数 3. 等待多个进程 三、为什么不用全局变量获取子进程的退出信息 前言 前面我们花了大量的时间去学习进程的退出&#xff0c;退出并不难&#xff0c;但更深入的学习能为本…

048 异常

什么是异常 异常体系结构 异常的继承关系 Error Exception 异常处理机制 try&#xff1a;用{}将可能产生异常的代码包裹catch&#xff1a;与try搭配使用&#xff0c;捕获try包裹代码中抛出的异常并进行后续动作finally&#xff1a;跟在try后&#xff0c;在try和catch之后执行…

web3时事粥报

比特币正成为更具有吸引力的通胀对冲工具 在通胀的宏观经济浪潮中&#xff0c;比特币正逐渐崭露头角&#xff0c;成为那些渴望多元化投资组合的投资者眼中的璀璨明星。Kooner 预测&#xff0c;2024年&#xff0c;各种宏观经济挑战可能进一步提升比特币、黄金和白银等资产的避险…

3月3日做题总结(C/C++真题)

第一题 参加位运算的数据其类型不能是&#xff08;&#xff09;。 A---int B---char C---float D---long int 正确答案&#xff1a;C 解析&#xff1a;无论是float&#xff0c;还是double&#xff0c;在内存中的存储分为三部分&#xff1a;符号位、指数位、尾数位&#…

Google Dremel和parquet的复杂嵌套数据结构表征方法解析

转载请注明出处。作者&#xff1a;archimekai 核心参考文献&#xff1a; Dremel: Interactive Analysis of Web-Scale Datasets 文章目录 引言复杂嵌套数据结构的无损表征问题Dremel论文中提出的表征方法parquet备注 引言 Dremel是Google的交互式分析系统。Google大量采用prot…

全量知识系统问题及SmartChat给出的答复 之17 知识系统中的两个特权类(超类和欠类) :脚本和场景

Q.45 知识系统中的两个特权类 &#xff1a;脚本和场景 知识系统中的两个特权类&#xff08;也是集合论中两个特权集合&#xff09;&#xff1a;脚本script和场景scene 。 一个$Demonstrate类型的脚本script&#xff1a; 表示“值val”&#xff08; 形式上是应用程序的实用工…

如何学习openfoam

学习OpenFOAM的详细步骤、流程、学习网站、练习案例以及B站学习资源推荐如下&#xff1a; 一、详细步骤和流程 安装OpenFOAM&#xff1a;首先&#xff0c;你需要在你的计算机上安装OpenFOAM。你可以从OpenFOAM的官方网站下载适合你的操作系统的安装包&#xff0c;然后按照官方提…

搭建服务器及跨域处理

使用内置的模块搭建服务器 自己电脑: 域名:localhost ip:127.0.0.1 http模块搭建服务器 const http = require(http)// 创建一个http对应的服务器,每次改完服务器的代码后都需要重新启动下服务器 /*方式一: const server = http.createServer((request,response)=>{…

对简单工厂模式、工厂方法模式的思考

目录 1 背景1.1 题目描述1.2 输入描述1.3 输出描述1.4 输入示例1.5 输出示例 2 简单工厂模式3 工厂方法模式4 思考4.1 改进工厂方法模式 1 背景 题目源自&#xff1a;【设计模式专题之工厂方法模式】2.积木工厂 1.1 题目描述 小明家有两个工厂&#xff0c;一个用于生产圆形积木…

铁路关基保护新规发布!铁路软件供应链安全洞察与治理思路

近日&#xff0c;国家铁路局发布《铁路关键信息基础设施安全保护管理办法》&#xff0c;《办法》第十四条提到&#xff1a;“运营者应当加强铁路关键信息基础设施供应链安全保护&#xff0c;优先采购安全可信的网络产品和服务。运营者采购网络产品和服务&#xff0c;应当预判该…