使用多进程实现简单socket并发问题

概述&＃xff1a;
socket函数有时候需要支持多个客户端&＃xff0c;需要接受来自不同客户端的数据&＃xff0c;实现这种目的可以引用多线程&＃xff0c;多进程等方案。socket创建以及监听的步骤是
创建套接字、绑定IP和端口号、监听客户端请求&＃xff0c;数据交互。很明显要想实现并发支持多客户端访问&＃xff0c;需要在accept的时候做出改变。在socket链接套接字的时候会阻塞&＃xff08;不出错和没有信号干涉&＃xff09;&＃xff0c;说明正常情况下是每当有客户端接入才会停止阻塞&＃xff0c;如果用多进程思想的话&＃xff1a;
accept函数所在进程只是去“接待”客户端&＃xff0c;所以每当有客户端接入在accept接待之后使用fork创建一个子进程来真正为客户端服务。所以每个客户端会有不同的子进程去服务&＃xff08;读写数据&＃xff09;。所以很自然的就解决了socket并发问题。
但是还需要考虑服务终止时&＃xff0c;子进程的处理&＃xff0c;防止他出现僵尸进程&＃xff0c;方案比如用信号对SIGCHLD信号忽略就不会差生僵尸进程&＃xff0c;也可以使用一个“wait”线程一直while(1)循环调用wait函数&＃xff0c;来实现如果有子进程退出可以及时去获取状态&＃xff0c;不让他产生僵尸进程&＃xff0c;占用内存空间。

服务端demo&＃xff1a;

#include
#include
#include
#include
#include
#include
#include
#include
#include int main(int argc,char **argv)
{int s_fd;int c_fd;char read_buf[128];struct sockaddr_in s_addr;struct sockaddr_in c_addr; /*判断输入参数是否正确*/if(argc !&＃61; 3){printf("please IP : port:\n ");exit(-1);}/*清零所定义的结构体&＃xff0c;也可以使用bzero()*/memset(&s_addr,0,sizeof(struct sockaddr_in));memset(&c_addr,0,sizeof(struct sockaddr_in));/*socket的一般过程&＃xff0c;创建&＃xff0c;绑定>>>>>*/if((s_fd &＃61; socket(AF_INET,SOCK_STREAM,0)) &＃61;&＃61; -1){perror("socket");exit(0);}s_addr.sin_family &＃61; AF_INET;s_addr.sin_port &＃61; htons(atoi(argv[2]));inet_aton(argv[1],&s_addr.sin_addr);bind(s_fd,(struct sockaddr*)&s_addr,sizeof(struct sockaddr_in));listen(s_fd,10);signal(SIGCHLD,SIG_IGN);//使用信号对SIGCHLD信号忽略int len &＃61; sizeof(struct sockaddr_in);while(1){c_fd &＃61; accept(s_fd,(struct sockaddr*)&c_addr,&len);if(c_fd &＃61;&＃61; -1){perror("accept");exit(-1);}printf("IP:%s port:%d\n",inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port));
/*如果接入客户端&＃xff0c;创建子进程去为他服务*/if(fork() &＃61;&＃61; 0){close(s_fd);/*关闭套接字描述符&＃xff1a;进程创建时一般会拷贝父进程数据到子进程&＃xff0c;所以需要释放子进程用不到的东西&＃xff0c;比如文件描述符&＃xff0c;文件真正的关闭时需要所有打开此文件的进程都把文件关闭&＃xff0c;所以子进程关闭套接字描述符时不会影响父进程使用*/int ret &＃61; 0;while(1){ret &＃61; read(c_fd,read_buf,sizeof(read_buf));if(ret <&＃61; 0){perror("read");break;}printf("IP:%s port:%d\n",inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port));printf("read_buf &＃61; %s\n",read_buf);}exit(0);//防止子进程服务完毕客户端后出来执行下面代码 }
/*父进程关闭客户端套接字描述符*/close(c_fd);}close(s_fd);return 0;}


客户端demo如下&＃xff1a;
客户端比较容易就是去创建套接字不需要考虑别的&＃xff0c;只有一个进程再跑

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include int main(int argc,char** argv)
{int c_fd;char writebuf[128];struct sockaddr_in c_addr; memset(&c_addr,0,sizeof(struct sockaddr_in));if(argc !&＃61; 3){printf("param error!\n");exit(-1);}c_fd &＃61; socket(AF_INET,SOCK_STREAM,0);if(c_fd &＃61;&＃61; -1){perror("socket");exit(0);}c_addr.sin_family &＃61; AF_INET;c_addr.sin_port &＃61; htons(atoi(argv[2]));inet_aton(argv[1],&c_addr.sin_addr);if(connect(c_fd,(struct sockaddr*)&c_addr,sizeof(struct sockaddr)) &＃61;&＃61; -1){perror("connect");exit(-1);}printf("connect ...\n");while(1){memset(writebuf,0,sizeof(writebuf));//清空一下要写入数据的buffgets(writebuf,128,stdin);//从标准输入获取数据并且存到writebuf里面writebuf[strlen(writebuf) -1] &＃61; &＃39;\0&＃39;;//在终端输入时会输入回车&＃xff0c;所以把最后一个赋值为0&＃xff0c;就不会把回车发出去write(c_fd,writebuf,128);}return 0;
}

测试也没有问题&＃xff1a;

两台客户端运行

这样就简单实现了socket并发&＃xff08;使用进程&＃xff09;&＃xff0c;也可以使用线程更佳