srs代码学习（1）--listen建立过程

srs的服务侦听的建立过程。

以rtmp服务为例 srs服务侦听的建立依靠从上到下的三个类。分别是

SrsServer

SrsStreamListener

SrsTcpListener

端口侦听过程为

1）main函数中调用全局变量_srs_server的 listen（）函数

[cpp] view plain copy

if ((ret = _srs_server->listen()) != ERROR_SUCCESS) {
return ret;
}

[cpp] view plain copy

在SrsServer的listen（）函数如下

[cpp] view plain copy

<pre name="code" class="cpp">int SrsServer::listen()
{
int ret = ERROR_SUCCESS;
if ((ret = listen_rtmp()) != ERROR_SUCCESS) {
return ret;
}
if ((ret = listen_http_api()) != ERROR_SUCCESS) {
return ret;
}
if ((ret = listen_http_stream()) != ERROR_SUCCESS) {
return ret;
}
if ((ret = listen_stream_caster()) != ERROR_SUCCESS) {
return ret;
}
return ret;
}

[cpp] view plain copy

listen_rtmp（）会建立一个rtmp的steamlistener

[cpp] view plain copy

<pre name="code" class="cpp">int SrsServer::listen_rtmp()
{
int ret = ERROR_SUCCESS;
// stream service port.
std::vector<std::string> ip_ports = _srs_config->get_listens();
srs_assert((int)ip_ports.size() > 0);
close_listeners(SrsListenerRtmpStream);
for (int i = 0; i < (int)ip_ports.size(); i++) {
SrsListener* listener = new SrsStreamListener(this, SrsListenerRtmpStream);
listeners.push_back(listener);
std::string ip;
int port;
srs_parse_endpoint(ip_ports[i], ip, port);
if ((ret = listener->listen(ip, port)) != ERROR_SUCCESS) {
srs_error("RTMP stream listen at %s:%d failed. ret=%d", ip.c_str(), port, ret);
return ret;
}
}
return ret;
}

这个streamlistener并不是真正的底层监听层。只是一个业务封装层。其类的继承顺序如下

在整个代码中，和其相识的类有SrsRtspListener SrsHttpFlvListener两个类。这种类的主要作用是在底层链接建立有。给不同的上层放回链接信息。

代码走到这一步，侦听的socket还么米有建立起来，看SrsStreamListener的listen()函数

[cpp] view plain copy

int SrsStreamListener::listen(string i, int p)
{
int ret = ERROR_SUCCESS;
ip = i;
port = p;
srs_freep(listener);
listener = new SrsTcpListener(this, ip, port);
if ((ret = listener->listen()) != ERROR_SUCCESS) {
srs_error("tcp listen failed. ret=%d", ret);
return ret;
}
srs_info("listen thread current_cid=%d, "
"listen at port=%d, type=%d, fd=%d started success, ep=%s:%d",
_srs_context->get_id(), p, type, listener->fd(), i.c_str(), p);
srs_trace("%s listen at tcp://%s:%d, fd=%d", srs_listener_type2string(type).c_str(), ip.c_str(), port, listener->fd());
return ret;
}

在这段代码里面。创建了真正的底层监听类

[cpp] view plain copy

listener = new SrsTcpListener(this, ip, port);

然后调用其listen()函数。代码如下

[cpp] view plain copy

int SrsTcpListener::listen()
{
int ret = ERROR_SUCCESS;
if ((_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
ret = ERROR_SOCKET_CREATE;
srs_error("create linux socket error. port=%d, ret=%d", port, ret);
return ret;
}
srs_verbose("create linux socket success. port=%d, fd=%d", port, _fd);
int reuse_socket = 1;
if (setsockopt(_fd, SOL_SOCKET, SO_REUSEADDR, &reuse_socket, sizeof(int)) == -1) {
ret = ERROR_SOCKET_SETREUSE;
srs_error("setsockopt reuse-addr error. port=%d, ret=%d", port, ret);
return ret;
}
srs_verbose("setsockopt reuse-addr success. port=%d, fd=%d", port, _fd);
sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_port = htons(port);
addr.sin_addr.s_addr = inet_addr(ip.c_str());
if (bind(_fd, (const sockaddr*)&addr, sizeof(sockaddr_in)) == -1) {
ret = ERROR_SOCKET_BIND;
srs_error("bind socket error. ep=%s:%d, ret=%d", ip.c_str(), port, ret);
return ret;
}
srs_verbose("bind socket success. ep=%s:%d, fd=%d", ip.c_str(), port, _fd);
if (::listen(_fd, SERVER_LISTEN_BACKLOG) == -1) {
ret = ERROR_SOCKET_LISTEN;
srs_error("listen socket error. ep=%s:%d, ret=%d", ip.c_str(), port, ret);
return ret;
}
srs_verbose("listen socket success. ep=%s:%d, fd=%d", ip.c_str(), port, _fd);
if ((_stfd = st_netfd_open_socket(_fd)) == NULL){
ret = ERROR_ST_OPEN_SOCKET;
srs_error("st_netfd_open_socket open socket failed. ep=%s:%d, ret=%d", ip.c_str(), port, ret);
return ret;
}
srs_verbose("st open socket success. ep=%s:%d, fd=%d", ip.c_str(), port, _fd);
if ((ret = pthread->start()) != ERROR_SUCCESS) {
srs_error("st_thread_create listen thread error. ep=%s:%d, ret=%d", ip.c_str(), port, ret);
return ret;
}
srs_verbose("create st listen thread success, ep=%s:%d", ip.c_str(), port);
return ret;
}

到此，rtmp的监听端口就建立起来了。

在仔细看SrsTcpListener类。继承关系如下

这个类中很有趣的有了个线程类SrsReusableThread* pthread，这个线程是什么时候建立的？答案是在构造函数中

[cpp] view plain copy

SrsTcpListener::SrsTcpListener(ISrsTcpHandler* h, string i, int p)
{
handler = h;
ip = i;
port = p;
_fd = -1;
_stfd = NULL;
pthread = new SrsReusableThread("tcp", this);
}

这个类的作用是什么呢？首先我们发现， SrsTcpListener 这个类继承了一个线程回调接口ISrsReusableThreadHandler。这个说明可以拥有可以在线程中运行的能力

观察线程类的结构

很奇怪，SrsReusableThread竟然也继承了一个handler类。这就表示。这个类还是一个封装类，并不是底层的真正的线程类。果然我们发现了其一个变量 internal::SrsThread* pthread，这个应该靠近点底层了吧。先放下不讲。我们是来追这个线程类也我的业务类啥关系的。这时另外一个有意思的变量ISrsReusableThreadHandler* handler，还记得
SrsTcpListener 类么，其有一个ISrsReusableThreadHandler的接口。通过这个接口，把线程和业务链接起来。看看其cycle()函数

[cpp] view plain copy

int SrsReusableThread::cycle()
{
return handler->cycle();
}

这个是线程这执行函数。它会调用上层类，具体到我们的例子里，就是 SrsTcpListener 的cycle().看看是什么

[cpp] view plain copy

int SrsTcpListener::cycle()
{
int ret = ERROR_SUCCESS;
st_netfd_t client_stfd = st_accept(_stfd, NULL, NULL, ST_UTIME_NO_TIMEOUT);
if(client_stfd == NULL){
// ignore error.
if (errno != EINTR) {
srs_error("ignore accept thread stoppped for accept client error");
}
return ret;
}
srs_verbose("get a client. fd=%d", st_netfd_fileno(client_stfd));
if ((ret = handler->on_tcp_client(client_stfd)) != ERROR_SUCCESS) {
srs_warn("accept client error. ret=%d", ret);
return ret;
}
return ret;
}

原来是accept函数。在有链接后直接上调给上层，具体来讲就是 SrsStreamListener类的 on_tcp_client（）函数

[cpp] view plain copy

int SrsStreamListener::on_tcp_client(st_netfd_t stfd)
{
int ret = ERROR_SUCCESS;
if ((ret = server->accept_client(type, stfd)) != ERROR_SUCCESS) {
srs_warn("accept client error. ret=%d", ret);
return ret;
}
return ret;
}

欧耶，这下调用到最上层去了。server里，建立一个链接。

到现在还有两个问题要搞明白：

1）srs的线程模型

2）如何管理各个链接。

这个下一次在摸索

http://blog.csdn.NET/ddr77/article/details/52314210

srs代码学习（1）--listen建立过程相关推荐

srs代码学习（4）-怎么转发流
publish的流和play的流怎么连接呢?这个恐怕是最绕的地方了.看了一上午的代码,淹没于各种数据结构与流程之中后,俺终于发现了连接publish和play的关键连个类是 SrsSource Srs ...
srs代码学习（2）- 线程模型
代码阅读到现在.发现srs有两大类线程.一个是主线程的逻辑. 一个是监听线程簇.结构图如下一定还有第三种线程模型,负责底层的多路分发.今天还没有发现. 2016.08.25--21:00 仔细阅读了 ...
程世东老师TensorFlow实战——个性化推荐，代码学习笔记之③推荐过程
个性化推荐第三部分:推荐过程(完结撒花) 代码来自于知乎:https://zhuanlan.zhihu.com/p/32078473 /代码地址https://github.com/chengston ...
HEVC代码学习：帧间预测——MVP过程中MV的获取、传递及存储
作为一个视频编码小白,最近开始着手啃HEVC帧间预测的代码,想用博客记录一下自己的学习过程,也想与大家分享.交流一下. HEVC代码的学习主要是参考两位大神岳麓吹雪.NB_vol_1的博客以及HM参考 ...
DL之GRU：GRU算法相关论文、建立过程(基于TF)、相关思路配图集合、TF代码实现
DL之GRU:GRU算法相关论文.建立过程(基于TF).相关思路配图集合.TF代码实现目录 GRU算法相关论文 GRU算法建立过程(基于TF) GRU算法的TF代码实现 GRU算法相关论文 GRU是 ...
深度学习模型建立过程_所有深度学习都是统计模型的建立
深度学习模型建立过程 Deep learning is often used to make predictions for data driven analysis. But what are th ...
TLS就是SSL的升级版+网络安全——一图看懂HTTPS建立过程——本质上就是引入第三方监管，web服务器需要先生成公钥和私钥，去CA申请，https通信时候浏览器会去CA校验CA证书的有效性...
起初是因为HTTP在传输数据时使用的是明文(虽然说POST提交的数据时放在报体里看不到的,但是还是可以通过抓包工具窃取到)是不安全的,为了解决这一隐患网景公司推出了SSL安全套接字协议层,SSL是基于 ...
为什么无法建立过程性能模型？
在CMMI四五级的软件公司中,建立过程性能模型是一个重点也是一个难点工作,很多公司无法建立过程性能模型,为什么呢? 1)数据不准比如: Ø 对于评审的会议,评审的参与人有的是来学习的,在统计人数.工 ...
Apollo代码学习(二)—车辆运动学模型
Apollo代码学习-车辆运动学模型前言车辆模型单车模型(Bicycle Model) 车辆运动学模型阿克曼转向几何(Ackerman turning geometry) 小结 Apollo( ...

srs代码学习（1）--listen建立过程

srs代码学习（1）--listen建立过程相关推荐

最新文章

热门文章