• 08-流媒体-RTMP拉流


    整体方案:
    采集端:摄像头采集(YUV)->编码(YUV转H264)->写封装(H264转FLV)->RTMP推流
    客户端:RTMP拉流->解封装(FLV转H264)->解码(H264转YUV)->YUV显示(SDL2)

    #include 
     
    #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 
    #include 
    #include 
    #ifdef __cplusplus
    };
    #endif
    #endif
     
    //'1': Use H.264 Bitstream Filter 
    #define USE_H264BSF 0
     
    int main(int argc, char* argv[])
    {
    	AVOutputFormat *ofmt = NULL;
    	//Input AVFormatContext and Output AVFormatContext
    	AVFormatContext *ifmt_ctx = NULL, *ofmt_ctx = NULL;
    	AVPacket pkt;
    	const char *in_filename, *out_filename;
    	int ret, i;
    	int videoindex=-1;
    	int frame_index=0;
    	in_filename  = "rtmp://192.168.6.139:1935/live/stream";
    	out_filename = "receive.flv";
     
    	av_register_all();
    	//Network
    	avformat_network_init();
    	//Input
    	if ((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;
    		}
     
    	av_dump_format(ifmt_ctx, 0, in_filename, 0);
     
    	//Output
    	avformat_alloc_output_context2(&ofmt_ctx, NULL, NULL, out_filename); //RTMP
     
    	if (!ofmt_ctx) {
    		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 AVStream
    		AVStream *in_stream = ifmt_ctx->streams[i];
    		AVStream *out_stream = avformat_new_stream(ofmt_ctx, in_stream->codec->codec);
    		if (!out_stream) {
    			printf( "Failed allocating output stream\n");
    			ret = AVERROR_UNKNOWN;
    			goto end;
    		}
    		//Copy the settings of AVCodecContext
    		ret = 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 |= AV_CODEC_FLAG_GLOBAL_HEADER;
    	}
    	//Dump Format------------------
    	av_dump_format(ofmt_ctx, 0, out_filename, 1);
    	//Open output URL
    	if (!(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'", out_filename);
    			goto end;
    		}
    	}
    	//Write file header
    	ret = avformat_write_header(ofmt_ctx, NULL);
    	if (ret < 0) {
    		printf( "Error occurred when opening output URL\n");
    		goto end;
    	}
     
    #if USE_H264BSF
    	AVBitStreamFilterContext* h264bsfc =  av_bitstream_filter_init("h264_mp4toannexb"); 
    #endif
     
    	while (1) {
    		AVStream *in_stream, *out_stream;
    		//Get an AVPacket
    		ret = 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/DTS
    		pkt.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;
    		//Print to Screen
    		if(pkt.stream_index==videoindex){
    			printf("Receive %8d video frames from input URL\n",frame_index);
    			frame_index++;
     
    #if USE_H264BSF
    			av_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_H264BSF
    	av_bitstream_filter_close(h264bsfc);  
    #endif
     
    	//Write file trailer
    	av_write_trailer(ofmt_ctx);
    end:
    	avformat_close_input(&ifmt_ctx);
    	/* close output */
    	if (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;
    	}
    	return 0;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86
    • 87
    • 88
    • 89
    • 90
    • 91
    • 92
    • 93
    • 94
    • 95
    • 96
    • 97
    • 98
    • 99
    • 100
    • 101
    • 102
    • 103
    • 104
    • 105
    • 106
    • 107
    • 108
    • 109
    • 110
    • 111
    • 112
    • 113
    • 114
    • 115
    • 116
    • 117
    • 118
    • 119
    • 120
    • 121
    • 122
    • 123
    • 124
    • 125
    • 126
    • 127
    • 128
    • 129
    • 130
    • 131
    • 132
    • 133
    • 134
    • 135
    • 136
    • 137
    • 138
    • 139
    • 140
    • 141
    • 142
    • 143
    • 144
    • 145
    • 146
    • 147
    • 148
    • 149
    • 150
    • 151
    • 152
    • 153
    • 154
    • 155
    • 156
    • 157
    • 158
    • 159
    • 160
    • 161
    • 162
    • 163
    • 164
    • 165
    • 166
  • 相关阅读:
    Mysql语句的RegExp的用法与案例
    Keepalived+LVS部署
    Linux - 进程管理
    【Java面试】工作7年去字节面试竟然在这题翻车了,请你说一下你对时间轮的理解?
    JavaScript能否实现在线Excel附件的上传与下载?
    SSRF漏洞
    【LeetCode】792. 匹配子序列的单词数
    小程序源码:王者战力查询,游戏扫码登录,王者巅峰信息查询等等支持流量主收益和CPS收益-多玩法安装简单
    2019银川F,ccpc威海D - Sternhalma 2022
    matlab绘制动图
  • 原文地址:https://blog.csdn.net/sishen4199/article/details/134470867