SRS4.0源码分析-SrsRecvThread::cycle - 弦外之音

/ 0评 / 1

本文采用的 SRS 版本是 4.0-b8 , 下载地址:github


从《SRS4.0源码分析-SrsRtmpConn::stream_service_cycle》 得知 ,真正接受客户端音视频流数据的地方是 SrsRecvThread::cycle()

那客户端推视频流来之后,服务器有没缓存?服务器缓存多少秒?怎么配置 SRS 让 RTMP 直播的延迟降低?

带着这些疑问,开始研究。 SrsRecvThread::cycle() 函数 的 代码如下:

上面的变量 pumperSrsPublishRecvThread,所以 on_start() 是指 SrsPublishRecvThreadon_start()

SrsRecvThread::cycle() 是一个协程函数,里面的重点是 do_cycle(),接下来分析 SrsRecvThread::do_cycle() 函数。代码如下:

SrsRecvThread::do_cycle() 函数 的重点如下:

1,再次见到这个 trd->pull() 这个应该是个错误码封装处理。

2,最重要的是下面两行代码。

// Process the received message.
if ((err = rtmp->recv_message(&msg)) == srs_success) {
    err = pumper->consume(msg);
}

读取 RTMP 消息,然后丢给 pumper 处理,之前说过 pumperSrsPublishRecvThread,在这里,大部分的 RTMP消息 都是音频帧或者视频帧。这里拿到的 RTMP 消息已经是由多个 chunk 拼接成一个完整的视频帧的了。



下面开始分析 SrsPublishRecvThread::consume() 函数的内部逻辑,代码如下:

上图有两个重点:

1,统计 video_frames,代码如下:

if (msg->header.is_video()) {
    video_frames++;
}

2,把 RTMP 消息丢给 _conn 处理,代码如下:

err = _conn->handle_publish_message(_source, msg);

3,最后使用了一下 srs_thread_yield(),yield 的原理,请看后续文章 《SRS4.0源码分析-yield》


接下来分析 _conn->handle_publish_message() 函数的内部逻辑,这里的 _connSrsRtmpConnSrsRtmpConn::handle_publish_message() 代码如下:

上图就两个逻辑:

1,处理 AMF 类型 的 RTMP消息。

2,用 process_publish_message() 处理视频,音频的 RTMP消息。

继续分析 process_publish_message() 函数的实现,请看下图代码:

process_publish_message() 函数有3个重点:

1,处理 MetaData 数据,RTMP直播传输音视频,通常情况 MetaData 是用 flv 那种 tag 封装的,但是 视频帧是直接传的 H264的裸数据,H264有一个网络传输层。

2,处理音频数据。

3,处理视频数据。

咱们主要分析视频的推流,音频先放一放,所以接下来分析 source->on_video() 函数的实现,代码如下:

source->on_video() 函数 主要有以下逻辑:

1,检测视频帧的时间戳是不是递增的,检查RTMP头有没问题。

2,调 on_video_imp() 处理视频帧。

到这里,整体的函数调用链条有点长,先画个流程图便于理解:


下面开始分析 on_video_imp() 函数的实现,代码如下:

on_video_imp() 函数 主要有 3个重点:

1,对 sequence_header 的处理。sequence_header 可以理解为 H264 网络包的一个头。具体定义在 标准⽂档《ISO-14496-15 AVC file format》,搜索 AVCDecoderConfigurationRecord 就行。

2,hub->on_video() 就是 SrsOriginHub::on_video(),这个函数主要把 H264包数据,解析到 两个变量 SrsVideoFrame* videoSrsVideoCodecConfig* vcodec

3,bridger_->on_video() 就是 SrsRtcFromRtmpBridger::on_video(),这个主要是一个桥接转换。 RTMP 转 SRT,RTC 的,不用管。

4,consumer->enqueue()SrsLiveConsumer::enqueue(),这个是重中之重,会把 H264 视频帧 插入队列,然后如果达到 350000 毫秒就通过条件变量,通知播放协程来取数据。

到这里,我们已经找到了,服务器缓存 视频的地方,服务器缓存视频默认是 350000,这个值应该可以在配置文件设置。

播放协程阻塞的地方我截图一下:

SrsRecvThread::cycle() 函数分析完毕,下一篇文章讲解如何降低 RTMP 直播的延迟。


由于笔者的水平有限, 加之编写的同时还要参与开发工作,文中难免会出现一些错误或者不准确的地方,恳请读者批评指正。如果读者有任何宝贵意见,可以加我微信 Loken1。QQ:2338195090。

发表回复

您的电子邮箱地址不会被公开。