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

五种 IO 模式的简单介绍 -- 阻塞 IO，非阻塞 IO，信号驱动 IO，IO 多路复用，异步 IO

ops 2025/6/25 9:04:07

1. 同步阻塞 IO（Blocking IO）

2. 同步非阻塞 IO（Non-Blocking IO）

2.1 同屋非阻塞 IO 介绍

2.2 错误码介绍

2.3 非阻塞 IO demo 代码

3. 信号驱动 IO（Signal Driven IO，SIGIO）

4. IO 多路复用（IO Multiplexing）

5. 异步 IO（Asynchronous IO，AIO）

IO 的过程可以分为等待数据和拷贝数据两个阶段。

1. 同步阻塞 IO（Blocking IO）

同步阻塞 IO：进程发起 IO 操作后会被阻塞，知道 IO 操作完成才返回，期间无法处理其他任务。阻塞 IO 是最常见的 IO 模型。

如上图所示，进程调用 recvfrom 向内核发送读请求（读取文件、网络接收数据），内核等待数据就绪（数据从磁盘加载到内存、网络数据到达），数据就绪后，内核将数据拷贝到进程（用户）缓冲区，进程解除阻塞并处理数据。

#include <iostream>
#include <cstdio>
#include <unistd.h>
#include <fcntl.h>int main()
{char buffer[1024];while(true){std::cout << "请输入数据: ";fflush(stdout); // 立即将内核缓冲区的数据刷新到标准输出中ssize_t n = read(0, buffer, sizeof(buffer));if (n > 0){buffer[n - 1] = 0;std::cout << "读取的数据：" << buffer << std::endl;}elsebreak;}r

如上图，标准输入默认情况下是阻塞模式的，所以每次都会等待用户进行输入之后才进行数据处理。

2. 同步非阻塞 IO（Non-Blocking IO）

2.1 同屋非阻塞 IO 介绍

同步非阻塞 IO：进程发起 IO 请求后立即返回，通过轮询方式查询 IO 操作是否完成，不会阻塞进程。

非阻塞 IO 往往需要轮询的方式反复尝试读写文件描述符，这对 CPU 来说是较大的浪费。

如上图，进程调用 recvfrom 发起读请求，第一次内核中无数据就绪，则返回，然后通过循环调用 recvfrom 发起第二次读请求，内核中依旧无数据就绪，继续返回，知道有数据就绪后，内核将数据拷贝到进程缓冲区中，并进行处理。

fcntl 函数：fcntl（file control）是 Linux 系统中用于操作文件描述符属性的核心系统调用，提供了对文件、套接字、管道等 IO 资源的高级控制能力。

#include <unistd.h>
#include <fcntl.h>int fcntl(int fd, int cmd, ...);

fd：目标文件描述符。

cmd：操作命令，决定 fcntl 的具体功能。

...：可变参数，根据 cmd 不同可能为整数、指针或结构体。

返回值：成功时根据 cmd 返回不同值，失败返回 -1，并设置 errno。

下列介绍部分 cmd 参数：

（1）F_GETFL：返回 fd 的状态标志（如 O_EDONLY、O_NONBLOCK）。

（2）F_SETFL：修改 fd 状态标志，常用标志包括：
O_NONBLOCK：设置为非阻塞 IO。

O_APPEND：设置为追加模式。

O_DIRECT：绕过内核缓冲区，直接 IO。

O_ASYNC：启动信号驱动 IO 通知。

2.2 错误码介绍

read 函数用于从文件描述符中读取数据，返回读取的字节数，错误时返回 -1，并设置 errno（错误码）。

下列介绍部分调用 read 函数时发生错误设置的错误码。

（1）EAGAIN：表示操作无法立即完成，需要重试（通常用于文件描述符设置为非阻塞时）。

（2）EWOULDBLOCK：与 EAGAIN 本质相同，是其别名，不同系统可能定义不同，在 POSXI 标准中，EWOULDBLOCK 常用于套接字操作。

（3）EINTR：表示阻塞的系统调用被信号（如 SIGINT、SIGTERM）中断，导致调用未完成而返回错误。

2.3 非阻塞 IO demo 代码

#include <iostream>
#include <cstdio>
#include <unistd.h>
#include <fcntl.h>void SetNonBlock(int fd)
{int fl = fcntl(fd, F_GETFL);if (fl < 0){perror("fcntl");return;}fcntl(fd, F_SETFL, fl | O_NONBLOCK);
}int main()
{SetNonBlock(0);  // 设置标准输入为非阻塞char buffer[1024];while(true){ssize_t n = read(0, buffer, sizeof(buffer));if (n > 0){buffer[n - 1] = 0;std::cout << buffer << std::endl;sleep(1);}else if (n < 0) // 底层数据没有准备好，数据读取不算出错{// 1. 读取出错或者数据没有就绪if (errno == EAGAIN || errno == EWOULDBLOCK)    // 错误码{std::cout << "数据没有就绪... " << std::endl;sleep(1);// 其他业务// ....continue;}else if (errno == EINTR)continue;else    // 其他错误break;}elsebreak;}return 0;
}