1多進程并發服務器
使用多進程并發服務器時要考慮以下幾點：
A.父最大文件描述個數（父進程中需要close關閉accept返回的新文件描述符）
B.系統內創建進程個數（和內存大小相關）
C.進程創建過多是否降低整體服務性能（進程調度）
2.案例說明
server.c,代碼如下：
|
#include <stdio.h> #include <string.h> #include <netinet/in.h> #include <arpa/inet.h> #include <signal.h> #include <sys/wait.h> #include <sys/types.h> #include <arpa/inet.h> #include <ctype.h> #include <unistd.h> #include "wrap.h"
#define MAXLINE 80 #define SERV_PORT 8000
void do_sigchild(int num) { waitpid(0,NULL,WNOHANG); }
int main(void) { struct sockaddr_in servaddr,cliaddr; socklen_t cliaddr_len; int listenfd,connfd; char buf[MAXLINE]; //INET_ADDRSTRLEN是ip地址的最大長度，是系統定義的一個宏 char str[INET_ADDRSTRLEN]; int i,n; pid_t pid;
struct sigaction newact; newact.sa_handler = do_sigchild; sigemptyset(&newact.sa_mask); newact.sa_flags = 0; //發信號 sigaction(SIGCHLD,&newact,NULL);
//1.這里建立一個TCP的連接，因為是SOCK_STREAM的，表示的是TCP的 listenfd = Socket(AF_INET,SOCK_STREAM,0); //將seraddr內容清零 bzero(&servaddr,sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY); servaddr.sin_port = htons(SERV_PORT); //2.綁定ip地址和端口號 Bind(listenfd,(struct sockaddr *)&servaddr,sizeof(servaddr)); //監聽，最多的可以是20個 Listen(listenfd,20);
printf("Accepting connections... "); while(1) { cliaddr_len = sizeof(cliaddr_len); //connfd:這里才是后續進程需要用的文件描述符 //listenfd:已經不用里，可以被銷毀,這個程序是在子進程里面銷毀 connfd = Accept(listenfd,(struct sockaddr *)&cliaddr,&cliaddr_len);
pid = fork(); if(pid ==0) { if(pid == 0) { Close(listenfd); while(1) { n = Read(connfd,buf,MAXLINE); if(n == 0) { printf("the other side has been closed. "); break; } printf("received from %s at PORT %d ", inet_ntop(AF_INET,&cliaddr.sin_addr.s_addr,str,sizeof(str)), ntohs(cliaddr.sin_port));
for(i = 0; i< n; i++) { buf[i] = toupper(buf[i]); } Write(connfd,buf,n); } Close(connfd); return 0; } else if(pid > 0) { Close(connfd); } else { perr_exit("fork"); } } } } |
client.c
|
#include <stdio.h> #include <string.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include "wrap.h"
#define MAXLINE 80 #define SERV_PORT 8000
int main(int argc,char *argv[]) { struct sockaddr_in servaddr; char buf[MAXLINE]; int sockfd,n;
sockfd = Socket(AF_INET,SOCK_STREAM,0);
bzero(&servaddr,sizeof(servaddr)); servaddr.sin_family = AF_INET; inet_pton(AF_INET,"127.0.0.1",&servaddr.sin_addr.s_addr); servaddr.sin_port = htons(SERV_PORT);
Connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));
while(fgets(buf,MAXLINE,stdin) != NULL) { Write(sockfd,buf,strlen(buf)); n = Read(sockfd,buf,MAXLINE); if(n == 0) {
生活不易，碼農辛苦 下一篇 Linux特殊權限分析(第二版) 程序員人生，我編程，我富裕，記住wfuyu網，php教程，php學習，php手冊，CMS模版制作 聲明：本站大部分內容是作者原創，少部分收集于互聯網供大家一起學習，原版權很多不明，如有侵權請聯系本站，謝謝！
粵ICP備14040726號-1??
2015-2020 程序員人生 版權所有
|
