多进程侦听同一端口

叁歲伎倆 2022-09-30 09:44 196阅读 0赞

转自：http://blog.csdn.net/cwj649956781/article/details/21533341

一、端口侦听  
我们知道，系统中的互联网端口地址是系统级唯一的，在默认情况下，IPV4和IPV6的同一个协议的套接口也不能再同一个端口侦听，而套接口编程的五元组就是<IP,port,peerip,peerport,inet proto>，其中没有进程区分，所以一个系统的套接口对于同一个网络地址来说是唯一的。但是有时候为了实现负载平衡，可能希望有多个进程来侦听同一个套接口，从而并发执行某个任务，此时就希望多个相同的进程(相同的可执行文件)来对同一个套接口进行侦听，从而完成负载分流和平衡。  
当然，多线程也是一种实现方法，但是缺点就是需要实现用户态编码，不对可执行程序透明，用户态的代码需要自己调用pthread\_create来创建多个线程，这样属于一种硬编码的方式，有其资源共享的优点，但是会增加维护的复杂度。而一个程序同时执行多份的话，由于代码段共享的原因，系统同样不会有太大的内存开销，并且可以方便的由用户态决定启动多少个任务而不依赖代码实现。  
二、fastcgi starter实现  
通产来说，如果让同一个进程依次派生执行，那么这个多进程侦听同一个套接口是一定无法实现的，因为在bind系统调用会返回端口被占用错误，所以此时就需要由一个父进程来完成这个同一个的bind+listen动作，这时候把一个套接口已经培养到可以执行accept系统调用来获得连接请求的时候，这个fd相当于已经被培育成熟，所以此时根据需要个数派生服务进程，这样子进程就可以在照约定的文件描述符上进行accept接收外部连接请求。或者任务fastcgi派生的都是“官二代”，当这些子进程启动起来之后，它就可以直接从一个文件描述符上进行accept来接见各种连接请求，并且每个子进程都有这种接收机会。  
这个流程无论从实现和原理上来讲都不是很复杂，但是比较有创意。大家经常说“文件是unix的精髓”，但是能够把它用到这种地步还真是不容易，同样的套接口，同样的文件描述符，就是可以做到多进程侦听同一个端口的实现。这一点和busybox的可执行文件“多路复用”一样，是一种化腐朽为神奇，或者至少是“化平凡为神奇”的实现方法。而两者也的确是依靠这两个比较有创意的思路，实现了两种非常有用的机制，busybox在[嵌入式][Link 1]中几乎是根文件系统的基础，而fastcgi则是网络服务器中的快速响应流行模型。  
httpd-2.4.2\\support\\fcgistarter.c中相关代码：

rv = apr\_sockaddr\_info\_get(&skaddr, interface, APR\_UNSPEC, port, 0, pool);  
    if (rv) \{  
        exit\_error(rv, "apr\_sockaddr\_info\_get");  
    \}

rv = apr\_socket\_create(&skt, skaddr->family, SOCK\_STREAM, APR\_PROTO\_TCP, pool);  
    if (rv) \{  
        exit\_error(rv, "apr\_socket\_create");  
    \}

rv = apr\_socket\_bind(skt, skaddr);  
    if (rv) \{  
        exit\_error(rv, "apr\_socket\_bind");  
    \}

rv = apr\_socket\_listen(skt, 1024);  
    if (rv) \{  
        exit\_error(rv, "apr\_socket\_listen");  
    \}  
 while (--num\_to\_start >= 0) \{完成套接口侦听之后循环创建子进程。  
        rv = apr\_proc\_fork(&proc, pool);  
……            apr\_os\_file\_t oft = 0;注意这个文件描述符，被fcgi派生的子进程就是通过在这个文件描述符上直接执行accept系统调用来完成服务请求的，这个文件描述符在fastcgi.h中定义为\#define FCGI\_LISTENSOCK\_FILENO 0，数值同样为零。  
            apr\_os\_sock\_t oskt;

三、多进程竞争连接请求  
内核实现部分其实并不重要，也没什么好说的，只是比较好奇，就大致看一下相关实现。  
1、等待队列头创建  
最原始的等待队列在sock\_alloc--->>>  
static struct inode \*sock\_alloc\_inode(struct super\_block \*sb)  
\{  
    init\_waitqueue\_head(&ei->socket.wait);  
\}  
中实现，这里其实没有什么初始化，就是初始化了一个自旋锁，并且初始化为可获取状态，它并没有初始化方法成员。  
然后在\_\_sock\_create--->>inet\_create--->>>sock\_init\_data  
        sk->sk\_sleep    =    &sock->wait;  
这里将sk结构中的等待队列头指向socket中的wait成员，而这个sk\_sleep将会是accept的等待队列头地址。  
2、accept阻塞  
sys\_accept---->>>inet\_accept--->>inet\_csk\_accept---->>>inet\_csk\_wait\_for\_connect--->>prepare\_to\_wait\_exclusive(sk->sk\_sleep, &wait,TASK\_INTERRUPTIBLE)  
wait->flags |= WQ\_FLAG\_EXCLUSIVE;  
    spin\_lock\_irqsave(&q->lock, flags);  
    if (list\_empty(&wait->task\_list))  
        \_\_add\_wait\_queue\_tail(q, wait);  
    /\*  
在加入等待队列之后，通过timeo = schedule\_timeout(timeo);让出调度权。  
这里比较特殊的是这里的唤醒是互斥的，也就是那个 WQ\_FLAG\_EXCLUSIVE标志，这个标志会在唤醒函数中使用，当遇到这个标志并且唤醒互斥进程个数为1(默认情况)时只唤醒一个进程，其中的prepare\_to\_wait\_exclusiv的wait是通过下面宏创建的  
DEFINE\_WAIT(wait);  
3、连接到来时唤醒  
tcp\_v4\_do\_rcv--->>>tcp\_child\_process  
        /\* Wakeup parent, send SIGIO \*/  
        if (state == TCP\_SYN\_RECV && child->sk\_state != state)  
            parent->sk\_data\_ready(parent, 0);  
inet\_create--->>>sock\_init\_data

sk->sk\_state\_change    =    sock\_def\_wakeup;  
    sk->sk\_data\_ready    =    sock\_def\_readable;  
    sk->sk\_write\_space    =    sock\_def\_write\_space;  
    sk->sk\_error\_report    =    sock\_def\_error\_report;  
    sk->sk\_destruct        =    sock\_def\_destruct;  
也就是执行的sk\_data\_ready即为sock\_def\_readable函数，在该函数中，其执行操作为  
static void sock\_def\_readable(struct sock \*sk, int len)  
\{  
    read\_lock(&sk->sk\_callback\_lock);  
    if (sk->sk\_sleep && waitqueue\_active(sk->sk\_sleep))  
        wake\_up\_interruptible(sk->sk\_sleep);  
    sk\_wake\_async(sk,1,POLL\_IN);  
    read\_unlock(&sk->sk\_callback\_lock);  
\}  
\#define wake\_up\_interruptible(x)    \_\_wake\_up(x, TASK\_INTERRUPTIBLE, 1, NULL)  
可以看到，通过sk->sk\_sleep唤醒了正在accept的接收套接口，并且其中\_\_wake\_up的唤醒互斥任务个数为1，所以只会唤醒一个进程，这次连接的到来对其它任务透明。

[Link 1]: http://lib.csdn.net/base/embeddeddevelopment