当前位置：首页 > news >正文

网络编程day4

news 2025/8/21 10:06:46

IP多路复用实现TCP服务器并发

#include<myhead.h>#define  SER_PORT  8888        //服务器端口号
#define SER_IP  "192.168.108.34"   //服务器IP地址 int main(int argc, const char *argv[])
{//1、创建一个用于连接的套接字文件描述符int sfd  = socket(AF_INET, SOCK_STREAM, 0);if(-1 == sfd){perror("socket  error");return -1;}printf("socket 成功 sfd = %d\n", sfd);          //3//设置套接字属性：允许端口号快速重用int reuse = 1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse))==-1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、给套接字绑定ip地址和端口号//2.1 封装地址信息结构体变量struct sockaddr_in sin;        //地址信息结构体变量sin.sin_family = AF_INET;      //通信域地址族sin.sin_port = htons(SER_PORT);   //端口号网络字节序sin.sin_addr.s_addr = inet_addr(SER_IP);  //ip地址网络字节序//2.2  绑定操作if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) ==-1){perror("bind  error");return -1;}printf("bind success\n");//3、将套接字启动监听if(listen(sfd, 128) == -1){perror("listen  error");return -1;}printf("listen success\n");//4、阻塞等等客户端的连接，如果有新客户端连接，//则创建一个用于通信的套接字struct sockaddr_in cin;            //用于接受客户端套接字信息socklen_t addrlen = sizeof(cin);   //用于接受客户端套接字的长度char  wbuf[128] = "";                 //用于服务器发送消息的容器//创建一个文件描述符容器，将可能产生阻塞任务的文件描述符放到里面//1、定义一个用于检测文件描述符的集合容器fd_set readsfds;//2、清空文件描述符数组中的内容FD_ZERO(&readsfds);//3、将需要检测的文件描述符放入到集合中FD_SET(0, &readsfds);           //将0号文件描述符放入FD_SET(sfd, &readsfds);         //讲sfd放入集合中//定义一个临时备用容器fd_set tempfds;int new_fd = -1;            //用于接收客户端请求后创建用于通信套接字int maxfd = sfd;            //用于存储文件描述符集合中最大的文件描述符//定义一个存储客户端地址信息的结构体数组struct sockaddr_in cin_arr[1024];while(1){//将文件描述符集合中的内容复制给临时容器tempfds = readsfds;//4、使用select一个阻塞函数检测文件描述符集合中是否有事件产生//有任意一个文件描述符的任务到达后，就会解除该阻塞int res = select(maxfd+1, &tempfds, NULL,NULL, NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){printf("time out\n");return -1;}//判断是否为有新的客户端发来连接请求if(FD_ISSET(sfd, &tempfds)){new_fd = accept(sfd, (struct sockaddr*)&cin, &addrlen);if(-1 == new_fd){perror("accept error");return -1;}printf("[%s:%d]发来连接，new_fd = %d\n", inet_ntoa(cin.sin_addr),\ntohs(cin.sin_port) ,new_fd);cin_arr[new_fd] = cin;      //将下标为newfd的结构体数组值赋值//将新的用于通信的套接字文件描述符加入到文件描述符集合中FD_SET(new_fd, &readsfds);//更新maxfdif(new_fd > maxfd){maxfd = new_fd;}}//判断是否为服务器终端输入if(FD_ISSET(0, &tempfds)){scanf("%s", wbuf);printf("触发终端输入事件：%s\n", wbuf);//讲消息发送给所有的客户端for(int i=4; i<=maxfd; i++){send(i, wbuf, strlen(wbuf), 0);}}//判断是否为客户端套接字发来的消息//由于客户端可能有多个，所以需要遍历完成for(int i=4; i<=maxfd; i++){//没有触发事件的文件描述符，直接结束if(!FD_ISSET(i, &tempfds)){continue;}//从套接字中读取消息char rbuf[128] = "";          //存放接受消息的容器//int res = read(new_fd, rbuf, sizeof(rbuf)-1);int res = recv(i, rbuf, sizeof(rbuf)-1, 0);if(res == 0){printf("客户端已下线\n");close(i);//将i文件描述符从集合中删除FD_CLR(i, &readsfds);//更新最值？for(int j=maxfd; j>=0; j--){if(FD_ISSET(j,&readsfds)){maxfd = j;break;}}break;}if(res == -1){perror("read error");close(i);close(sfd);return -1;}//如果程序执行至此，表示数据成功读取下来，病放入rbuf中printf("[%s:%d] : %s\n", inet_ntoa(cin_arr[i].sin_addr), ntohs(cin_arr[i].sin_port), rbuf);//给当前消息加个笑脸还回去strcat(rbuf, "*_*");//向套接字中写入消息//write(new_fd, rbuf, strlen(rbuf));send(i, rbuf, strlen(rbuf), 0);printf("发送成功\n");}}//6、关闭监听套接字close(sfd);return 0;
}