您的位置:首页 > 理论基础 > 计算机网络

TCP并发服务器(一)——每个客户一个子进程

2014-07-23 22:33 330 查看
TCP并发服务器(一)——每个客户一个子进程

1.说明

这是最传统的并发服务器,对于每一个客户请求fork一个子进程。问题在于每次fork一个子进程比较耗费时间,下面会讲预创建进程。

程序代码基于UNP的库。

程序在使用进程的模式下是最慢的。

2.代码

#include "unp.h"

int main(int argc, char *argv[])
{
int listenfd;
socklen_t addrlen;
if (argc = 2) {
listenfd = Tcp_listen(NULL, argv[1], &addrlen);
} else if (argc ==3) {
listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
} else {
err_quit("Usage: a.out [ <host> ] <port#>");
}
struct sockaddr *cliaddr = (struct sockaddr*)Malloc(addrlen);

void sig_chld(int), sig_int(int), web_child(int);
Signal(SIGCHLD, sig_chld);
Signal(SIGINT, sig_int);

for ( ; ;) {
socklen_t clilen = addrlen;
DPRINTF("Wait for a connection\n");
int connfd = accept(listenfd, cliaddr, &clilen);    //clilen用于值-结果参数,可能会改变,所以每次重新赋值,所以此处不能使用addrlen
DPRINTF("Accept a connection\n");
if (connfd < 0) {
if (errno == EINTR) {
continue;
} else {
err_sys("accept() error");
}
}

pid_t childpid = Fork();
if (childpid == 0) {        //child process
DPRINTF("Fork a child process\n");
Close(listenfd);        //close listening socket
web_child(connfd);        //process request
exit(0);
}
Close(connfd);                //parent closes connected socket
} //end for(;;)

return 0;
}

void sig_int(int)
{
DPRINTF("sig_int()\n");
void pr_cpu_time(void);
pr_cpu_time();
exit(0);
}

void sig_chld(int)
{
static int cnt = 0;
pid_t pid;
int stat;
//param1: 想要等待的PID;-1: 等待第一个终止的子进程
//param2: 子进程的终止状态(整数)
//param3: 附加选项;WNOHANG:没有子进程终止时,不阻塞
while ((pid = waitpid(-1, &stat, WNOHANG)) > 0) {    //成功:返回进程ID > 0, 出错:0或-1
DPRINTF("Waitpid for %d child process\n", ++cnt);
;
}

return;
}


  
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: