1.SRS(simple-rtmp-server)流媒体服务器源码分析--RTMP消息play
SRS(simple-rtmp-server)流媒体服务器源码分析--RTMP消息play
本章内容梳理了SRS在接收到RTMP信息后如何进行转发的源码过程。在此过程中,分析首先进行代码梳理,源码作者也在源码熟悉阶段,分析可能尚未完全梳理完接受到RTMP后信息如何处理、源码指标源码平台缓存以及转发给直播用户等内容。分析检测机构 网站源码
SRS源码中的源码Play流程如下:
1. 进入play流程:本章内容直接从SrsRtmpConn::stream_service_cycle()方法开始梳理。
2. 在接受流程中,分析客户类型为SrsRtmpConnFMLEPublish “fmle publish”,源码而在转发流程中,分析客户类型为SrsRtmpConnPlay。源码
3. 在http_hooks_on_play()方法中,分析回调on_play()方法通知vhost,源码有源码小程序xxx用户已经开始play。分析
4. 在http_hooks_on_stop()方法中,源码回调on_stop()方法通知vhost,xxx用户已经停止play。相册和视频源码
5. 最重要的是进入该函数。
在函数中:
1.1 根据客户端创建消费者对象:create_consumer(this, consumer)
1.2 为该消费者开启一个独立协程:trd.start() //此处一直不太明白,在play流程中创建一个协程用来做什么?
1.3 进入play主流程:do_playing(source, consumer, &trd);
2. 进入主play循环:do_playing()函数内容众多且非常重要,因此将函数内容全部列出。下级网格系统源码
2.1 通知消费者准备play
2.2 从消费者列表中取出Rtmp信息(SrsMessageQueue)
2.3 进入play入口
3. 进入SRS发送接口(play):在int SrsProtocol::send_and_free_messages(SrsSharedPtrMessage** msgs, int nb_msgs, int stream_id)函数中,进入int SrsProtocol::do_send_messages(SrsSharedPtrMessage** msgs, int nb_msgs),该函数有一个#ifdef SRS_PERF_COMPLEX_SEND宏定义,一般rtmp协议都是要混合音视频数据,在做转发。在往后面看,
最后进入
在该函数中,最重要的一点是send message总出口writen()函数。它负责将转发给直播用户的流转发出去。
4. 最后:play总结
(1)通知client开始play
(2)从消费者列表中取出Rtmp数据
(3)从总出口writev()函数中转发出去
2024-12-28 19:47
2024-12-28 19:46
2024-12-28 19:31
2024-12-28 19:19
2024-12-28 19:09
2024-12-28 18:08