《SRS原理》上架了，深度剖析 SRS 源代码，访问地址：srs.xianwaizhiyin.net
本文采用的 SRS 版本是 4.0-b8 ， 下载地址：github
本文讲解 SrsRtmpConn::stream_service_cycle() 函数的实现原理。流程图如下：
上面的流程图中有几个重点：
重点1，这里插个题 在调 stream_service_cycle() 之前，调了 trd->pull()， trd->pull() 在很多地方都出现，应该是个重点函数，具体另起一篇文章分析。本文暂时跳过。
stream_service_cycle() 开头有一些 RTMP edge 集群 的逻辑，这块先跳过不管，本文环境没配置集群，不会跑进去那块逻辑。
重点2，因为 info->type 是 SrsRtmpConnFMLEPublish，所以执行的是rtmp->start_fmle_publish() ，这个函数是做推流交互处理的，fmle 是什么缩写我也不太清楚，埋个坑，后面填。下图 wireshark 圈出来的交互部分就是这个函数做的。
start_fmle_publish() 函数里面使用了 expect_message() ，expect_message() 函数会阻塞等待客户端的RTMP包来，然后按顺序处理，完成整个推流的前期交互逻辑，例如流名称是啥，客户端总得先告诉服务器再推流。
重点3：_srs_sources->fetch_or_create() 创建了一个 SrsLiveSource，用 SrsLiveSource 来管理推流。请看后续文章《SRS4.0源码分析-SrsLiveSource》
_srs_sources 全局变量是在 srs_thread_initialize() 函数里面初始化的，代码如下：
_srs_sources = new SrsLiveSourceManager();重点4：SrsRtmpConn::publishing()，这个函数内部其实会阻塞的，里面会创建一个协程来处理后续的音视频推流，然后主协程就不行循环统计信息。
重点5：rtrd->start() 这个函数是重中之中，变量 rtrd 的创建代码如下：
SrsPublishRecvThread rtrd(rtmp, req, srs_netfd_fileno(stfd), 0, this, source, _srs_context->get_id());创建协程的地方，我截图贴出来：
我们知道，每次才创建协程之后，后面协程都是在 cycle() 函数跑起来的，所以 SrsRecvThread::cycle() 函数就是真正处理音视频推流的地方。
总结，本文其实只有3个重点。
1，推流的前期交互，创建流之类。
2，开一个协程函数 SrsRecvThread::cycle() 来处理客户端的音视频数据流推送。
3，主协程不断循环，统计流数据。
由于笔者的水平有限， 加之编写的同时还要参与开发工作，文中难免会出现一些错误或者不准确的地方，恳请读者批评指正。如果读者有任何宝贵意见，可以加我微信 Loken1。QQ：2338195090。