html做网站步骤,网站开发和设计如何合作,怎么用idea做响应式网站,惠州地区网站建设公司多进程并发服务器 多线程并发服务器 I/O多路转接服务器 epoll的工作模式
1 多进程并发服务器
在多进程并发服务器中#xff0c;若有用户请求到达#xff0c;服务器将会调用fork()函数#xff0c;创建一个子进程#xff0c;之后父进程将继续调用accept()#xff0c;而子进…多进程并发服务器 多线程并发服务器 I/O多路转接服务器 epoll的工作模式
1 多进程并发服务器
在多进程并发服务器中若有用户请求到达服务器将会调用fork()函数创建一个子进程之后父进程将继续调用accept()而子进程则去处理用户请求。
【案例1】构建多进程并发服务器。
服务器端接收多个客户端的数据并将接收到的数据转为大写写回客户端客户端向服务器发送数据并将服务器返回的数据打印到终端。
forkserver.c
#include arpa/inet.h
#include signal.h
#include sys/wait.h
#include sys/types.h
#include wrap.h
#define MAXLINE 80 //缓冲数组大小
#define SERV_PORT 8000 //端口号
//子进程回收函数
void doSigChild(int paraNum) {while (waitpid(0, NULL, WNOHANG) 0);
} //of doSigChild
int main() {struct sockaddr_in tempServAddr, tempCliAddr;socklen_t tempCliAddrLen;int tempListenFd, tempConnFd;char tempBuf[MAXLINE];char tempStr[INET_ADDRSTRLEN];int i, tempDataLen;pid_t tempPid;struct sigaction tempNewAct;tempNewAct.sa_handler doSigChild;sigaction(SIGCHLD, tempNewAct, NULL); //信号捕获与处理回收子进程tempListenFd Socket(AF_INET, SOCK_STREAM, 0);//设置服务器端口地址bzero(tempServAddr, sizeof(tempServAddr));tempServAddr.sin_family AF_INET;tempServAddr.sin_addr.s_addr htonl(INADDR_ANY);tempServAddr.sin_port htons(SERV_PORT);//使服务器与端口绑定Bind(tempListenFd, (struct sockaddr *)tempServAddr, sizeof(tempServAddr));Listen(tempListenFd, 20);printf(Accepting connections ...\n);while (1) {tempCliAddrLen sizeof(tempCliAddr);tempConnFd Accept(tempListenFd, (struct sockaddr *)tempCliAddr, tempCliAddrLen);tempPid fork(); //创建子进程if (tempPid 0) {//子进程处理客户端请求Close(tempListenFd);while (1) {tempDataLen Read(tempConnFd, tempBuf, MAXLINE);if (tempDataLen 0) {printf(the other side has been closed.\n);break;}//of if//打印客户端端口信息printf(received from %s at PORT %d\n,inet_ntop(AF_INET, tempCliAddr.sin_addr, tempStr, sizeof(tempStr)),ntohs(tempCliAddr.sin_port));for (i 0; i tempDataLen; i) {tempBuf[i] toupper(tempBuf[i]);} //of for iWrite(tempConnFd, tempBuf, tempDataLen);}//of whileClose(tempConnFd);return 0;} else if (tempPid 0) {Close(tempConnFd);} else {perr_exit(fork);}//of if}//of whileClose(tempListenFd);return 0;
}//of mainforkclient.c
#include stdio.h
#include string.h
#include unistd.h
#include netinet/in.h
#include wrap.h
#define MAXLINE 80 //缓冲数组大小
#define SERV_PORT 8000 //端口号
int main() {struct sockaddr_in tempServAddr;char tempBuf[MAXLINE];int tempSockFd, tempDataLen;tempSockFd Socket(AF_INET, SOCK_STREAM, 0);bzero(tempServAddr, sizeof(tempServAddr));tempServAddr.sin_family AF_INET;inet_pton(AF_INET, 127.0.0.1, tempServAddr.sin_addr);tempServAddr.sin_port htons(SERV_PORT);Connect(tempSockFd, (struct sockaddr *)tempServAddr, sizeof(tempServAddr));while (fgets(tempBuf, MAXLINE, stdin) ! NULL) {Write(tempSockFd, tempBuf, strlen(tempBuf));tempDataLen Read(tempSockFd, tempBuf, MAXLINE);if (tempDataLen 0) {printf(the other side has been closed.\n);} else {Write(STDOUT_FILENO, tempBuf, tempDataLen);}//of if}//of whileClose(tempSockFd);return 0;
} //of main
