SRS RTMP 发布和播放代码解析

主程序启动后，会根据config判断是控制台模式还是后台运行模式，之后进入run_hybrid_server启动各种服务,rtmp,http,https,rtc等等服务；

SrsServerAdapter 各种服务器的适配，rtmp，http，https等，RtcServerAdapter 是webrtc的服务，此篇我们就分析rtmp服务，所以进入SrsServerAdapter后，就会进行各种服务器的监听，调用到，后调用

SrsServer::listen() ->SrsBufferListener::listen ->new SrsTcpListener(this, ip, port)

rtmp使用的是tcp，所以就开始监听tcp了

srs_tcp_listen创建socket并监听

之后new SrsSTCoroutine("tcp", this)创建协程，调用start会调用SrsTcpListener::cycle()；

具体流程是

协程里面处理accept等待客户端的连接，客户端连接请求后，开始回调on_tcp_client，即调用 SrsBufferListener::on_tcp_client()

调用 SrsServer::accept_client

调用fd_to_resource，根据type创建不同的ISrsStartableConneciton，这里rtmp是SrsListenerRtmpStream，所以返回new SrsRtmpConn 而后调用 SrsRtmpConn::start

class SrsRtmpConn : virtual public ISrsCoroutineHandler

所以调用到SrsRtmpConn::cycle(),里面调用SrsRtmpConn::do_cycle()

开始握手，建立rtmp连接，进入SrsRtmpConn::service_cycle()

建立连接后，设置rtmp

set_window_ack_size

set_peer_bandwidth

set_chunk_size

调用 SrsRtmpConn::stream_service_cycle()

首先进行rtmp->identify_client 客户端的身份识别

然后再根据不同的客户端类型type进入不同的分支

SrsRtmpConnPlay 客户端播流。

SrsRtmpConnFMLEPublish Rtmp推流到服务器。

SrsRtmpConnHaivisionPublish 应该是海康威视推流到服务器

SrsRtmpConnFlashPublish Flash推流到服务器。

我们先看推流 SrsRtmpConnFMLEPublish

首先 start_fmle_publish 创建流

然后进入 publishing

SrsPublishRecvThread rtrd(rtmp, req, srs_netfd_fileno(stfd), 0, this, source, _srs_context->get_id())

err = do_publishing(source, &rtrd)

SrsPublishRecvThread 有

SrsRecvThread trd

SrsRtmpServer* rtmp

class SrsRecvThread : public ISrsCoroutineHandler

所以rtrd->start后，会调用SrsRecvThread::cycle()再调用do_cycle()

rtmp->recv_message读取数据->SrsProtocol::recv_message ->

pumper->consume 调回 SrsRtmpConn::handle_publish_message(SrsSource* source, SrsCommonMessage* msg)

然后调用 process_publish_message

如果是edge边缘服务器，直接推流回源到源服务器

处理audio数据

处理video数据

我们先看处理video数据

SrsCommonMessage* shared_video 转换为 SrsSharedPtrMessage msg

mix_correct是混合单增算法，解决音频和视频混合单增的问题

这里没有设置，就直接走on_video_imp

首先判断是不是sequence header, 如果是，判断跟之前的有没有一样，一样，那就只缓存一次，根据源码可知，音视频的metadata只发一次，如果有新的拉流端需求，怎样更新呢？

缓存h264 sequence header, hls分发，dvs分发，forwarders推流等，之后就客户端消费者分发，如果有客户端请求播放，那就会有consumer了，就可以进入consumer->enqueue

每个SrsConsumer消费者拥有独立的SrsMessageQueue* queue队列。内部队列实现实际上是SrsFastVector msgs

SrsMessageQueue有数量大小限制，当队列满的时候删除丢弃旧的messages：

队列大小限制queue_size设置为配置文件中的"queue_length"。如果没设置则默认#define SRS_PERF_PLAY_QUEUE 30。

max_queue_size = (int)(queue_size * 1000)

推流到此就结束了，而后播放端请求拉流，前面的基本一致，从

srs_error_t SrsRtmpConn::stream_service_cycle()

{

srs_error_t err = srs_success

}

会走 SrsRtmpConnPlay分支

SrsRtmpConn::do_playing

SrsConsumer::dump_packets

SrsMessageQueue::dump_packets

即前面的SrsMessageQueue* queue里面取数据了

SrsRtmpServer::send_and_free_messages

网络直播平台的实现技术，归纳起来主要有如下这些：

一、视音频的采集和编码技术，当前主流的主要是H.264、H.265这种视频编码技术和AAC、MP3这种音频编码技术。

二、视音频的流媒体传输技术。

三、CDN内容分发技术。

四、终端解码技术。

架构方面，如果要做运营级的服务平台，需要采用分布式的架构方式，不仅包括各个功能模块的分布式部署，还包括各种应用服务器的分布式部署。

流媒体传输技术通常使用的方式主要包括：

1、通过HTTP协议传输，需要通过技术开发来实现高性能的HTTP流媒体服务器；

2、通过RTMP协议传输，需要通过技术开发来实现高性能的RTMP流媒体服务器；

3、通过UDP协议传输，这种方式通常用于大规模的可控网络中，比如IPTV电视直播应用，通过交换机即可支持这种传输方式；

4、通过P2P方式传输，P2P方式所用的传输协议可以由用户自主定义，并且可以基于UDP或TCP来实现，这种方式通常也是用于超大规模组网环境中。

Nginx：Nginx是一个非常出色的HTTP服务器，其特点是占有内存少，并发能力强，事实上nginx的并发能力确实在同类型的网页服务器中表现较好。

在浏览器地址栏输入： http://localhost:8080 （直接点击）

如果出现下图, 则表示安装成功

前往该路径

只推流摄像头（不带麦）推流指令

推屏幕

只推麦

使用ffplay播放rtmp推流

---