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

Linux内核中的IO模型详解

news 2026/7/25 1:47:43

Linux内核中的IO模型详解

引言

IO模型是Linux内核中处理输入输出的核心机制，它决定了应用程序如何与外设、文件、网络等进行数据交互。不同的IO模型有不同的特点和适用场景，理解这些模型对于开发高性能网络应用和系统级程序至关重要。本文将深入探讨Linux内核中的各种IO模型，包括阻塞IO、非阻塞IO、IO多路复用、信号驱动IO和异步IO等。

IO模型的基本概念

1. 同步与异步

  • 同步IO：应用程序发出IO请求后，需要等待IO操作完成后才能继续执行
  • 异步IO：应用程序发出IO请求后，不需要等待IO操作完成，可以继续执行其他任务

2. 阻塞与非阻塞

  • 阻塞IO：当IO资源不可用时，进程会被挂起，直到资源可用
  • 非阻塞IO：当IO资源不可用时，立即返回错误，不会阻塞进程

3. IO操作的两个阶段

  • 数据准备阶段：等待IO资源就绪
  • 数据拷贝阶段：将数据从内核空间拷贝到用户空间

阻塞IO模型

1. 原理

阻塞IO是最简单的IO模型，进程调用recvfrom等系统调用后，如果数据未准备好，进程会被挂起，直到数据准备好并拷贝到用户空间后才返回。

2. 特点

  • 编程简单，易于理解
  • 进程在等待期间不消耗CPU资源
  • 适用于对延迟要求不高的场景
  • 每个连接需要一个独立的线程或进程处理

3. 示例代码

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8080 #define BUFFER_SIZE 1024 int main() { int server_fd, client_fd; struct sockaddr_in address, client_addr; socklen_t addrlen = sizeof(client_addr); char buffer[BUFFER_SIZE] = {0}; // 创建套接字 server_fd = socket(AF_INET, SOCK_STREAM, 0); // 绑定地址 address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(server_fd, (struct sockaddr *)&address, sizeof(address)); // 监听连接 listen(server_fd, 5); printf("Server listening on port %d\n", PORT); while (1) { // 阻塞等待客户端连接 client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &addrlen); // 阻塞读取数据 int n = read(client_fd, buffer, BUFFER_SIZE); if (n > 0) { printf("Received: %s\n", buffer); // 处理数据 memset(buffer, 0, BUFFER_SIZE); } close(client_fd); } close(server_fd); return 0; }

非阻塞IO模型

1. 原理

非阻塞IO通过设置O_NONBLOCK标志，使IO操作立即返回。当数据未准备好时，返回EAGAIN或EWOULDBLOCK错误，进程可以继续执行其他任务。

2. 特点

  • 进程不会被阻塞，可以处理多个连接
  • 需要轮询检查IO状态，消耗CPU资源
  • 编程复杂，需要处理各种错误情况
  • 适用于高并发场景

3. 示例代码

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <fcntl.h> #include <sys/socket.h> #include <netinet/in.h> #include <errno.h> #define PORT 8080 #define BUFFER_SIZE 1024 void set_nonblocking(int fd) { int flags = fcntl(fd, F_GETFL, 0); fcntl(fd, F_SETFL, flags | O_NONBLOCK); } int main() { int server_fd, client_fd; struct sockaddr_in address; char buffer[BUFFER_SIZE]; // 创建套接字 server_fd = socket(AF_INET, SOCK_STREAM, 0); // 设置为非阻塞 set_nonblocking(server_fd); // 绑定地址 address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(server_fd, (struct sockaddr *)&address, sizeof(address)); // 监听 listen(server_fd, 5); printf("Non-blocking server listening on port %d\n", PORT); while (1) { client_fd = accept(server_fd, NULL, NULL); if (client_fd >= 0) { set_nonblocking(client_fd); // 非阻塞读取 int n = read(client_fd, buffer, BUFFER_SIZE); if (n > 0) { printf("Received: %s\n", buffer); } else if (n < 0 && errno != EAGAIN && errno != EWOULDBLOCK) { perror("read error"); } close(client_fd); } } close(server_fd); return 0; }

IO多路复用模型

1. select

原理

select允许进程监控多个文件描述符，等待其中任何一个变为可读、可写或异常状态。

示例代码
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/time.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8080 #define FD_SIZE 1024 int main() { int server_fd, client_fd; struct sockaddr_in address; fd_set readfds, masterfds; int maxfd, activity; char buffer[1024]; server_fd = socket(AF_INET, SOCK_STREAM, 0); address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(server_fd, (struct sockaddr *)&address, sizeof(address)); listen(server_fd, 5); printf("Select server listening on port %d\n", PORT); FD_ZERO(&masterfds); FD_SET(server_fd, &masterfds); maxfd = server_fd; while (1) { readfds = masterfds; activity = select(maxfd + 1, &readfds, NULL, NULL, NULL); if (activity < 0) { perror("select error"); break; } if (FD_ISSET(server_fd, &readfds)) { struct sockaddr_in client_addr; socklen_t addrlen = sizeof(client_addr); client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &addrlen); FD_SET(client_fd, &masterfds); if (client_fd > maxfd) maxfd = client_fd; printf("New connection\n"); } for (int i = 0; i <= maxfd; i++) { if (FD_ISSET(i, &readfds) && i != server_fd) { int n = read(i, buffer, sizeof(buffer)); if (n <= 0) { close(i); FD_CLR(i, &masterfds); } else { buffer[n] = '\0'; printf("Received: %s\n", buffer); } } } } close(server_fd); return 0; }

2. poll

原理

poll与select类似，但使用pollfd结构体管理文件描述符，没有最大文件描述符数量的限制。

示例代码
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <poll.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8080 #define MAX_CLIENTS 1024 int main() { int server_fd, client_fd; struct sockaddr_in address; struct pollfd fds[MAX_CLIENTS]; int nfds = 1, i; char buffer[1024]; server_fd = socket(AF_INET, SOCK_STREAM, 0); address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(server_fd, (struct sockaddr *)&address, sizeof(address)); listen(server_fd, 5); printf("Poll server listening on port %d\n", PORT); fds[0].fd = server_fd; fds[0].events = POLLIN; while (1) { int ret = poll(fds, nfds, -1); if (ret < 0) { perror("poll error"); break; } if (fds[0].revents & POLLIN) { struct sockaddr_in client_addr; socklen_t addrlen = sizeof(client_addr); client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &addrlen); fds[nfds].fd = client_fd; fds[nfds].events = POLLIN; nfds++; } for (i = 1; i < nfds; i++) { if (fds[i].revents & POLLIN) { int n = read(fds[i].fd, buffer, sizeof(buffer)); if (n <= 0) { close(fds[i].fd); fds[i].fd = -1; } else { buffer[n] = '\0'; printf("Received: %s\n", buffer); } } } } close(server_fd); return 0; }

3. epoll

原理

epoll是Linux特有的IO多路复用机制，比select和poll更高效，适用于大规模并发连接。

示例代码
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/epoll.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8080 #define MAX_EVENTS 1024 int main() { int server_fd, client_fd, epfd; struct sockaddr_in address; struct epoll_event ev, events[MAX_EVENTS]; int nfds, i; char buffer[1024]; server_fd = socket(AF_INET, SOCK_STREAM, 0); address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(server_fd, (struct sockaddr *)&address, sizeof(address)); listen(server_fd, 5); printf("Epoll server listening on port %d\n", PORT); epfd = epoll_create1(0); ev.events = EPOLLIN; ev.data.fd = server_fd; epoll_ctl(epfd, EPOLL_CTL_ADD, server_fd, &ev); while (1) { nfds = epoll_wait(epfd, events, MAX_EVENTS, -1); for (i = 0; i < nfds; i++) { if (events[i].data.fd == server_fd) { struct sockaddr_in client_addr; socklen_t addrlen = sizeof(client_addr); client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &addrlen); ev.events = EPOLLIN; ev.data.fd = client_fd; epoll_ctl(epfd, EPOLL_CTL_ADD, client_fd, &ev); } else { int fd = events[i].data.fd; int n = read(fd, buffer, sizeof(buffer)); if (n <= 0) { close(fd); epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); } else { buffer[n] = '\0'; printf("Received: %s\n", buffer); } } } } close(server_fd); close(epfd); return 0; }

信号驱动IO模型

1. 原理

信号驱动IO允许进程在IO数据准备好时接收SIGIO信号，进程可以继续执行其他任务。

2. 特点

  • 进程不被阻塞，可以处理其他任务
  • 需要处理信号，编程复杂
  • 适用于低频IO操作

3. 示例代码

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <signal.h> #include <sys/socket.h> #include <netinet/in.h> #define PORT 8080 static int sock_fd; void sigio_handler(int signo) { char buffer[1024]; int n = read(sock_fd, buffer, sizeof(buffer)); if (n > 0) { buffer[n] = '\0'; printf("Received: %s\n", buffer); } } int main() { struct sockaddr_in address; sock_fd = socket(AF_INET, SOCK_STREAM, 0); // 设置信号处理函数 signal(SIGIO, sigio_handler); // 设置进程为SIGIO信号的属主 fcntl(sock_fd, F_SETOWN, getpid()); // 设置为异步模式 int flags = fcntl(sock_fd, F_GETFL); fcntl(sock_fd, F_SETFL, flags | O_ASYNC); address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); bind(sock_fd, (struct sockaddr *)&address, sizeof(address)); listen(sock_fd, 5); printf("Signal-driven IO server listening on port %d\n", PORT); while (1) { sleep(1); } close(sock_fd); return 0; }

异步IO模型

1. 原理

异步IO允许进程发出IO请求后立即返回，内核完成IO操作后通知进程。

2. Linux异步IO实现

Linux提供多种异步IO机制，包括POSIX AIO和io_uring。

3. io_uring示例

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <liburing.h> #define QUEUE_DEPTH 16 #define BUFFER_SIZE 1024 int main() { struct io_uring ring; struct io_uring_sqe *sqe; struct io_uring_cqe *cqe; char buffer[BUFFER_SIZE]; int fd; io_uring_queue_init(QUEUE_DEPTH, &ring, 0); // 打开文件 sqe = io_uring_get_sqe(&ring); io_uring_prep_openat(sqe, AT_FDCWD, "test.txt", O_RDONLY, 0); io_uring_submit(&ring); io_uring_wait_cqe(&ring, &cqe); fd = cqe->res; io_uring_cqe_seen(&ring, cqe); if (fd < 0) { perror("open"); return 1; } // 读取数据 sqe = io_uring_get_sqe(&ring); io_uring_prep_read(sqe, fd, buffer, BUFFER_SIZE, 0); io_uring_submit(&ring); io_uring_wait_cqe(&ring, &cqe); if (cqe->res > 0) { buffer[cqe->res] = '\0'; printf("Read: %s\n", buffer); } io_uring_cqe_seen(&ring, cqe); close(fd); io_uring_queue_exit(&ring); return 0; }

各IO模型的比较

性能对比

模型并发能力CPU占用延迟复杂度
阻塞IO低低高简单
非阻塞IO中高中中等
select高高中复杂
poll高高中复杂
epoll非常高低低中等
信号驱动IO高低中复杂
异步IO非常高低低复杂

适用场景

  • 阻塞IO：低并发、简单应用
  • 非阻塞IO：轮询场景、低并发
  • select/poll：中等并发（<1000连接）
  • epoll：高并发（>1000连接）
  • 异步IO：高性能计算、IO密集型应用

结论

Linux内核提供了多种IO模型，每种模型都有其特点和适用场景。epoll以其高效的事件处理机制成为高并发网络应用的首选，而异步IO模型则为高性能IO密集型应用提供了更好的性能。在实际开发中，我们需要根据应用场景和性能需求选择合适的IO模型，以达到最佳的系统性能和开发效率。

http://www.jsqmd.com/news/621053/

相关文章：

  • 实战指南：高效恢复ROG笔记本GameVisual色彩配置文件的最佳方案
  • 孤儿进程与僵尸进程（超详细解析 + 代码演示）
  • HJ172 小红的矩阵染色
  • 操作系统之系统调用
  • HTML5中SVG解析器原理及手动构建矢量字符串
  • Go语言中的数据库操作：从SQL到ORM
  • Photoshop CS6 分享
  • Fe₃O₄@Au-PEG-ICG-DOX，四氧化三铁@金-聚乙二醇/吲哚菁绿-多柔比星纳米复合材料，合成路线
  • TTP229电容触摸库详解：Arduino I²C驱动与边沿检测实践
  • uni-app怎么实现图片拖拽排序功能 uni-app手势识别与位置交换【代码】
  • 嵌入式Wi-Fi驱动重构：状态机+双缓冲提升WiFly模块可靠性
  • 考研数学高分突破：零基础速成模板与实战技巧全解析
  • 解锁Presto/Trino高级查询：从集合运算到多维分析与窗口函数实战
  • 安全彻底卸载Ubuntu20.04：从分区清理到EFI引导修复
  • 2026医院厨房设备选型指南：成都商用厨房制冷设备、成都商用厨房厨具工程、成都商用厨房厨具设备厂家、成都商用厨房定制设备厂家选择指南 - 优质品牌商家
  • WPF开发必备：CommunityToolkit.Mvvm中RelayCommand的5个实战技巧
  • CAN总线数据分析避坑指南：BLF解析时DBC信号匹配失败的3种常见原因与解决
  • 同城上门软件产品开发+定制化开发+私有化部署
  • 如何高效生成技术文章：方法与工具详解
  • 算法稳定性分析中的输入扰动建模的技术9
  • 【uniapp】地图路线轨迹，路线规划，兼容H5与APP端！
  • 从H∞到μ：结构奇异值（SSV）如何为不确定系统锻造鲁棒控制器
  • 面向企业的 AI Agent Harness Engineering 安全蓝图
  • Block Copy 的内存布局详解屎
  • NextTrace实战：5分钟搞定跨地域网络延迟排查（附地图可视化技巧）
  • PyQt6 vs PySide6：闭源项目选哪个？从许可证到实战避坑指南
  • R 4.5中DESeq2用于微生物组？：权威验证——3篇Nature Microbiology复现实验揭示其在低丰度菌群中的FDR失控风险
  • 代码随想录算法训练营第二十天 |235、二叉搜索树的最近巩固祖先 701、二叉搜索树中的插入操作 450、删除二叉搜索树中的节点
  • OpenClaw Windows 部署全程图文教程 | 免代码
  • 从架构到Agent能力的技术演进分析