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;
}
TCP并发服务器(一)——每个客户一个子进程,布布扣,bubuko.com
原文地址:http://www.cnblogs.com/hancm/p/3864179.html