使用多进程实现TCP服务端的优势和注意事项

首先&＃xff0c;为什么要用多进程处理&＃xff0c;多进程的好处是可靠性高&＃xff0c;而且在处理大量数据的时候&＃xff0c;多进程的速度会比多线程快&＃xff0c;所有多进程还是要掌握的。

在一些实际项目中&＃xff0c;进程和线程要根据实际场景用。

但是多进程是不能共享进程空间的&＃xff0c;所以有很多变量都不能共享。除了fork&＃xff08;&＃xff09;之前的变量是可以共享的。

下面的代码基本逻辑就是&＃xff0c;用父进程来 accept&＃xff0c;检测有没有新的客户端要连入&＃xff0c;用子进程来接受客户端发来的信息

下面给出服务端的代码&＃xff1a;&＃xff08;有详细注释&＃xff09;

#include"myhead.h"char rbuf[50];
char wbuf[50];
char ipbuf[50];int main()
{signal(SIGCHLD,SIG_IGN);//把子进程的僵尸进程给init进程处理 struct sockaddr_in saddr;struct sockaddr_in caddr;int size,len,opt &＃61; 1;int sockfd,newfd;pid_t pid;int err;size &＃61; sizeof(struct sockaddr_in);len &＃61; sizeof(struct sockaddr);//初始化本地ip&＃xff0c;地址信息bzero(&saddr,size);saddr.sin_family &＃61; AF_INET;saddr.sin_port &＃61; htons(8888);saddr.sin_addr.s_addr &＃61; htonl(INADDR_ANY);//创建一个监听套接字sockfd &＃61; socket(AF_INET,SOCK_STREAM,0);if(sockfd<0){perror("failed socket");return -1;}//设置端口复用err &＃61; setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof opt);if(err<0){perror("setsockopt failed");return -1;}//绑定套接字和IP&＃xff0c;地址信息err &＃61; bind(sockfd,(struct sockaddr*)&saddr,len);if(err<0){perror("failed bind");return -1;}//开始监听listen(sockfd,10);//循环接收 客户端的连入while(1){//监测有没有新的客户端连入&＃xff0c;有的话&＃xff0c;返回新的套接字newfd &＃61; accept(sockfd,(struct sockaddr*)&caddr,&len);if(newfd<0){perror("accept failed");continue;}//有新的客户端连入&＃xff0c;则打印他的IP和端口inet_ntop(AF_INET,(void*)&caddr.sin_addr.s_addr,ipbuf,50);printf("the client:%s is in\n",ipbuf);//创建一个子进程来接受新客户端的信息pid &＃61; fork();if(pid<0) //fork失败{perror("failed fork()");return -1;}else if(pid &＃61;&＃61; 0) //子进程{ close(sockfd);//关闭从父进程进程来的监听套接字//因为在子进程用不到/*关闭不需要的套接字可节省系统资源&＃xff0c; 同时可避免父子进程共享这些套接字 可能带来的不可预计的后果 */  //这个子进程循环接收客户端信息while(1){err &＃61; recv(newfd,rbuf,50,0);if(err<0){perror("failed recv");}//若recv的返回&＃61;0&＃xff0c;表示客户端已经断开 else if(err &＃61;&＃61; 0){bzero(ipbuf,50);inet_ntop(AF_INET,(void*)&caddr.sin_addr.s_addr,ipbuf,50);printf("the client:%s is out\n",ipbuf);exit(0);close(newfd);}//读取客户端的信息else{inet_ntop(AF_INET,(void*)&caddr.sin_addr.s_addr,ipbuf,50);printf("ip:%s,port:%d\n",ipbuf,ntohs(caddr.sin_port));printf("%s\n",rbuf);bzero(rbuf,50);}}}else if(pid>0) //父进程&＃xff0c;用于继续监测有没有新的客户端连入{close(newfd);//关闭新客户端返回的套接字&＃xff0c;因为在//父进程中用不到continue;}}}