TCP高并发服务器简介(select、poll、epoll实现与区别)

select、poll、epoll三者的实现:

select实现TCP高并发服务器的流程:

  • 一、创建套接字(socket函数):
  • 二、填充服务器的网络信息结构体:
  • 三、套接字和服务器的网络信息结构体进行绑定(bind函数):
  • 四、套接字设置成被动监听(listen函数):
  • 五、创建要监听的文件描述符集合:
  • 使用select函数后,会将没有就绪的文件描述符在集合中去除,所以需要创建两个文件描述符集合,一个是母本read_fds,类似于常量,保持不变,而另一个作为副本read_fds_t,类似于变量,可以改变;
	fd_set read_fds;FD_ZERO(&read_fds);fd_set read_fds_t;FD_ZERO(&read_fds_t);
  • 六、把创建的套接字添加到要监视的集合中:
	FD_SET(sockfd,&read_fds);int fd_max = 0;fd_max = fd_max > sockfd ? fd_max : sockfd;
  • 七、设置系统时间结构体变量,用来指定超时的时间:
	struct timeval tm_out;
  • 八、等待文件描述符中的事件是否就绪,成功则返回就绪的文件描述符的个数(select函数):
  • select函数:
	#include <sys/select.h>int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);/*参数:nfds:		要监视的最大文件描述符+1readfds:	要监视的读文件描述符集合 不关心可以传NULLwritefds:	要监视的写文件描述符集合 不关心可以传NULLexceptfds:	要监视的异常文件描述符集合 不关心可以传NULLtimeout:	超时时间 如果设置成NULL 会一直阻塞 直到有文件描述符就绪返回值:成功 就绪的文件描述符的个数超时 0失败 -1 重置错误码*///struct timeval  可以指定超时时间//如果结构体的两个成员都为0 表示非阻塞struct timeval {long    tv_sec;         //秒 long    tv_usec;       //微秒};void FD_CLR(int fd, fd_set *set);	//将文件描述符在集合中删除int  FD_ISSET(int fd, fd_set *set);	//判断文件描述符是否还在集合中// 返回0 表示不在了 非0 表示在void FD_SET(int fd, fd_set *set);	//向集合中添加一个文件描述符void FD_ZERO(fd_set *set);			//清空集合
		if(-1 == (ret = select(fd_max + 1,&read_fds_t,NULL,NULL,&tm_out))){perror("select error");exit(-1);}else if(0 == ret){puts("timeout!!!!!");putchar('\n');continue;}
  • 九、遍历文件描述符集合,判断哪些文件描述符已经准备就绪:
		for(int i = 3; i < fd_max + 1 && 0 != ret; i++){...}
  • 十、判断文件描述符是否还在集合中,并且接收来自客户端的数据(recv函数)和给客户端发送应答消息(send函数):
            if(FD_ISSET(i,&read_fds_t)){//说明有新的客户端连接服务器if(i == sockfd){   if(-1 == (accept_fd = accept(sockfd,NULL,NULL))){perror("accept error");exit(-1);}printf("客户端[%d]连接到服务器\n",accept_fd);//将新连接的客户端的套接字添加到要监视的集合中FD_SET(accept_fd,&read_fds);fd_max = fd_max > accept_fd ? fd_max : accept_fd;}else //之前连接的客户端在向服务器发送信息{memset(buf,0,sizeof(buf));if(-1 == (nbytes = recv(i,buf,sizeof(buf),0))){perror("recv error");exit(-1);}else if(0 == nbytes){printf("客户端[%d]已断开连接\n",i);//将已断开连接客户端的套接字在文件描述符集合中剔除FD_CLR(i,&read_fds);//关闭套接字close(i);continue;}if(!strncmp(buf,"quit",4)){printf("客户端[%d]已退出\n",i);//将已断开连接客户端的套接字在文件描述符集合中剔除FD_CLR(i,&read_fds);//关闭套接字close(i);continue;}printf("客户端[%d]发来信息[%s]\n",i,buf);//组装应答消息strcat(buf,"----------k");//给客户端发送应答消息if(-1 == send(i,buf,sizeof(buf),0)){perror("send error");exit(-1);}}ret--; //减少遍历次数}
  • 十一、关闭套接字(close函数):

poll实现TCP高并发服务器的流程:

  • 一、创建套接字(socket函数):
  • 二、填充服务器的网络信息结构体:
  • 三、套接字和服务器的网络信息结构体进行绑定(bind函数):
  • 四、套接字设置成被动监听(listen函数):
  • 五、创建要监听的文件描述符集合并清空文件描述符集合:
	//创建要监听的文件描述符集合struct pollfd new_fds[2048] = {0};//清空文件描述符集合for(int i = 0; i < 2048; ++i){new_fds[i].fd = -1;}
  • 六、把创建的套接字添加到要监视的集合中:
	FD_SET(sockfd,&read_fds);int fd_max = 0;fd_max = fd_max > sockfd ? fd_max : sockfd;
  • 七、套接字添加到要监视的集合中,并且设置要监听的事件:
	//套接字添加到要监视的集合中new_fds[0].fd = sockfd;//设置要监听的事件new_fds[0].events |= POLLIN;
  • 八、记录文件描述符集合中最大的文件描述符,并且设置超时的时间:
	//记录文件描述符集合中最大的文件描述符int fd_max = 0;fd_max = fd_max > sockfd ? fd_max : sockfd;//设置超时的时间int tm_out = 10000;
  • 九、等待文件描述符中的事件是否就绪,成功则返回就绪的文件描述符的个数(poll函数):
  • poll实现TCP中型并发服务器select实现TCP小型并发服务器区别就是无需每次重置集合,并且可以设置要监视的最大文件描述符的个数,而select至多监视1024个文件描述符
  • poll函数:
	#include <poll.h>int poll(struct pollfd *fds, nfds_t nfds, int timeout);/*参数:fds:要监视的文件描述符的集合指向自定义的结构体数据nfds:fds中已经使用的项目的个数timeout:超时时间单位是毫秒  设置成10000 表示10s-1	永久阻塞0	非阻塞返回值:0		超时-1		出错 重置错误码正数	成功 返回的就绪的文件描述符的个数*/struct pollfd {int   fd;         /* 文件描述符 设置成-1 内核就不再监视这一位了*/short events;     /* 要监视的事件 */short revents;    /* 返回的事件 */};/*要监视的事件是用位运算或起来的要监视的事件放在events字段,而实际就绪的事件在revents字段返回POLLIN	读事件POLLOUT	写时间POLLERR	异常事件*/
		if(-1 == (ret = poll(new_fds,fd_max,tm_out))){perror("poll error");exit(-1);}else if(0 == ret){puts("timeout!!!!!");putchar('\n');continue;}
  • 十、遍历文件描述符集合,判断哪些文件描述符已经准备就绪:
		for(k = 0; k <= fd_max && ret != 0; ++k){   ...}
  • 十一、找到实际就绪的事件的文件描述符,并且接收来自客户端的数据(recv函数)和给客户端发送应答消息(send函数):
           //找到实际就绪的事件的文件描述符if(0 != (new_fds[k].revents & POLLIN)){//说明有新的客户端连接服务器if(new_fds[k].fd == sockfd){if(-1 == (accept_fd = accept(sockfd,NULL,NULL))){perror("accept error");exit(-1);}printf("客户端[%d]连接到服务器\n",accept_fd);//将新连接的客户端的套接字添加到要监视的集合中//遍历文件描述符集合,给新的文件描述符找一个位置for(j = 0; j < 2048; j++){if(-1 == new_fds[j].fd){new_fds[j].fd = accept_fd;new_fds[j].events |= POLLIN;fd_max = fd_max > accept_fd ? fd_max : accept_fd;break;}}if(2048 == j){//此时集合容量满了close(accept_fd);}}else //之前连接的客户端在向服务器发送信息{memset(buf,0,sizeof(buf));if(-1 == (nbytes = recv(new_fds[k].fd,buf,sizeof(buf),0))){perror("recv error");exit(-1);}else if(0 == nbytes){printf("客户端[%d]已断开连接\n",new_fds[k].fd);//将已断开连接客户端的套接字在文件描述符集合中剔除close(new_fds[k].fd);new_fds[k].fd = -1;continue;}if(!strncmp(buf,"quit",4)){printf("客户端[%d]已退出\n",new_fds[k].fd);//将已断开连接客户端的套接字在文件描述符集合中剔除close(new_fds[k].fd);new_fds[k].fd = -1;continue;}printf("客户端[%d]发来信息[%s]\n",new_fds[k].fd,buf);//组装应答消息strcat(buf,"----------k");//给客户端发送应答消息if(-1 == send(new_fds[k].fd,buf,sizeof(buf),0)){perror("send error");exit(-1);}}ret--; //减少遍历次数}
  • 十二、关闭套接字(close函数):

epoll实现TCP高并发服务器的流程:

  • 一、创建套接字(socket函数):
  • 通信域选择IPV4网络协议、套接字类型选择流式
	int sock_fd = socket(AF_INET,SOCK_STREAM,0); //通信域选择IPV4、套接字类型选择流式
  • 二、填充服务器和客户机的网络信息结构体:
  • 1.分别定义服务器网络信息结构体变量serveraddr和客户机网络信息结构体变量clientaddr
  • 2.分别求出服务器和客户机的网络信息结构体变量的内存空间大小,以作备用;
  • 3.网络信息结构体清0
  • 4.使用IPV4网络协议AF_INET
  • 5.在终端预留服务器端主机的IP地址inet_addr(argv[1])
  • 6.在终端预留服务器端网络字节序的端口号htons(atoi(argv[2]))
	struct sockaddr_in serveraddr; //定义服务器网络信息结构体变量struct sockaddr_in clientaddr;socklen_t serveraddr_len = sizeof(serveraddr);//求出服务器结构体变量的内存空间大小socklen_t clientaddr_len = sizeof(clientaddr);//求出客户机结构体变量的内存空间大小memset(&serveraddr,0,serveraddr_len); //服务器结构体清零memset(&clientaddr,0,clientaddr_len);//客户机结构体清零serveraddr.sin_family = AF_INET;  //使用IPV4网络协议serveraddr.sin_addr.s_addr = inet_addr(argv[1]);  //IP地址serveraddr.sin_port = htons(atoi(argv[2]));//网络字节序的端口号
  • 三、设置允许端口复用(setsockopt函数):
  • setsockopt函数:
  • 功能:设置套接字属性;
#include <sys/types.h>#include <sys/socket.h>int setsockopt(int sockfd, int level, int optname,const void *optval, socklen_t optlen);	/*参数:sockfd:套接字level:	选项的级别套接字API级别		SOL_SOCKETTCP级别			IPPROTO_TCPIP级别			IPPROTO_IPoptname:选项的名字套接字API级别SO_BROADCAST	是否允许发送广播SO_RCVBUF		接收缓冲区的大小SO_SNDBUF		发送缓冲区的大小SO_RCVTIMEO		接收超时时间参数使用的是 struct timeval 结构体如果超时了 函数调用会立即返回-1并将错误码置成 EAGAINSO_SNDTIMEO			发送超时时间SO_REUSEADDR		端口复用TCP级别TCP_NODELAY		使能/禁用Nagle算法IP级别IP_ADD_MEMBERSHIP	设置加入多播组optval:	选项的值没有特殊说明时 使用的都是int类型optlen:optval的大小返回值:成功 	0失败 	-1 	重置错误码*/
  • 特别注意:
  • 使用setsockopt设置允许端口复用时,其在代码的位置在填充网络信息结构体和bind之间;
	int reuse = 1;if(-1 == (setsockopt(sock_fd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)))){perror("setsockopt error");exit(-1);}
  • 四、套接字和服务器的网络信息结构体进行绑定(bind函数):

  • 五、套接字设置成被动监听(listen函数):

  • 六、创建红黑树(epoll_create函数):

	#include <sys/epoll.h>int epoll_create(int size);/*功能:创建epoll/创建epoll实例的描述符参数:size:参数已经被忽略了,只需要填写大于0的值即可返回值:epoll_create 调用成功时会返回一个非负整数epfd,表示新创建的 epoll 实例的文件描述符,如果调用失败则返回 -1,并设置 errno 变量以指示具体错误原因*/
	int epfd = epoll_create(1);if(-1 == epfd){perror("epoll_create error");exit(-1);}
  • 七、定义事件结构体变量和存放就绪事件描述符的数组:
  • 事件结构体epoll_event用于描述一个文件描述符上的事件;
			typedef union epoll_data {void        *ptr;int          fd;  uint32_t     u32;uint64_t     u64;} epoll_data_t;   struct epoll_event {uint32_t     events;      //EPOLLIN 读 / EPOLLOUT 写epoll_data_t data;        //存放用户的数据};    
struct epoll_event event;struct epoll_event events[N];
  • 八、将关心的文件描述符加入到红黑树(epoll_ctl函数):
  • 功能:epoll的控制操作或者用于向 epoll 实例中添加、修改、删除事件;
  • epoll_ctl函数:
	int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);/*参数:epfd:epoll的文件描述符op:控制方式EPOLL_CTL_ADD:添加EPOLL_CTL_MOD:修改EPOLL_CTL_DEL:删除fd:被操作的文件描述符event:(事件)结构体指针返回值:    成功返回0,失败返回-1 置位错误码*/
	//添加要检测事件的描述符event.events = EPOLLIN;event.data.fd = sock_fd;//将关心的文件描述符加入到红黑树if(-1 == (epoll_ctl(epfd,EPOLL_CTL_ADD,sock_fd,&event))){perror("epoll_ctl error");exit(-1);}
  • 九、等待文件描述符中的事件是否就绪,成功则返回就绪的文件描述符的个数(epoll_wait函数):
  • epoll_wait函数:
	int epoll_wait(int epfd, struct epoll_event *events,int maxevents, int timeout);/*参数:epfd:epoll的文件描述符events:准备好的事件的结构体地址maxevents:返回的最大的文件描述符的个数timeout:超时>0 :毫秒级别的超时时间=0 :立即返回=-1:不关心超时时间返回值:成功返回准备好的文件描述符的个数返回0代表超时时间到了失败返回-1置位错误码*/
		if(-1 == (ret = epoll_wait(epfd,events,N,-1))){perror("epoll_wait error");exit(-1);}	
  • 十、遍历就绪的文件描述符集,判断哪些文件描述符已经准备就绪:
		for(int i = 0; i < ret; ++i){...}
  • 十一、找到实际就绪的事件的文件描述符,并且接收来自客户端的数据(recv函数)和给客户端发送应答消息(send函数):
			if(events[i].data.fd == sock_fd){//获取连接成功后新的客户端new_fd = accept(sock_fd,(struct sockaddr *)&clientaddr,&clientaddr_len);if(-1 == new_fd){perror("accept error");exit(-1);}printf("文件描述符[%d]客户端[%s:%d]连接到了服务器\n",new_fd,inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port));//添加要检测的文件描述符event.events = EPOLLIN;event.data.fd = new_fd;if(-1 == (epoll_ctl(epfd,EPOLL_CTL_ADD,new_fd,&event))){perror("epoll_ctl error");exit(-1);}printf("文件描述符[%d]成功挂载在红黑树上\n",new_fd);}else{memset(buf,0,sizeof(buf));int old_fd = events[i].data.fd;if(-1 == (nbytes = recv(old_fd,buf,sizeof(buf),0))){perror("recv error");exit(-1);}else if(0 == nbytes){printf("文件描述符[%d]客户端断开了服务器\n",old_fd);//关闭对应的文件描述符close(old_fd);//剔除挂在树上对应的文件描述符epoll_ctl(epfd,EPOLL_CTL_DEL,old_fd,&event);}if(!strncmp(buf,"quit",4)){printf("文件描述符[%d]客户端退出了服务器\n",old_fd);//关闭对应的文件描述符close(old_fd);//剔除挂在树上对应的文件描述符epoll_ctl(epfd,EPOLL_CTL_DEL,old_fd,&event);}printf("文件描述符[%d]客户端发来数据[%s]\n",old_fd,buf);//组装应答消息strcat(buf,"-----k");//给客户端发送应答消息send(old_fd,buf,sizeof(buf),0); 
  • 十二、关闭套接字(close函数):

select、poll、epoll三者的区别:

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/640162.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

大模型笔记【3】 gem5 运行模型框架LLama

一 LLama.cpp LLama.cpp 支持x86&#xff0c;arm&#xff0c;gpu的编译。 1. github 下载llama.cpp https://github.com/ggerganov/llama.cpp.git 2. gem5支持arm架构比较好&#xff0c;所以我们使用编译LLama.cpp。 以下是我对Makefile的修改 开始编译&#xff1a; make UNAME…

Kotlin协程的JVM实现源码分析(下)

协程 根据 是否保存切换 调用栈 &#xff0c;分为&#xff1a; 有栈协程&#xff08;stackful coroutine&#xff09;无栈协程&#xff08;stackless coroutine&#xff09; 在代码上的区别是&#xff1a;是否可在普通函数里调用&#xff0c;并暂停其执行。 Kotlin协程&…

【git分支管理策略】

文章目录 前言一、分支管理策略简介二、git基本操作三、git分支远程分支本地分支 四、gitflow分支管理策略分支定义gitflow分支管理策略评价 五、GITHUB FLOW分支管理策略分支使用流程创建分支&#xff08;Create a branch&#xff09;新增提交(add and commit)提出 Pull 请求&…

C++泛型编程-类模板的项目实战实现基础的Vector的编写

请设计一个数组模板类&#xff08; Vector &#xff09;&#xff0c;完成对 int 、 char 、 float 、 double 以 及任意的自定义类等类型元素进行管理。 需求 a. 实现构造函数 b. 实现拷贝构造函数 c. 实现 cout << 操作 d. 实现下标访问符 [] 的重载操作 …

CTF-PWN-堆-【chunk extend/overlapping-1】

文章目录 chunk extend/overlappingfastbin与topchunk相邻free时候不会合并unsortedbinchunk中与topchunk相邻的被free时会合并extend向后overlapping先修改header&#xff0c;再free&#xff0c;再malloc先free&#xff0c;再修改header&#xff0c;再malloc extend向前overla…

Filter简单了解

1、filter能干嘛 过滤器实际上就是对web资源进行拦截&#xff0c;做一些处理后交给下一个过滤器或者servlet处理&#xff0c;通常都是拦截request的&#xff0c;也可以对response进行拦截处理&#xff1b; 2、面试考点&#xff1a;filter能干嘛&#xff08;应用场景&#xff0…

多维时序 | Matlab实现CNN-GRU-Mutilhead-Attention卷积门控循环单元融合多头注意力机制多变量时间序列预测

多维时序 | Matlab实现CNN-GRU-Mutilhead-Attention卷积门控循环单元融合多头注意力机制多变量时间序列预测 目录 多维时序 | Matlab实现CNN-GRU-Mutilhead-Attention卷积门控循环单元融合多头注意力机制多变量时间序列预测效果一览基本介绍程序设计参考资料 效果一览 基本介绍…

退出微软账号,edge/必应退出账号

微软账号退出&#xff1a;搜的教程都是说改成本地帐号&#xff0c;但是我的已经是本地帐号&#xff0c;操作没用。 但是找到了退出edge/必应浏览器账号的方法&#xff0c;见下图。 参考链接&#xff1a;奶酪真好次个人动态-奶酪真好次动态记录-哔哩哔哩视频 (bilibili.com)

【Linux】基本指令收尾

文章目录 日期查找打包压缩系统信息Linux和Windows互传文件 日期 这篇是基本指令的收尾了&#xff0c;还有几个基本指令我们需要说一下 首先是Date&#xff0c;它是用来显示时间和日期 直接输入date的话显示是有点不好看的&#xff0c;所以我们可以根据自己的喜欢加上分隔符&…

使用 Vector 在 Kubernetes 中收集日志

多年来&#xff0c;我们一直在使用 Vector 在我们的 Kubernetes 平台中收集日志&#xff0c;并成功地将其应用于生产中以满足各种客户的需求&#xff0c;并且非常享受这种体验。因此&#xff0c;我想与更大的社区分享它&#xff0c;以便更多的 K8s 运营商可以看到潜力并考虑他们…

【 CSS 】基础1

“坚持就是胜利。” - 温斯顿丘吉尔 【 CSS 】基础 1 CSS 简介 CSS 是层叠样式表 ( Cascading Style Sheets ) 的简称.有时我们也会称之为 CSS 样式表或级联样式表。CSS 也是一种标记语言CSS 主要用于设置 HTML 页面中的文本内容&#xff08;字体、大小、对齐方式等&#xff…

Python使用gRPC入门,定义proto文件和收发消息

gRPC 一开始由 google 开发&#xff0c;是一款语言中立、平台中立、开源的远程过程调用(RPC)系统。 本文通过一个简单的 Hello World 例子来向您介绍 gRPC 。 Grpc官方文档地址&#xff1a;Quick start | Python | gRPC gRPC 是什么&#xff1f; gRPC 也是基于以下理念&#…

Python武器库开发-武器库篇之Quake360-API使用(四十七)

Python武器库开发-武器库篇之Quake360-API使用(四十七) Quake360是一款网络资产搜索引擎&#xff0c;旨在帮助用户快速定位和识别网络上的资产信息。它具有强大的搜索功能&#xff0c;可以搜索并展示各种类型的网络资产&#xff0c;包括域名、IP地址、子域名、端口信息等。同时…

Unity编程#region..#endregion以及面板提示语标签[Tooltip(““)]

C#中的#region..#endregion 在Unity中&#xff0c;#region和#endregion是用于代码折叠的预处理指令。它们并不是Unity特有的&#xff0c;而是C#语言本身提供的功能。 #region用于标记一段代码的开始&#xff0c;而#endregion用于标记一段代码的结束。在编辑器中&#xff0c;可…

橡木桶陈酿:木材选择、烤制程度与陈酿时间

在威士忌的酿造过程中&#xff0c;橡木桶陈酿是一个至关重要的环节。橡木桶不仅为威士忌提供了特别的香气和风味&#xff0c;还赋予其丰富的颜色和味蕾。本文将深入探讨橡木桶陈酿的奥秘&#xff0c;特别是木材选择、烤制程度以及陈酿时间对威士忌风味的影响&#xff0c;以雷盛…

【Linux】解决普通用户无法进行sudo提权

当某个普通用户进行sudo指令提权的时候&#xff0c;可能存在无法操作的问题&#xff0c;如下图&#xff1a; 这个图中有一个细节&#xff0c;我们使用sudo进行提权的时候&#xff0c;用的可是zhangsan的密码&#xff0c;因此有人可能会有疑问&#xff0c;这不是有问题吗&#x…

安泰电子电压放大器的三个特性是指什么

电压放大器是一种主要用于将输入电压信号放大的电子器件。它的工作原理是通过增加电压信号的幅度&#xff0c;使得输出信号比输入信号有更大的电压差。电压放大器通常具有许多特性&#xff0c;其中三个主要特性包括增益、带宽和线性度。 增益是电压放大器最重要的特性之一。增益…

RabbitMQ-消息延迟

一、死信交换机 1、描述 一个队列接收到的消息有过期时间&#xff0c;消息过期之后&#xff0c;如果配置有死信队列&#xff0c;消息就会进去死信队列。 2、图解 3、过程 当生产者将消息发送到exchange1&#xff0c;然后交换机将消息路由到队列queue1&#xff0c;但是队列que…

JavaScript进阶:WebAPIs重点知识整理1

目录 1 DOM修改元素内容 2 DOM修改元素常见属性 3 修改元素样式属性 3.1 通过style修改元素样式 3.2 通过类名className修改元素样式 3.3 通过classList修改元素样式 4 操作表单元素属性 5 自定义属性 6 定时器 7 事件监听 7.1 点击事件 click 7.2 鼠mouseenter和移…

【Linux】权限 !

Linux 权限 Liunx Linux 权限1 什么是权限1.1 Linux用户1.2 切换用户 2 权限管理2.1 文件访问者的分类2.2 文件类型和访问权限2.3 文件权限的设置方法chmod 命令chown 命令chgrp 命令umask 命令file 指令 2.4 目录权限粘滞位 3 权限总结 1 什么是权限 关于Linux的权限问题&…