2024/03/19(网络编程·day5)

一、思维导图

二、selec函数实现TCP并发服务器

#include<myhead.h>#define SER_PORT 8888 	//服务器端口号
#define SER_IP "192.168.117.116" 	//服务器IP
int main(int argc, const char *argv[])
{//1、创建一个套接字int sfd = -1;sfd = socket(AF_INET,SOCK_STREAM,0);//参数1:表示创建的是网络通信的套接字//参数2:表示使用的是TCP通信协议//参数3:参数2指定了协议，参数3填0即可if(sfd == -1){perror("socket error");return -1;}printf("%d success sfd = %d\n",__LINE__,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("%d bind success\n",__LINE__);//3、将套接字设置成被监听状态if(listen(sfd,128) == -1){perror("listen error");return -1;}//4、阻塞等待客户端的连接请求int newfd = -1;//定义结构体变量接受客户端地址信息结构体struct sockaddr_in cin;//接收客户端信息结构体socklen_t addrlen = sizeof(cin);//接收客户端结构体大小char sbuf[128] = ""; //服务器输入数据内容//11、定义一个文件描述符集合fd_set readfds,tempfds;//22、将集合清空FD_ZERO(&readfds);//33、将要被检测的文件描述符放入集合FD_SET(0,&readfds);FD_SET(sfd,&readfds);int maxfd = sfd; //记录当前容器中的最大文件描述符struct sockaddr_in cin_arr[1024]; //存储客户端信息结构体while(1){//将readfds备份tempfds = readfds;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;}//当程序执行到此处说明集合中有事件产生，此时集合中只剩下本次触发事件的描述符for(int i=0;i<=maxfd;i++){//如果不是触发事件的文件描述符,直接跳过if(!FD_ISSET(i,&tempfds)){continue;}//程序执行至此,表示当前i文件描述符触发了事件//判断sfd是否触发事件if(i == sfd){if((newfd = accept(sfd,(struct sockaddr*)&cin,&addrlen)) == -1){perror("accept error");return -1;}printf("[%s %d]:发来连接请求\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));//将客户端地址信息结构体放入容器中cin_arr[newfd] = cin;//将newfd放入readfds容器中参与检测FD_SET(newfd,&readfds);//可能要更新的maxfdif(newfd > maxfd){maxfd = newfd;}}//判断0号文件描述符是否触发事件else if(0 == i){fgets(sbuf,sizeof(sbuf),stdin); //终端输入sbuf[strlen(sbuf)-1] = 0;printf("触发了键盘输入事件:%s\n",sbuf);//将消息发送给所有客户端for(int i = 4;i<= maxfd;i++){send(i,sbuf,sizeof(sbuf),0);}printf("发送成功\n");}else{//说明某个客户端发来消息了，遍历所有客户端，判断是哪个发来的消息//5、收发数据char rbuf[128] = "";//接收客户端发送的信息//将容器清空bzero(rbuf,sizeof(rbuf));//memset(rbuf,0,sizeof(rbuf));//从套接字中读取数据int res = recv(i,rbuf,sizeof(rbuf)-1,0);if(res == 0){			printf("客户端已下线\n");//关闭与客户端通信的套接字close(i);//将当前文件描述符移除容器FD_CLR(i,&readfds);//可能要更新maxfdfor(int k=maxfd;k>=sfd;k--){if(FD_ISSET(k,&readfds)){maxfd = k;break;}}continue;}printf("[%s  %d]:%s\n",inet_ntoa(cin_arr[i].sin_addr),ntohs(cin_arr[i].sin_port),rbuf);//加个收到再回回去strcat(rbuf," <Got it>!");send(i,rbuf,strlen(rbuf),0);printf("回复成功\n");}}}//6、关闭服务器close(sfd);return 0;
}

三、poll函数实现TCP客户端

#include<myhead.h>#define SER_PORT 8888 	//服务器端口号
#define SER_IP "192.168.117.116" 	//服务器IP
#define CLI_PORT 9999 	//客户端端口号
#define CLI_IP "192.168.117.116" 	//客户端IPint main(int argc, const char *argv[])
{//1、创建一个套接字int cfd = -1;cfd = socket(AF_INET,SOCK_STREAM,0);//参数1:表示创建的是网络通信的套接字//参数2:表示使用的是TCP通信协议//参数3:参数2指定了协议，参数3填0即可if(cfd == -1){perror("socket error");return -1;}printf("%d success cfd = %d\n",__LINE__,cfd);  //3//设置端口号快速重用int reuse = 1;if(setsockopt(cfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)) == -1){perror("setsockopt error");return -1;}printf("端口号快速重用成功\n");//2、绑定IP和端口号//2.1填充客户端信息结构体struct sockaddr_in cin;cin.sin_family = AF_INET; 	//地址族cin.sin_port = htons(CLI_PORT); 	//端口号cin.sin_addr.s_addr = inet_addr(CLI_IP); //IP地址//2.2绑定if(bind(cfd,(struct sockaddr *)&cin,sizeof(cin))==-1){perror("bind error");return -1;}printf("bind success\n");//3、连接服务器//3.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地址//3.2、连接服务器if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin)) ==-1){perror("connect error");return -1;}printf("连接成功!\n");//使用poll完成0号文件描述符和cfd文件描述符的多路复用//11、准备文件描述符容器struct pollfd pfds[2];pfds[0].fd = 0; //文件描述符pfds[0].events = POLLIN; //检测读事件pfds[1].fd = cfd; //文件描述符pfds[1].events = POLLIN; //检测读事件//4、收发数据char wbuf[128] = "";while(1){int res = poll(pfds,2,-1); //阻塞检测集合中是否有事件发生if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}//程序执行至此，说明检测的文件描述符集合中有事件发生//判断是否为0号文件描述符产生的事件if(pfds[0].revents == POLLIN){fgets(wbuf,sizeof(wbuf),stdin); //终端读取wbuf[strlen(wbuf)-1] = '\0'; //将换行换成'\0'//判断输入的字符串if(strcmp(wbuf,"quit") == 0){break;}//将数据发送给服务器send(cfd,wbuf,strlen(wbuf),0);}//判断是否为cfd文件描述符中产生了事件if(pfds[1].revents == POLLIN){//将字符数组清空bzero(wbuf,sizeof(wbuf));recv(cfd,wbuf,sizeof(wbuf)-1,0);printf("收到的服务器消息为:%s\n",wbuf);}}//5、关闭套接字close(cfd);return 0;
}

四、select函数实现的TCP并发服务器连接poll函数实现的TCP客户端

五、模拟面试