SRS4.0源码分析-SrsRecvThread::cycle

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

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

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

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

上面的变量 pumper 是 SrsPublishRecvThread，所以 on_start() 是指 SrsPublishRecvThread 的 on_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 处理，之前说过 pumper 是 SrsPublishRecvThread，在这里，大部分的 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() 函数的内部逻辑，这里的 _conn 是 SrsRtmpConn，SrsRtmpConn::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* video 跟SrsVideoCodecConfig* 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。

推荐一个零声学院免费公开课程，个人觉得老师讲得不错，分享给大家：

Linux，Nginx，ZeroMQ，MySQL，Redis，fastdfs，MongoDB，ZK，流媒体，CDN，P2P，K8S，Docker，TCP/IP，协程，DPDK等技术内容，立即学习