ffmpeg api接口实现rtmp推流的两种方式

FFmpeg 版本

version 4.0.2

搭建Rtmp服务

具体可以参考一下其它文章，本文主要讲的是如何使用FFmpeg api接口实现推流功能

推流flv文件

    av_register_all();AVFormatContext *ictx = NULL;//打开文件，解封文件头int re = avformat_open_input(&ictx, inUrl, 0, 0);if (re != 0){return ff_Error(re);}cout << "open file " << inUrl << " success..." << endl;//获取音频视频流信息re = avformat_find_stream_info(ictx, 0);if (re != 0){return ff_Error(re);}cout << "打印输入文件信息" << endl;av_dump_format(ictx, 0, inUrl, 0);//创建输出流上下文AVFormatContext *octx = NULL;re = avformat_alloc_output_context2(&octx, 0, "flv", outUrl);if (!octx){return ff_Error(re);}cout << "输出上下文创建成功" << endl;//配置输出流//遍历输入的AVStreamfor (int i = 0; i < ictx->nb_streams; i++){//创建输出流AVStream *out = avformat_new_stream(octx, ictx->streams[i]->codec->codec);if (!out){return ff_Error(0);}//复制配置信息AVCodecParameters *codecpar = ictx->streams[i]->codecpar;re = avcodec_parameters_copy(out->codecpar, codecpar);out->codec->codec_tag = 0;}cout << "打印输出流信息" << endl;av_dump_format(octx, 0, outUrl, 1);//rtmp推流//打开iore = avio_open(&octx->pb, outUrl, AVIO_FLAG_WRITE);if (!octx->pb){return ff_Error(re);}//写入头信息re = avformat_write_header(octx, 0);if (re < 0){return ff_Error(re);}AVPacket pkt;long long startTime = av_gettime();for (;;){re = av_read_frame(ictx, &pkt);if (re != 0){break;}if (ictx->streams[pkt.stream_index]->codecpar->codec_type != AVMEDIA_TYPE_VIDEO) {continue;}cout << pkt.pts << " " << flush;//计算转换pts dtsAVRational itime = ictx->streams[pkt.stream_index]->time_base;AVRational otime = octx->streams[pkt.stream_index]->time_base;pkt.pts = av_rescale_q_rnd(pkt.pts, itime, otime, (AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_NEAR_INF));pkt.dts = av_rescale_q_rnd(pkt.dts, itime, otime, (AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_NEAR_INF));pkt.duration = av_rescale_q_rnd(pkt.duration, itime, otime, (AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_NEAR_INF));pkt.pos = -1;//视频帧推送速度if (ictx->streams[pkt.stream_index]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO){AVRational tb = ictx->streams[pkt.stream_index]->time_base;//已经过去的时间long long now = av_gettime() - startTime;long long dts = 0;dts = pkt.dts * (1000 * 1000 * r2d(tb));if (dts > now)av_usleep(dts - now);}//推送帧数据re = av_interleaved_write_frame(octx, &pkt);if (re<0){return ff_Error(re);}}cout << "rtmp 推流结束" << endl;

推流H264数据帧

有时候我们想推流的数据并非来自文件，而是来自编码器，视频数据通过函数参数传入，所以我们需要另一种方式实现推流,在这里通过读H264文件模拟视频数据帧

代码实现

static int write_frame(AVFormatContext *fmt_ctx, const AVRational *time_base, AVStream *st, AVPacket *pkt)
{// rescale output packet timestamp values from  codec to stream timebaseav_packet_rescale_ts(pkt, *time_base, st->time_base);pkt->stream_index = st->index;printf("pkt pts = %d dts = %d \n", pkt->pts, pkt->dts);return av_write_frame(fmt_ctx, pkt);
}static int write_video_frame(AVFormatContext *ofmt_ctx, AVStream *st, char* data, int datalen)
{int ret = 0;int isI = 0;AVCodecContext *c = st->codec;AVPacket pkt = { 0 };av_init_packet(&pkt);isI = isIdrFrame((uint8_t*)data, datalen);pkt.flags |= isI ? AV_PKT_FLAG_KEY : 0;pkt.data = (uint8_t*)data;pkt.size = datalen;AVRational time_base = {1, 1000};pkt.pts = av_rescale_q(ptsInc++, time_base, st->time_base);enum AVRounding rnd = (enum AVRounding)(AV_ROUND_NEAR_INF | AV_ROUND_PASS_MINMAX);pkt.dts = av_rescale_q_rnd(pkt.dts, st->time_base, st->time_base, rnd);pkt.duration = av_rescale_q(pkt.duration, st->time_base, st->time_base);pkt.pos = -1;ret = write_frame(ofmt_ctx, &c->time_base, st, &pkt);if (ret < 0){printf("Error while writing video frame\n");return -1;}return 0;
}
static int pushFlow2(char *outUrl)
{av_register_all();//输出流//创建输出流上下文AVFormatContext *octx = NULL;int re = avformat_alloc_output_context2(&octx, 0, "flv", outUrl);if (!octx){return ff_Error(re);}cout << "输出上下文创建成功" << endl;AVCodec *codec = avcodec_find_encoder(AV_CODEC_ID_H264);if (codec == NULL) {printf("No codec for format: H264 \n");return -1;}AVCodecContext *codec_context = avcodec_alloc_context3(codec);if (! codec) {printf("Could not alloc an encoding context \n");return -1;}AVStream *vstream = avformat_new_stream(octx, NULL);if (vstream == NULL) {printf("cannot new video stream \n");return -1;}vstream->id = 0;vstream->codec = codec_context;codec_context->codec_id = codec->id;codec_context->codec_type = AVMEDIA_TYPE_VIDEO;codec_context->pix_fmt = AV_PIX_FMT_YUV420P;codec_context->bit_rate = 4000000;codec_context->width = 1280;codec_context->height = 720;AVRational time_base = {1, 30};vstream->time_base = time_base;codec_context->time_base = time_base;codec_context->codec_tag = 0;if (octx->oformat->flags & AVFMT_GLOBALHEADER) {codec_context->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;}int ret = avcodec_open2(codec_context, codec, NULL);if(ret < 0){printf("open video codec failed ! \n");}if(avcodec_parameters_from_context(vstream->codecpar, codec_context) < 0){printf("acvodec_parameters_from_context failed!\n");}cout << "打印输出流信息" << endl;av_dump_format(octx, 0, outUrl, 1);//rtmp推流//打开iore = avio_open(&octx->pb, outUrl, AVIO_FLAG_WRITE);if (!octx->pb){return ff_Error(re);}//写入头信息re = avformat_write_header(octx, 0);if (re < 0){return ff_Error(re);}H264FileSource *source = h264_file_source_new("1.h264");if (source == NULL) {return -1;}for (;;){usleep(33 * 1000);const H264Nal *frame = H264_file_source_read(source);if (frame == NULL) {break;}int ret = write_video_frame(octx, vstream, (char *)frame->data, frame->size);if (ret < 0) {printf("write video frame fail \n");return -1;}}cout << "rtmp 推流结束" << endl;
}

ffmpeg api接口实现rtmp推流的两种方式相关推荐

ASP.NET Web API接受AngualrJS的QueryString的两种方式
ASP.NET Web API如何接受来自AngualrJS的QueryString呢?本篇体验两种方式. 第一种方式:http://localhost:49705/api/products?sear ...
【FFMPEG】AVFrame中buffer分配的两种方式
AVFrame在使用ffmpeg进行编解码过程中,是最基本的数据结构. 在某些场景下,需要对AVFrame的数据区域进行提前分配,有两种方法,需要根据自己的需求来使用. (1) * This func ...
使用ArcGIS JS API加载WMTS图层的两种方式
文章目录前言方式一方式二前言某些项目可能多方参与,每一方使用的GIS平台有时会有所不同,这时为了统一各方地图服务,通常会发布OGC标准的WMTS地图服务供各方使用.ArcGIS API fo ...
API数据传输，flask发送接收两种方式/cryptography is required for sha256_password or caching_sha2_password
import requests import jsondata = {"texts": '{"uuid": [5, 1], "createName&q ...
使用库函数API和C代码中嵌入汇编代码两种方式使用同一个系统调用
实验4:使用库函数API和C代码中嵌入汇编代码两种方式使用同一个系统调用姓名:李冬辉学号:20133201 注: 原创作品转载请注明出处 + <Linux内核分析>MOOC课程http ...
python 收发微信之一：利用 WxPusher 的 web api 及 python SDK 两种方式给自己发微信
目录摘要实操代码分析需求来源与路径选择参考摘要本文给出利用 WxPusher 提供的 web api 与 python SDK 两种方式,实现微信发送的 python 代码样例,并简单 ...
java操作Excel有两种方式方式1：jxl操作Excel jxl的API
java操作Excel有两种方式方式1:jxl操作Excel 方式2:poi操作Excel 下面介绍jxl API: 使用Windows操作系统的朋友对Excel(电子表格)一定不会陌生,但是要使用 ...
对外API接口的安全性设计及鉴权方式
对外API接口的安全性设计及鉴权方式 API鉴权方式 API Key + API Secret实现API鉴权 Cookie + Session实现API鉴权 token机制实现API鉴权 API接口的 ...
实验四：使用库函数API和C代码中嵌入汇编代码两种方式使用同一个系统调用
贺邦+原创作品转载请注明出处 + <Linux内核分析>MOOC课程http://mooc.study.163.com/course/USTC-1000029000 实验目的: 使用库函数 ...

ffmpeg api接口实现rtmp推流的两种方式

FFmpeg 版本

搭建Rtmp服务

推流flv文件

推流H264数据帧

ffmpeg api接口实现rtmp推流的两种方式相关推荐

最新文章

热门文章