SRS4.0源码分析-SrsRtmpConn::stream_service_cycle - 弦外之音

/ 0评 / 0

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



本文讲解 SrsRtmpConn::stream_service_cycle() 函数的实现原理。流程图如下:

上面的流程图中有几个重点:

重点1,这里插个题 在调 stream_service_cycle() 之前,调了 trd->pull()trd->pull() 在很多地方都出现,应该是个重点函数,具体另起一篇文章分析。本文暂时跳过。

stream_service_cycle() 开头有一些 RTMP edge 集群 的逻辑,这块先跳过不管,本文环境没配置集群,不会跑进去那块逻辑。

重点2,因为 info->typeSrsRtmpConnFMLEPublish,所以执行的是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。

发表回复

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