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

网络编程-select(二)

一、I/O多路复用

1、为什么要多路复用

之前开启多线程能实时接收数据,并且也不是一次性连接服务。但毕竟是一请求一连接,每有一个客户端向服务端发起请求,就会创建一个线程,当请求达到上千上万,就会创建上千上万的线程,虽然线程所占资源很少,但也架不住数量多,会给系统内核资源调度增加负担<不利于高并发>

2、解决单个线程处理多个I/O操作问题

系统提供3种策略来解决,分别是select,poll,epoll

二、select机制

1、将多个线程请求看成是一个集合

2、关注集合中的fd哪些可读,可写,可出错

3、逐个管理集合中的fd,如果有数据到来就进行处理,否则就继续阻塞等待。

4、遍历集合中的fd,判断是否可读,可读就接收。

三、具体实操

在之前的阻塞I/O中,我们是阻塞在accept上,现在我们阻塞在select上。
所以在之前的代码中,将accept及以下代码进行更换。

1、创建集合,清空集合,设置集合

fd_set rfds, rset;        //集合
FD_ZERO(&rfds);     //对集合进行清空
FD_SET(socketfd, &rfds);           //对集合进行设置,将客户端fd添加至集合中

2、阻塞在select上

select函数原型:

int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);
/*
nfds: 集合最大边界值 + 1,因为从0开始
readfds: 关注这部分(如4,5,6)fd是否可读
writefds: 关注这部分(如7,8,9)fd是否可写
exceptfds:关注这部分(如7,8,9)fd是否出错
timeout: 超时时间,NULL表示永久阻塞,非NULL表示等待时间,单位为秒
return value: 返回的是所关注的共达标多少个,如可读3个,可写2个,可出错1个,共计6个
*/
int maxfd = socketfd;             //对集合遍历的最大值,集合也有边界,从0开始
while(true){rset = rfds;                    //复制一份集合,防止在select中被修改int nready = select(maxfd + 1, &rset, NULL, NULL, NULL);    //等待IO就绪if(nready < 0){                //出错处理cout << "select error:" << strerror(errno) << endl;continue;}else if (nready == 0){                //超时处理cout << "timeout\n";continue;}else{//accept操作,此处省略}//recv操作,此处省略
}

3、管理逐个IO,accept操作

if(FD_ISSET(socketfd, &rset)){          //如果有数据到来,则进行接收处理====acceptint clientfd = accept(socketfd, (struct sockaddr *)&clientaddr, &len);cout<<"clientfd:"<<clientfd<<endl;       //获取到客户端的连接描述符FD_SET(clientfd, &rfds);            //将新的连接加入到集合中if(clientfd > maxfd){               //更新遍历的边界,回收旧的连接,更新边界值maxfd = clientfd;}
}

4、recv操作,判断是否可读,接收数据

for(int i = socketfd + 1; i <= maxfd; i++){ if(FD_ISSET(i, &rset)){                 //判断IO是否可读char buffer[1024] = {0};int count = recv(i, buffer, 1024, 0);if(count == 0){close(i);FD_CLR(i, &rfds);continue;}cout << "buffer:" << buffer << endl;//返回信息count = send(i, buffer, count, 0);}
}

在这里插入图片描述

5、小结:

一个线程多路I/O,阻塞在select上,当有客户端连接时,select返回,再进行accept操作。
select主要用到

fd_set          //集合
FD_SET          //设置集合,将fd加入到集合中
FD_CLR          //清除集合,将fd从集合中移除
FD_ISSET        //判断IO是否可读
FD_ZERO         //初始化为空集合
select          //阻塞等待IO就绪

相比于之前的网络I/O,避免了多线程的开销, select解决了单个线程处理多个I/O的问题。
但是,select还是有缺陷的。select,每次调用都需要把fd_set集合,从用户空间拷贝到内核空间,随着fd越来越大,拷贝的开销比较大。
maxfd,遍历到最大的fd。

6、扩展问题:

1、fd_set究竟是什么?

#define FD_SETSIZE 1024  // 假设文件描述符集合的最大大小为1024typedef struct {unsigned long fds_bits[FD_SETSIZE / (8 * sizeof(unsigned long))];
} fd_set;

可见fd_set本质是一个位图,每个fd对应一个bit位。
2、集合大小是多少,能修改吗?
集合大小可以通过宏定义修改,但是不建议修改。

相关文章:

  • 组态王|组态王中如何添加西门子1200设备
  • 【QGIS二次开发】地图编辑-04
  • Python数据可视化 - Pyecharts绘图示例
  • 【Linux网络】五种IO模型与阻塞IO
  • 【MYSQL】笔记
  • Go 后端中双 token 的实现模板
  • 几种基于比较的排序
  • 建一个结合双向长短期记忆网络(BiLSTM)和条件随机场(CRF)的模型
  • 【java多线程】线程间通信-利用wait和notify轮流按序打印奇数和偶数
  • 什么是着色器 Shader
  • 正则表达式与文本处理的艺术
  • WPS多级标题编号以及样式控制
  • k6学习k6学习k6学习k6学习k6学习k6学习
  • 【Android】从Choreographer到UI渲染(二)
  • Linux虚拟文件系统(1)
  • Spark,数据提取和保存
  • 数组随机重排与维度转换算法
  • 深入解析Python中的Vector2d类:从基础实现到特殊方法的应用
  • ngx_http_random_index_module 模块概述
  • LoadBarWorks:一款赛博风加载动画生成器的构建旅程
  • 从良渚到三星堆:一江水串起了5000年的文明对话
  • 茅台总经理到访五粮液:面对白酒行业周期性调整,需要团结一心的合力
  • 新任重庆市垫江县委副书记刘振已任县政府党组书记
  • 高新波任西安电子科技大学校长
  • 铁路端午假期运输火车票今日开售,12306提升应对超大规模并发访问需求能力
  • 牛市早报|中方调整对美加征关税措施,五部门约谈外卖平台企业