#clude <stdlib.h>
#clude <stdio.h>
#clude <errno.h>
#clude <strg.h>
#clude <unistd.h>
#clude <sys/socket.h>
#clude <i/.h>
#clude <sys/types.h>
#clude <db.h>
#defe SERV_PORT 1113
#defe LISTENQ 32
#defe MAXLINE 1024
/连接处理函数/
void str_echo(t fd);
void
sig_chld(t signo)
{
pid_t pid;
t stat;
pid = wait(&stat);//获取子进程进程号
prtf("child %d termated\n", pid);
return;
}
t
ma(t argc, char argv[]){
t listenfd,connfd;
pid_t childpid;
socklen_t clilen;
struct sockaddr_ servaddr;
struct sockaddr_ cliaddr;
//struct sockaddr_ servaddr;
//struct sockaddr_ cliaddr;
if((listenfd = socket(AF_INET, SOCK_STREAM,0))==-1){
fprtf(stderr,"Socket error:%s\n\a",strerror(errno));
exit(1);
}
/ 服务器端填充 sockaddr结构/
bzero(&servaddr, sizeof(servaddr));
servaddr.s_family = AF_INET;
servaddr.s_addr.s_addr = htonl (INADDR_ANY);
servaddr.s_port = htons(SERV_PORT);
signal(SIGCHLD,sig_chld);//处理SIGCHLD信号
/ 捆绑listenfd描述符 /
if(bd(listenfd,(struct sockaddr)(&servaddr),sizeof(struct sockaddr))==-1){
fprtf(stderr,"Bd error:%s\n\a",strerror(errno));
exit(1);
}
/ 监听listenfd描述符/
if(listen(listenfd,5)==-1){
fprtf(stderr,"Listen error:%s\n\a",strerror(errno));
exit(1);
}
for ( ; ; ) {
clilen = sizeof(cliaddr);
/ 服务器阻塞,直到客户程序建立连接 /
if((connfd=aept(listenfd,(struct sockaddr)(&cliaddr),&clilen))<0){
/当一个子进程终止时，执行信号处理函数sig_chld，
而该函数返回时，aept系统调用可能返回一个EINTR错误，
有些内核会自动重启被中断的系统调用，为便于移植，将考虑对EINTR的处理/
if(errno==EINTR)
contue;
fprtf(stderr,"Aept error:%s\n\a",strerror(errno));
exit(1);
}
//有客户端建立了连接后
if ( (childpid = fork()) == 0) { /子进程/
close(listenfd); / 关闭监听套接字/
str_echo(connfd); /处理该客户端的请求/
exit (0);
}
close(connfd);/父进程关闭连接套接字，继续等待其他连接的到来/
}
}
void str_echo(t sockfd){
ssize_t n;
char buf[MAXLINE];
aga:
while ( (n = read(sockfd, buf, MAXLINE)) > 0)
write(sockfd, buf, n);
if (n < 0 && errno == EINTR)//被中断，重入
goto aga;
else if (n < 0){//出错
fprtf(stderr,"read error:%s\n\a",strerror(errno));
exit(1);
}
}