Swoole源码学习记录（十四）――Server模块详解（下）(一)

?

1.swServer函数分析

swServer_addListener

该函数用于在swServer中添加一个需要监听的host及port。函数原型如下：

// Server.h 438h
int swServer_addListener(swServer *serv, int type, char *host,int port);

函数核心源码：

    // Server.c 900~943h
    swListenList_node *listen_host = SwooleG.memory_pool->alloc(SwooleG.memory_pool, sizeof(swListenList_node));

    listen_host->type = type;
    listen_host->port = port;
    listen_host->sock = 0;
    listen_host->ssl = 0;

    bzero(listen_host->host, SW_HOST_MAXSIZE);
    strncpy(listen_host->host, host, SW_HOST_MAXSIZE);
    LL_APPEND(serv->listen_list, listen_host);

    //UDP需要提前创建好
    if (type == SW_SOCK_UDP || type == SW_SOCK_UDP6 || type == SW_SOCK_UNIX_DGRAM)
    {
        int sock = swSocket_listen(type, listen_host->host, port, serv->backlog);
        if (sock < 0)
        {
            return SW_ERR;
        }
        //设置UDP缓存区尺寸，高并发UDP服务器必须设置
        int bufsize = serv->udp_sock_buffer_size;
        setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize));
        setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));

        listen_host->sock = sock;
        serv->have_udp_sock = 1;
    }
    else
    {
        if (type & SW_SOCK_SSL)
        {
            type = type & (~SW_SOCK_SSL);
            listen_host->type = type;
            listen_host->ssl = 1;
        }
        if (type != SW_SOCK_UNIX_STREAM && port <= 0)
        {
            swError(listen port must greater than 0.);
            return SW_ERR;
        }
        serv->have_tcp_sock = 1;
    }
    return SW_OK;

源码解释：
在SwooleG的共享内存池中创建一个swListenList_node，并设置type等相关参数，并将该node添加进swServer的listen_list。随后，判定type类型。如果是UDP类型的socket，需要直接调用swSocket_listen进行监听，并根据swServer的udp_sock_buffer_size设置socket的缓存区大小；如果是TCP类型的socket，只针对两种特别的type类型做判定（SSL类型要设置ssl开关，非Unix Sock类型要保证监听端口大于0）。

swServer_listen

该函数用于开始监听swServer中全部的TCP类型的socket。函数原型如下：

// Server.h 440h
int swServer_listen(swServer *serv, swReactor *reactor);

函数核心源码：

    // Server.c 949-998h
    LL_FOREACH(serv->listen_list, listen_host)
    {
        //UDP
        if (listen_host->type == SW_SOCK_UDP || listen_host->type == SW_SOCK_UDP6 || listen_host->type == SW_SOCK_UNIX_DGRAM)
        {
            continue;
        }

        //TCP
        sock = swSocket_listen(listen_host->type, listen_host->host, listen_host->port, serv->backlog);
        if (sock < 0)
        {
            LL_DELETE(serv->listen_list, listen_host);
            return SW_ERR;
        }

        if (reactor!=NULL)
        {
            reactor->add(reactor, sock, SW_FD_LISTEN);
        }

#ifdef TCP_DEFER_ACCEPT
        int sockopt;
        if (serv->tcp_defer_accept > 0)
        {
            sockopt = serv->tcp_defer_accept;
            setsockopt(sock, IPPROTO_TCP, TCP_DEFER_ACCEPT, &sockopt, sizeof(sockopt));
        }
#endif
        listen_host->sock = sock;
        //将server socket也放置到connection_list中
        serv->connection_list[sock].fd = sock;
        serv->connection_list[sock].addr.sin_port = listen_host->port;
        //save listen_host object
        serv->connection_list[sock].object = listen_host;
    }
    //将最后一个fd作为minfd和maxfd
    if (sock >= 0)
    {
        swServer_set_minfd(serv, sock);
        swServer_set_maxfd(serv, sock);
    }

源码解释：
遍历listen_list列表，对所有TCP类型的socket，调用swSocket_listen函数启动监听，并将socket添加到reactor中。如果设置了TCP_DEFER_ACCEPT属性，则设置相应的socket option。最后，将监听的socket加入swServer的connection_list,并设置swServer的minfd和maxfd为最后一个待监听的server socket。

swServer_addTimer

该函数用于在swServer中添加一个定时器。函数原型如下：

// Server.h 443h
int swServer_addTimer(swServer *serv, int interval);

函数核心源码：

    // Server.c 263-293h
    if (serv->onTimer == NULL)