ffmpeg源码分析_SRS流媒体之RTMP拉流框架分析(3)

╰+哭是因爲堅強的太久メ 2023-01-10 11:56 165阅读 0赞

**0.引言**

阅读本文前，先参考前面的文章，能够帮你更好地理解，文章列表如下:

手把手搭建流媒体服务器详细步骤

SRS流媒体之RTMP推流框架分析(2)

流媒体服务器架构与应用分析

SRS流媒体框架分析(1)

简述SRS流媒体服务器相关技术

**1.拉流框架核心类简述**

核心类如下：

**SrsServer SRS**:流媒体服务入口。

**SrsBufferListener**:监听器，主要是TCP的监听。

**SrsTcpListener**:TCP监听器。

**SrsRtmpConn** :表示RTMP连接，里面对应了**SrsStSocket和SrsCoroutine**。

**SrsRtmpServer**:提供与客户端之间的RTMP-命令-协议-消息的交互服务，使用SrsRtmpConn提供的socket读写数据。

**SrsSource**：描述一路播放源，包括推流和拉流的描述。SrsConsumer从这里取的是音视频的数据。

**SrsConsumer**:拉流消费者，每一路拉流客户端对应一个SrsConsumer。

**SrsStSocket**:经过封装的socket接口。

**SrsRecvThread**:负责接收数据，但是要注意的是，这里并不是从IO里读取数据。而是从**SrsRtmpServer类拉取数据**，然后推送到SrsPublishThread(推流用)，或SrsQueueRecvThread(拉流用)。SrsRecvThread接收的消息是每个play(SrsRtmpConn)独有。这里拷贝数据都是浅拷贝(深拷贝比较耗时和占内存)，使用引用计数去控制。

**SrsQueueRecvThread**:**主要用于拉流**，**对应的是**客户端-服务器的**控制消息**，和音视频消息没有关系，客户端读取**数据还是从consumer的queue里面去读取**。

![9d12a3894fb4ae3ad6d62c0ea30e7547.png][]

客户端推流端经过SrsRtmpConn建立连接，然后推流到流媒体服务器，并使用SrsSource来管理流，同时把流放进队列，使用SrsConsumer来管理。客户端播放端就通过SrsRtmpConn建立连接，然后从SrsConsumer中去取队列的数据，并播放。

**注意：**每个播放端，所持有的连接都是独立。

![dfd71128faddddd70b3a9e40938595a6.png][]

**2.推拉流测试命令**

客户端推流测试

ffmpeg -re -i  xxx.flv -vcodec  copy  -acodec  copy  -f  flv  -y  rtmp://xxx.xxx.xxx.xxx/live/livestream

客户端拉流测试

ffplay  rtmp://xxx.xxx.xxx.xxx/live/livestream

**3.RTMP拉流框架源码分析**

前面文章讲解了推流的源码框架分析，本篇文章讲解拉流的源码框架分析。源码流程如下：

![8f6b5d2e332c77c5a88e4db262c0dbd7.png][]

首先，发送一些控制命令信息。

![b9de1b7e674d8ecf8c4505544a558c9a.png][]

![debb0757826c973fcda9d722c1c49177.png][]

然后对每个拉流，都会创建一个consumer。源码如下图：

这里会把Source、consumer、SrsRtmpConn绑定起来。

![4f1f2b1d3eb844f39de7746144c833a4.png][]

独立每个客户端。

![0385e1563bf6bdcb3caf0d244bed055f.png][]

接下来，就是do\_playing的工作。源码如下：

![d6c5587678c0f2eb36bc9e7e83bc33a3.png][]

播放客户端在do\_playing里面要读取控制命令消息。源码如下：

![ce8bb23b1da6da842fcc1d5c23d480f4.png][]

在do\_playing里面可以设置，多久从客户端去读一次数据。源码如下：

这里的0表示，不等数据的累计。如果要累计，默认就是8ms。

![ce415bfd821f546e781a33760db2b4ce.png][]

从队列中，使用consumer->dump\_packets()读取音视频数据，源头是source输入过来的。

![3cca42a58dba647f26b1917586a8216c.png][]

通过rtmp->send\_and\_free\_message()，发送音视频数据给播放客户端。源码如下:

![b813d52a6be67854dfe0d5016a2b8a0b.png][]

![630f2f3897137a31c3d25ae317f081cd.png][]

do\_send\_messages调用do\_iovs\_send发送，再调用srs\_write\_large\_iovs。

![33b10fcc40729d79b1302c1c5bb8f42c.png][]

发现这里，发送数据还是通过底层socket IO去发送。

![261ca167bfb7fd65d3b8c03e7f1b812b.png][]

**4.RTMP拉流框架端点调试**

断点调试

启动后输入命令

**b SrsRtmpConn::process\_play\_control\_msg(SrsConsumer\*，SrsCommonMessage\*)**

如下界面:

![0de5e0b0b336ca66284226f9d57e0739.png][]

打断点成功，再输入命令

**r**

如下界面:

![026ba31985741b7acb3cae5ad5092547.png][]

在运行到这里之前，就要启动播放端。输入命令：

**print \*msg**

界面如下：

![5e5d26a0cdcaf99e079fb571f3e0ef9e.png][]

再继续输入命令：

**c**

界面如下:

![0facc600a77bef8b68d5d3337e7a5050.png][]

播放一会儿后，继续输入命令：

**print \*msg**

界面如下:

发现这里的message\_type变成了3。

![f7e7c01f39f911bf58b310414d893b9a.png][]

看源码后，知道，这里是指播放端读取一定数据后，做的一个应答。源码如下:

![9cf2b2e7fd42f365f32e3e2632095de0.png][]

播放端每次读取到一定数据后，就会发送给服务器一定的确认信息，这个上报的频率是比较固定。源码如下:

![cf89c4c16e0074b447e3979496eaffa8.png][]

无论是在推流还是拉流，首先都要去判断是否有可用的source。如果推流端开始推流，srs流媒体服务器这里会去创建source url、consumer等。流媒体服务器信息如下图：

![614a43178c94eeb604565f9efbefbc93.png][]

**5.总结**

本篇文章结合源码和端点调试，分析了RTMP拉流框架流程，这是更深入学习RTMP流媒体服务器必定要经历的过程。希望能够帮助到大家。

本篇文章就分析到这里，**欢迎关注，转发，点赞，收藏，分享，评论区讨论。**

后期关于项目的知识，会在微信公众号上更新，如果想要学习项目，可以关注微信公众号“记录世界 from antonio”

[9d12a3894fb4ae3ad6d62c0ea30e7547.png]: /images/20221119/58a8d2a35414431da05ea88b82ac911d.png
[dfd71128faddddd70b3a9e40938595a6.png]: /images/20221119/2adb49c0d7f34f62a140853aa144d7fa.png
[8f6b5d2e332c77c5a88e4db262c0dbd7.png]: /images/20221119/1b1352214e2f442b9e04fd6204fb5b1b.png
[b9de1b7e674d8ecf8c4505544a558c9a.png]: https://img-blog.csdnimg.cn/img_convert/b9de1b7e674d8ecf8c4505544a558c9a.png
[debb0757826c973fcda9d722c1c49177.png]: https://img-blog.csdnimg.cn/img_convert/debb0757826c973fcda9d722c1c49177.png
[4f1f2b1d3eb844f39de7746144c833a4.png]: https://img-blog.csdnimg.cn/img_convert/4f1f2b1d3eb844f39de7746144c833a4.png
[0385e1563bf6bdcb3caf0d244bed055f.png]: https://img-blog.csdnimg.cn/img_convert/0385e1563bf6bdcb3caf0d244bed055f.png
[d6c5587678c0f2eb36bc9e7e83bc33a3.png]: https://img-blog.csdnimg.cn/img_convert/d6c5587678c0f2eb36bc9e7e83bc33a3.png
[ce8bb23b1da6da842fcc1d5c23d480f4.png]: https://img-blog.csdnimg.cn/img_convert/ce8bb23b1da6da842fcc1d5c23d480f4.png
[ce415bfd821f546e781a33760db2b4ce.png]: https://img-blog.csdnimg.cn/img_convert/ce415bfd821f546e781a33760db2b4ce.png
[3cca42a58dba647f26b1917586a8216c.png]: https://img-blog.csdnimg.cn/img_convert/3cca42a58dba647f26b1917586a8216c.png
[b813d52a6be67854dfe0d5016a2b8a0b.png]: https://img-blog.csdnimg.cn/img_convert/b813d52a6be67854dfe0d5016a2b8a0b.png
[630f2f3897137a31c3d25ae317f081cd.png]: https://img-blog.csdnimg.cn/img_convert/630f2f3897137a31c3d25ae317f081cd.png
[33b10fcc40729d79b1302c1c5bb8f42c.png]: https://img-blog.csdnimg.cn/img_convert/33b10fcc40729d79b1302c1c5bb8f42c.png
[261ca167bfb7fd65d3b8c03e7f1b812b.png]: https://img-blog.csdnimg.cn/img_convert/261ca167bfb7fd65d3b8c03e7f1b812b.png
[0de5e0b0b336ca66284226f9d57e0739.png]: https://img-blog.csdnimg.cn/img_convert/0de5e0b0b336ca66284226f9d57e0739.png
[026ba31985741b7acb3cae5ad5092547.png]: https://img-blog.csdnimg.cn/img_convert/026ba31985741b7acb3cae5ad5092547.png
[5e5d26a0cdcaf99e079fb571f3e0ef9e.png]: https://img-blog.csdnimg.cn/img_convert/5e5d26a0cdcaf99e079fb571f3e0ef9e.png
[0facc600a77bef8b68d5d3337e7a5050.png]: https://img-blog.csdnimg.cn/img_convert/0facc600a77bef8b68d5d3337e7a5050.png
[f7e7c01f39f911bf58b310414d893b9a.png]: https://img-blog.csdnimg.cn/img_convert/f7e7c01f39f911bf58b310414d893b9a.png
[9cf2b2e7fd42f365f32e3e2632095de0.png]: https://img-blog.csdnimg.cn/img_convert/9cf2b2e7fd42f365f32e3e2632095de0.png
[cf89c4c16e0074b447e3979496eaffa8.png]: https://img-blog.csdnimg.cn/img_convert/cf89c4c16e0074b447e3979496eaffa8.png
[614a43178c94eeb604565f9efbefbc93.png]: https://img-blog.csdnimg.cn/img_convert/614a43178c94eeb604565f9efbefbc93.png