【网络编程】IO多路复用


        IO多路复用是一种高效的I/O处理方式,它允许单个进程能够同时监视多个文件描述符(sockets、文件等),并在其中任何一个文件描述符准备好进行I/O操作时进行处理。它的核心在于使用少量的线程或进程来管理多个I/O操作,以提高系统的性能和响应速度

一、概念


1. IO多路复用的核心

        文件描述符集合:使用一个数据结构(如数组或位图)来管理多个文件描述符,通常使用select、poll或epoll等系统调用来监视这些文件描述符。

        阻塞与非阻塞:IO多路复用可以与阻塞和非阻塞I/O一起使用。非阻塞I/O允许程序立即返回,而不必等待数据准备好。

        事件驱动:当一个或多个文件描述符准备好进行读取或写入操作时,IO多路复用会触发相应的事件,从而通知应用程序执行相应的操作。

        单线程/多线程:IO多路复用可以由单个线程或多个线程来处理,取决于应用程序的需求。通常,单个线程可以管理多个文件描述符。

2. 四种IO模型

阻塞IO模型(Blocking IO)

        ① 阻塞IO模型是最简单的IO模型之一;
        ② 当程序执行IO操作时,它会被阻塞,直到IO操作完成为止;
        ③ 这种模型的效率较低,因为程序在等待IO完成期间无法执行其他任务。


非阻塞IO模型(Non-blocking IO)

        ① 非阻塞IO模型允许程序在等待IO完成时继续执行其他任务;
        ② 当程序请求IO操作时,它会立即返回,不会被阻塞;
        ③ 程序需要不断轮询以检查IO操作是否完成,这可能会导致CPU资源浪费。


多路复用IO模型(IO Multiplexing)

        ① 多路复用IO模型使用了一种机制,允许程序同时等待多个IO操作的完成;
        ② 通常使用select、poll或epoll等系统调用来实现;
        ③ 程序可以同时监视多个文件描述符,只有当其中某个文件描述符有IO事件发生时,程序才会被唤醒处理该事件。


异步IO模型(Asynchronous IO)

        ① 异步IO模型中,程序发起IO操作后立即返回,不会阻塞;
        ② 当IO操作完成时,系统会通知程序,然后程序处理完成的数据;
        ③ 这种模型的效率很高,因为程序不需要轮询,但实现复杂度较高。

        因此IO复用的核心基本思想为:先构造一张有关描述符的表,然后调用一个函数。当这些文件描述符中的一个或多个已准备好进行I/O时函数才返回。函数返回时告诉进程哪些描述符已就绪,可以进行I/O操作。

3. IO复用的优点

  • 高效利用CPU:相较于传统的多线程/多进程模型,IO多路复用可以减少线程/进程的创建和切换开销,提高CPU的利用率。

  • 减少资源占用:减少了每个连接的资源消耗,因为不再需要为每个连接创建一个线程或进程。

  • 简化程序逻辑:IO多路复用可以简化程序的逻辑,使得代码更易于维护和理解。

二、代码实现(TCP服务器端为例)

1. 创建监听套接字socket

	// 创建套接字socketint ser_socket = socket(AF_INET, SOCK_STREAM, 0);if (ser_socket == -1){perror("socket");return -1;}int reuse = 1;//设置套接字属性,  SO_REUSEADDR 允许端口重用 if(setsockopt(ser_socket, SOL_SOCKET, SO_REUSEADDR, (void *)&reuse, sizeof(reuse))<0){perror("setsockopt error");return -1;}


2. 初始化套接字和服务器自己的IP地址结构体(包括端口号)

// 初始化地址结构体 // IP地址+PORT端口号struct sockaddr_in addr;addr.sin_family = AF_INET;   						//地址簇addr.sin_port = atoi(argv[1]);								//端口(一般以传参的传进来)// addr.sin_addr.s_addr = inet_addr("192.168.1.25");	//IP地址addr.sin_addr.s_addr = htonl(INADDR_ANY);			//用特殊的"0.0.0.0"这个IP来绑定本机IP地址


3. 绑定bind

// 绑定地址结构体bindint b = bind(ser_socket, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));if(b == -1){perror("bind");return -1;}printf("绑定成功\n");


4. 开启监听listen

int l = listen(ser_socket, 3);if (l == -1){perror("listen");return -1;}printf("监听成功\n");//ser_socket由 待链接套接字 变成 监听套接字


5. 创建文件描述符集合,并初始化

        这里呢设置了套接字超时,就是在规定的时间内如果没有客户端连接,则退出服务器。

//设置套接字接收超时struct timeval tv;tv.tv_sec = 5; //超时秒数tv.tv_usec = 0;setsockopt(ser_socket, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); // 等待连接acceptstruct sockaddr_in c_addr;		//用来存放客户端链接成功之后的IP加端口int addrlen = sizeof(c_addr);int new_socekt = accept(ser_socket, (struct sockaddr *)&c_addr, &addrlen);if (new_socekt == -1){printf("延时时间到了,服务器退出了\n");perror("accept");return -1;}// new_socekt 链接成功之后,用来通信的套接字printf("客户端【%s】【%u】连接成功\n", inet_ntoa(c_addr.sin_addr), c_addr.sin_port);//客户端的IP跟端口,IP是你客户端本身自带的,但是端口是系统随机分配的啊// 接收消息read/recvchar buf[1024];while(1){bzero(buf, sizeof(buf));read(new_socekt, buf, sizeof(buf));// recv(new_socekt, buf, sizeof(buf), 0);printf(" client %s\n", buf);}


6. 资源释放,关闭套接字

close(new_socekt);// shutdown(new_socekt, SHUT_RDWR);

三、使用场景


       1. 网络服务器: IO复用常用于网络服务器,特别是需要同时处理大量客户端连接的情况,例如Web服务器、聊天服务器和在线游戏服务器。

       2. 网络代理: 代理服务器需要同时监听多个客户端和服务器连接,以便在它们之间传递数据,这是IO复用的典型应用场景。

        3. 聊天应用: 实时聊天应用通常需要处理多个客户端的消息,IO复用可以用于同时监视多个客户端连接,以便实时传递消息。

        4. 文件传输应用: 文件传输服务器需要同时处理多个文件上传或下载请求,使用IO复用可以有效管理这些请求。

        更多C/C++语言、Linux系统、数据结构和ARM板实战相关文章,关注专栏:

   手撕C语言

            玩转linux

                    脚踢数据结构

                            系统、网络编程

                                     探索C++

                                             6818(ARM)开发板实战

📢写在最后

  • 今天的分享就到这啦~
  • 觉得博主写的还不错的烦劳 一键三连喔~
  • 🎉🎉🎉感谢关注🎉🎉🎉

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

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

相关文章

消息队列基本原理和选型对比

消息队列使用场景 消息队列中间件是分布式系统中重要的组件&#xff0c;主要解决应用耦合&#xff0c;异步消息&#xff0c;削峰填谷等问题。实现高性能、高可用、可伸缩和最终一致性架构。 解耦&#xff1a;多个服务监听、处理同一条消息&#xff0c;避免多次 rpc 调用。 异步…

c语言开篇---跟着视频学C语言

标识符 标识符必须声明定义&#xff0c;可以是变量、函数或其他实体。 Int是标识符吗&#xff1f; 不是&#xff0c;int是c语言关键词&#xff0c;不是随意命名的 C语言关键词如下&#xff1a; 常量 不需要被声明&#xff0c;不能赋值更改。 printf函数 printf是由print打印…

202328读书笔记|《杨绛传:岁月流转,我心依然》——我和谁都不争,和谁争我都不屑。我爱大自然,其次就是艺术。

202328读书笔记|《杨绛传&#xff1a;岁月流转&#xff0c;我心依然》——我和谁都不争&#xff0c;和谁争我都不屑。我爱大自然&#xff0c;其次就是艺术 《杨绛传&#xff1a;岁月流转&#xff0c;我心依然》作者王臣。关于杨绛女士自传的书很多&#xff0c;她和钱钟书的爱情…

CSS_文字渐变

/* 定义渐变背景样式 */ .gradient-text {background-image: linear-gradient(to right, #ff0000, #00ff00); /* 渐变色范围 */background-clip: text; /* 应用渐变背景到文本 */-webkit-background-clip: text; /* Safari 和 Chrome 的前缀 */color: transparent; /* 将文本颜…

SpringBoot通过自定义注解实现日志打印

目录 前言&#xff1a; 正文 一.Spring AOP 1.JDK动态代理 2.Cglib动态代理 使用AOP主要的应用场景&#xff1a; SpringBoot通过自定义注解实现日志打印 一.Maven依赖 二.ControllerMethodLog.class自定义注解 三.Spring AOP切面方法的执行顺序 四.ControllerMethodL…

进阶C语言-指针的进阶(上)

指针的进阶 &#x1f4d6;1.字符指针&#x1f4d6;2.指针数组&#x1f4d6;3.数组指针&#x1f388;3.1 数组指针的定义&#x1f388;3.2 &数组名VS数组名&#x1f388;3.3 数组指针的使用 &#x1f4d6;4.数组参数、指针参数&#x1f388;4.1一维数组传参&#x1f388;4.2…

怎么扫码听音频?音频在线生码的方法

现在很多小伙伴喜欢听书而不是自己看&#xff0c;那么当我们想分享一段听书音频时&#xff0c;有什么的方法能够更快更好地来让其他人获取内容呢&#xff1f;想要提高传播的效率&#xff0c;那么制作音频二维码&#xff08;音视频二维码制作-一键免费生成音视频二维码在线工具-…

uniapp点击事件在小程序中无法传参

这个问题很是神奇&#xff0c;第一次遇到。在h5中&#xff0c;点击事件可以正常传参&#xff0c;打包小程序后确失效了。 修改&#xff1a;for循环中的key&#xff0c;使用 index就好了

并发内存池(C++)

项目简介 这个项目是实现了一个高效的并发内存池。它的原型的goggle的一个开源项目tcmalloc&#xff0c;即thread-cache malloc&#xff08;线程缓存的malloc&#xff09;&#xff0c;实现了高效多线程的内存管理&#xff0c;可实现对系统提供的内存分配函数malloc和free的替代…

2023高教社杯数学建模C题思路代码 - 蔬菜类商品的自动定价与补货决策

# 1 赛题 在生鲜商超中&#xff0c;一般蔬菜类商品的保鲜期都比较短&#xff0c;且品相随销售时间的增加而变差&#xff0c; 大部分品种如当日未售出&#xff0c;隔日就无法再售。因此&#xff0c; 商超通常会根据各商品的历史销售和需 求情况每天进行补货。 由于商超销售的蔬菜…

Python Flask Web开发三:数据表的字段增加和删除

前言 在实际的开发中&#xff0c;数据表中的字段的增加和删除是很正常的操作&#xff0c;在运营的不断提需求下&#xff0c;这个修改的频率是很高的&#xff0c;那么在flask中如何进行字段的增加和删除呢&#xff1f;下面我来给大家讲讲 一、创建迁移脚本 使用数据库迁移工具…

Maven编译java及解决程序包org.apache.logging.log4j不存在问题

1、首先新建一个文件夹&#xff0c;比如hello Hello里新建pom.xml <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi…