rtmp代码java rtmp rtp

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

你好,java怎么接受rtmp协议传过来的视频

今天尝试了一下利用ffmpeg 将流保存为MP4格式的是可以的,但是我想用RED5去看一下ffmpeg将rtsp转rtmp的效果,但是ffmpeg报了个不能连接端口,还在寻找原因中

安卓如何实现播放RTMP直播(代码怎么写)

Adboe的Red5流媒体服务器免费并且是开源的,与Flash搭配的时候可谓是天生一对,但使用Java和Android作为客户端调用却可谓一波三折。

Adobe的Red5源代码里有一个RTMPClient的类,这个类在使用上其实不复杂,但却没办法成功调用。观察日志,发现是连接成功后在开始创建流的时候,服务端把连接断开了。我能想到的解释就是可能公司现在所使用的Red5服务器的版本与这个RTMPClient不兼容。

有人接触过JUV_RTMP_Client这个吗 java的RTMP实现

非常麻烦,如果只是播放,很多种方式可以实现,比如在客户端嵌入一个webview,或者使用flex框架的air,就能简单实现.


分享名称:rtmp代码java rtmp rtp
分享网址:http://myzitong.com/article/hpejhj.html