对Linux开发者、运维工程师而言，I/O性能直接决定系统上限，但多数人只知“读写文件、网络传输”的表层操作，却不懂内核在底层默默做了多少优化，才实现数据的高效流转。我们日常操作的文件读写、网络请求，看似简单的“读”与“写”，背后是内核一套精密的I/O机制在支撑。
从缓冲区设计、数据拷贝优化，到零拷贝、异步I/O等核心技术，内核用层层优化规避了硬件与软件的性能瓶颈，减少不必要的资源消耗。它就像一个高效的“数据调度员”，协调用户空间与内核空间、内存与磁盘/网络设备，让数据传输既快速又稳定。接下来，我们将拆解内核I/O的核心架构，从底层原理出发，一步步搞懂内核如何突破性能限制，实现高效的数据读写，帮你跳出“只会用、不懂原理”的误区。
一、Linux内核 I/O 机制是什么？
在操作系统的复杂体系中，Linux 内核 I/O 机制宛如一座桥梁，连接着计算机的硬件设备与上层的应用程序 ，在整个系统的运行中扮演着极为关键的角色。从用户日常使用的文本编辑器保存文件，到服务器处理海量的网络请求，背后都离不开 Linux 内核 I/O 机制的高效运作。它负责管理和协调系统中所有的输入输出操作，确保数据能够准确、快速地在设备与内存之间传输，保障了系统的稳定运行和应用程序的流畅执行。接下来，让我们深入探索 Linux 内核 I/O 机制的奥秘。
在Linux中，I/O机制主要包括以下几个方面：
- 文件系统：Linux使用文件系统作为对外提供数据存储和访问的接口。文件系统可以是基于磁盘的，也可以是虚拟的，如procfs、sysfs等。通过文件系统，应用程序可以通过读写文件来进行输入输出操作。
- 文件描述符：在Linux中，每个打开的文件都会分配一个唯一的整数标识符，称为文件描述符（file descriptor）。应用程序可以使用文件描述符进行对文件的读写操作。
- 阻塞I/O和非阻塞I/O：在进行I/O操作时，可以选择阻塞或非阻塞模式。阻塞I/O会使调用进程在完成I/O操作之前被挂起，而非阻塞I/O则会立即返回，在数据未准备好时可能返回一个错误或特殊值。
- 异步I/O：异步I/O是指应用程序发起一个读/写请求后不需要等待其完成就可以继续执行其他任务。当请求完成时，内核会通知应用程序并将数据复制到指定缓冲区中。
- 多路复用：多路复用是一种同时监控多个输入源（例如套接字）是否有数据可读/可写的机制。常见的多路复用技术有select、poll和epoll。
二、深入剖析 Linux I/O 模型
在 Linux 系统中，I/O 模型的选择对于应用程序的性能和效率有着至关重要的影响。不同的 I/O 模型适用于不同的场景，了解它们的工作原理和特点，能够帮助我们在开发过程中做出更合适的选择。接下来，让我们深入剖析 Linux 中的五种常见 I/O 模型。
2.1阻塞 I/O（Blocking IO）
阻塞 I/O 是最基本、最常用的 I/O 模型。在这种模型下，当一个进程发起 I/O 操作时，它会在两个阶段都被阻塞，直到 I/O 操作完成才会返回 。以从网络套接字读取数据为例，当调用read函数时，首先会进入数据就绪阶段，此时如果数据还没有到达，进程就会被挂起，进入睡眠状态，让出 CPU 资源 。直到数据到达内核缓冲区，进程才会被唤醒，进入数据拷贝阶段，将数据从内核缓冲区拷贝到用户空间缓冲区，这个过程中进程依然是阻塞的 。只有当数据成功拷贝到用户空间缓冲区后，read函数才会返回，进程继续执行后续的操作 。
用一个简单的案例来表示就是：进程调用read函数后，就像一个人在餐厅点餐，点完后就坐在那里干等，直到服务员把菜端上来，期间什么也做不了 。只有菜上齐了，他才能开始享用美食，继续进行下一步的活动 。这种模型的工作流程简单直观，易于理解和实现 。
在 C 语言中，使用read系统调用就可以实现阻塞 I/O。下面是一个简单的代码示例：
#include <stdio.h>#include <unistd.h>#include <fcntl.h>#include <string.h>#define BUFFER_SIZE 1024intmain(){ int fd; char buffer[BUFFER_SIZE]; ssize_t bytes_read; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 读取文件内容 bytes_read = read(fd, buffer, BUFFER_SIZE); if (bytes_read == -1) { perror("read"); close(fd); return 1; } // 输出读取到的内容 buffer[bytes_read] = '\0'; printf("Read %zd bytes: %s\n", bytes_read, buffer); // 关闭文件 close(fd); return 0;}
在这个示例中，read函数会阻塞进程，直到从文件test.txt中读取到数据或者发生错误 。如果文件中没有数据可读，进程就会一直等待，直到有数据到达 。
阻塞 I/O 的优点非常明显，它的实现简单，不需要额外的处理逻辑，开发者可以专注于业务逻辑的实现 。同时，在 I/O 等待期间，进程会让出 CPU 资源，使得 CPU 可以被其他进程使用，提高了系统整体的 CPU 利用效率 。然而，阻塞 I/O 也存在一些缺点 。由于进程在 I/O 操作时会被阻塞，这就导致在高并发场景下，每个阻塞的进程都会占用一个线程或进程资源，系统需要创建大量的线程或进程来处理并发请求，这会消耗大量的系统资源，并且线程或进程的上下文切换也会带来额外的开销，从而降低了系统的响应性 。
基于这些特点，阻塞 I/O 适用于连接数较少且 I/O 操作频繁的场景 。比如一些简单的本地文件处理程序，或者对并发性能要求不高的小型服务器应用 。在这些场景中，阻塞 I/O 的简单性和稳定性能够很好地满足需求 。
2.2非阻塞 I/O（Non - blocking IO）
非阻塞 I/O 与阻塞 I/O 最大的区别在于，在数据就绪阶段，进程不会被阻塞 。当进程发起 I/O 操作时，如果数据还没有准备好，系统不会让进程进入睡眠状态，而是立即返回一个错误码，通常是EAGAIN或EWOULDBLOCK 。这就好比你去餐厅点外卖打包，点完菜后你不用坐在那里干等，可以在餐厅里自由活动 。但是你需要每隔一段时间就去问一下服务员 “我的菜好了吗？”，这就是所谓的轮询 。
在非阻塞 I/O 中，进程需要不断地轮询检查数据状态，直到数据就绪 。当数据就绪后，进入数据拷贝阶段，这个阶段和阻塞 I/O 一样，进程会被阻塞，直到数据从内核缓冲区拷贝到用户空间缓冲区 。用流程图来表示就是：进程调用非阻塞的read函数，若数据未就绪，立即返回EAGAIN错误 。进程可以继续执行其他任务，然后再次调用read函数进行轮询，直到数据就绪，再进行数据拷贝 。
在 Linux 中，可以通过fcntl函数来设置文件描述符为非阻塞模式 。下面是一个设置文件描述符为非阻塞模式并进行非阻塞读取的代码示例：
#include <stdio.h>#include <unistd.h>#include <fcntl.h>#include <string.h>#include <errno.h>#define BUFFER_SIZE 1024intmain(){ int fd; char buffer[BUFFER_SIZE]; ssize_t bytes_read; int flags; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 获取文件描述符的当前标志 flags = fcntl(fd, F_GETFL, 0); if (flags == -1) { perror("fcntl F_GETFL"); close(fd); return 1; } // 设置文件描述符为非阻塞模式 if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1) { perror("fcntl F_SETFL"); close(fd); return 1; } while (1) { // 非阻塞读取文件内容 bytes_read = read(fd, buffer, BUFFER_SIZE); if (bytes_read == -1) { if (errno == EAGAIN || errno == EWOULDBLOCK) { // 数据未就绪，继续轮询 printf("No data available, will try again...\n"); sleep(1); // 稍微休眠一下，避免CPU资源过度消耗 continue; } else { perror("read"); close(fd); return 1; } } else { // 数据读取成功 buffer[bytes_read] = '\0'; printf("Read %zd bytes: %s\n", bytes_read, buffer); break; } } // 关闭文件 close(fd); return 0;}
在这个示例中，首先通过fcntl函数获取文件描述符的当前标志，然后添加O_NONBLOCK标志将其设置为非阻塞模式 。在读取数据时，如果返回EAGAIN或EWOULDBLOCK错误，表示数据未就绪，程序会继续轮询，直到读取到数据 。
非阻塞 I/O 的优点在于它提高了程序的响应性，特别适用于需要实时交互的场景 。在高并发服务器程序中，使用非阻塞 I/O 可以高效地处理大量请求，因为它允许进程在等待 I/O 操作完成的同时，执行其他任务，避免了线程阻塞 。但是，非阻塞 I/O 也带来了一些问题 。由于需要不断地轮询检查数据状态，这会增加程序的复杂度，并且如果没有采用合适的等待机制（如select、poll或epoll），频繁的轮询会导致 CPU 资源被大量占用，降低了 CPU 的利用率 。
因此，非阻塞 I/O 适用于 I/O 操作频繁且数据就绪较快的场景 。比如一些实时监控系统，需要频繁地读取传感器数据，但每次读取的数据量不大且数据就绪速度较快，使用非阻塞 I/O 可以在不阻塞其他任务的情况下，及时获取传感器数据 。
2.3I/O 多路复用（IO Multiplexing）
I/O 多路复用是一种允许一个进程同时监控多个文件描述符的技术 。它的核心原理是通过一个进程来监控多个 I/O 事件，当其中任何一个文件描述符的数据就绪时，系统会通知进程进行处理 。这就像是一个餐厅经理可以同时照看多个桌子的客人，当某一桌客人有需求时，经理会及时响应 。
在 I/O 多路复用中，常用的系统调用有select、poll和epoll 。select通过设置文件描述符集合来监控多个文件描述符，它会遍历所有的文件描述符，检查是否有事件发生 。poll和select类似，也是通过轮询的方式检查文件描述符的状态，但它在处理大量文件描述符时性能比select更好 。epoll是select和poll的增强版本，它采用了事件驱动的方式，当有文件描述符就绪时，内核会通过回调函数将其加入就绪队列，进程只需要处理就绪队列中的文件描述符即可，大大提高了处理效率 。
具体的工作流程如下：进程首先将需要监控的文件描述符注册到select、poll或epoll中 。然后，这些系统调用会阻塞进程，直到有文件描述符就绪 。当有文件描述符就绪时，系统调用返回，进程可以通过检查返回的结果来确定哪些文件描述符就绪，然后对这些就绪的文件描述符进行相应的 I/O 操作 。
下面是使用select和epoll系统调用的代码示例：
// select示例#include <stdio.h>#include <unistd.h>#include <sys/select.h>#include <sys/types.h>#include <fcntl.h>#include <string.h>#define BUFFER_SIZE 1024#define FD_SETSIZE 10intmain(){ int fd[FD_SETSIZE]; fd_set read_fds; struct timeval timeout; int max_fd, ret; char buffer[BUFFER_SIZE]; ssize_t bytes_read; // 打开文件 for (int i = 0; i < FD_SETSIZE; i++) { char filename[20]; sprintf(filename, "test%d.txt", i); fd[i] = open(filename, O_RDONLY); if (fd[i] == -1) { perror("open"); return 1; } } // 设置最大文件描述符 max_fd = fd[FD_SETSIZE - 1]; while (1) { // 清空文件描述符集合 FD_ZERO(&read_fds); // 将文件描述符添加到集合中 for (int i = 0; i < FD_SETSIZE; i++) { FD_SET(fd[i], &read_fds); } // 设置超时时间 timeout.tv_sec = 5; timeout.tv_usec = 0; // 调用select监控文件描述符 ret = select(max_fd + 1, &read_fds, NULL, NULL, &timeout); if (ret == -1) { perror("select"); break; } else if (ret == 0) { // 超时 printf("Timeout\n"); continue; } else { // 有文件描述符就绪 for (int i = 0; i < FD_SETSIZE; i++) { if (FD_ISSET(fd[i], &read_fds)) { // 读取文件内容 bytes_read = read(fd[i], buffer, BUFFER_SIZE); if (bytes_read == -1) { perror("read"); close(fd[i]); } else { buffer[bytes_read] = '\0'; printf("Read from %d: %s\n", i, buffer); } } } } } // 关闭文件 for (int i = 0; i < FD_SETSIZE; i++) { close(fd[i]); } return 0;}// epoll示例#include <stdio.h>#include <unistd.h>#include <sys/epoll.h>#include <sys/types.h>#include <fcntl.h>#include <string.h>#define BUFFER_SIZE 1024#define MAX_EVENTS 10intmain(){ int epfd, fd[MAX_EVENTS]; struct epoll_event event, events[MAX_EVENTS]; int i, nfds; char buffer[BUFFER_SIZE]; ssize_t bytes_read; // 创建epoll实例 epfd = epoll_create1(0); if (epfd == -1) { perror("epoll_create1"); return 1; } // 打开文件并添加到epoll实例中 for (i = 0; i < MAX_EVENTS; i++) { char filename[20]; sprintf(filename, "test%d.txt", i); fd[i] = open(filename, O_RDONLY); if (fd[i] == -1) { perror("open"); close(epfd); return 1; } event.data.fd = fd[i]; event.events = EPOLLIN; if (epoll_ctl(epfd, EPOLL_CTL_ADD, fd[i], &event) == -1) { perror("epoll_ctl add"); close(fd[i]); close(epfd); return 1; } } while (1) { // 等待事件发生 nfds = epoll_wait(epfd, events, MAX_EVENTS, -1); if (nfds == -1) { perror("epoll_wait"); break; } // 处理就绪事件 for (i = 0; i < nfds; i++) { if (events[i].events & EPOLLIN) { int fd = events[i].data.fd; // 读取文件内容 bytes_read = read(fd, buffer, BUFFER_SIZE); if (bytes_read == -1) { perror("read"); close(fd); } else { buffer[bytes_read] = '\0'; printf("Read from %d: %s\n", fd, buffer); } } } } // 关闭文件和epoll实例 for (i = 0; i < MAX_EVENTS; i++) { close(fd[i]); } close(epfd); return 0;}
在select示例中，通过FD_ZERO、FD_SET和FD_ISSET等宏来操作文件描述符集合，调用select函数阻塞等待文件描述符就绪 。在epoll示例中，首先通过epoll_create1创建 epoll 实例，然后使用epoll_ctl将文件描述符添加到 epoll 实例中，最后通过epoll_wait等待事件发生并处理就绪事件 。I/O 多路复用的优点非常显著，它能够处理大量的并发连接，因为一个进程可以监控多个文件描述符，大大减少了系统资源的开销 。在高并发场景下，比如 Web 服务器、数据库服务器等，I/O 多路复用能够高效地处理大量的客户端请求，提高系统的性能和吞吐量 。然而，I/O 多路复用的实现相对复杂，需要开发者对 select、poll、epoll 等系统调用有深入的理解和掌握 。而且，不同的系统调用在性能和适用场景上也有所不同，选择合适的系统调用需要一定的经验和对系统性能的评估 。
总的来说，I/O 多路复用适用于高并发场景，尤其是需要处理大量并发连接且 I/O 操作较为频繁的应用 。像 Nginx、Redis 等高性能服务器软件，都广泛使用了 I/O 多路复用技术来提升系统的并发处理能力 。
2.4信号驱动 I/O（Signal - Driven IO）
信号驱动 I/O 是一种异步通知的 I/O 模型 。它的原理是当数据就绪时，内核会向进程发送一个SIGIO信号，进程在接收到这个信号后，会在信号处理函数中执行 I/O 操作 。这就好比你在餐厅点完菜后，服务员给你一个叫号器，当你的菜做好了，叫号器会响，提醒你去取餐 。
具体的工作流程如下：进程首先通过fcntl函数设置文件描述符为异步模式，并通过fcntl函数设置进程为文件描述符的拥有者 。然后，进程继续执行其他任务，当数据就绪时，内核会向进程发送SIGIO信号 。进程在接收到信号后，会调用预先注册的信号处理函数，在信号处理函数中执行数据读取操作。与非阻塞 I/O 的轮询机制不同，信号驱动 I/O 无需进程主动检查数据状态，而是由内核主动通知，这样可以避免轮询带来的 CPU 资源浪费，让进程在等待数据就绪期间能够更高效地执行其他业务逻辑。
需要注意的是，信号驱动 I/O 仅在数据就绪阶段实现异步，数据拷贝阶段依然是阻塞的 。也就是说，当内核发送SIGIO信号通知数据就绪后，进程在信号处理函数中调用read等系统调用时，依然会被阻塞，直到数据从内核缓冲区拷贝到用户空间缓冲区完成。
在 Linux 中，实现信号驱动 I/O 需要通过fcntl函数设置文件描述符的异步属性，并注册SIGIO信号的处理函数 。下面是一个信号驱动 I/O 的代码示例：
#include <stdio.h>#include <unistd.h>#include <fcntl.h>#include <signal.h>#include <string.h>#include <errno.h>#define BUFFER_SIZE 1024int fd; // 全局文件描述符，方便信号处理函数访问char buffer[BUFFER_SIZE];// SIGIO信号处理函数voidsigio_handler(int signum){ ssize_t bytes_read; // 数据就绪，读取数据（此阶段仍阻塞） bytes_read = read(fd, buffer, BUFFER_SIZE); if (bytes_read == -1) { perror("read in sigio_handler"); return; } buffer[bytes_read] = '\0'; printf("Read %zd bytes via signal-driven IO: %s\n", bytes_read, buffer);}intmain(){ int flags; struct sigaction sa; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 注册SIGIO信号处理函数 memset(&sa, 0, sizeof(sa)); sa.sa_handler = sigio_handler; sa.sa_flags = 0; if (sigaction(SIGIO, &sa, NULL) == -1) { perror("sigaction"); close(fd); return 1; } // 设置文件描述符的拥有者为当前进程 if (fcntl(fd, F_SETOWN, getpid()) == -1) { perror("fcntl F_SETOWN"); close(fd); return 1; } // 获取文件描述符当前标志，并设置为异步模式（O_ASYNC） flags = fcntl(fd, F_GETFL, 0); if (flags == -1) { perror("fcntl F_GETFL"); close(fd); return 1; } if (fcntl(fd, F_SETFL, flags | O_ASYNC) == -1) { perror("fcntl F_SETFL O_ASYNC"); close(fd); return 1; } // 进程继续执行其他任务（模拟业务逻辑） printf("Waiting for data via signal-driven IO...\n"); while (1) { sleep(2); // 模拟其他任务执行 printf("Doing other tasks...\n"); } // 实际不会执行到这里，仅作示例 close(fd); return 0;}
在这个示例中，首先注册SIGIO信号的处理函数sigio_handler，然后通过fcntl函数设置文件描述符的拥有者为当前进程，并开启异步模式（O_ASYNC）。之后进程可以执行其他任务，当数据就绪时，内核会发送SIGIO信号，触发信号处理函数执行数据读取操作。
信号驱动 I/O 的优点在于，进程无需像非阻塞 I/O 那样频繁轮询检查数据状态，而是由内核主动通知数据就绪，这样可以减少 CPU 资源的浪费，提高系统资源利用率 。同时，它的实时性较好，数据就绪后能及时通知进程处理，适用于对实时性要求较高的场景。
其缺点也较为明显：信号处理机制本身较为复杂，尤其是在多线程、多文件描述符的场景下，信号的分发和处理容易出现混乱，增加程序的开发和调试难度 。此外，数据拷贝阶段依然阻塞，无法充分利用 CPU 资源；而且SIGIO信号是一种异步信号，可能会被其他信号打断，影响 I/O 操作的稳定性。基于这些特点，信号驱动 I/O 适用于对实时性要求较高且数据处理不复杂的场景 。比如一些实时数据采集系统，需要及时响应外部设备的数据就绪事件，且每次数据处理逻辑简单，此时使用信号驱动 I/O 可以在保证实时性的同时，减少 CPU 开销。
2.5异步 I/O（Asynchronous IO）
异步 I/O 是五种 I/O 模型中真正实现完全异步的模型，它与前面几种模型的核心区别在于：进程发起 I/O 操作后，无需等待数据就绪和数据拷贝两个阶段，而是直接返回，继续执行其他任务 。内核会全程负责数据的就绪和拷贝操作，当这两个阶段全部完成后，内核才会向进程发送通知（通常是信号或回调函数），告知进程 I/O 操作已完成。
用生活场景类比，就像是你在餐厅点完菜后，直接回家等待，不需要在餐厅等待，也不需要频繁打电话询问，当菜做好后，外卖员会直接把菜送到你家，通知你可以享用了 。整个过程中，你可以自由安排其他事情，完全不会被点餐这件事阻塞。
具体的工作流程如下：进程通过异步 I/O 系统调用（如aio_read、aio_write）发起 I/O 操作，并指定操作完成后的通知方式（信号或回调）。调用完成后，进程立即返回，继续执行自身的业务逻辑 。内核会在后台完成数据就绪（从外部设备读取到内核缓冲区）和数据拷贝（从内核缓冲区拷贝到用户空间缓冲区）两个阶段 。当所有操作完成后，内核会通过预先约定的方式通知进程，进程收到通知后，即可直接使用用户空间缓冲区中的数据（读操作）或确认数据已写入外部设备（写操作）。
需要注意的是，异步 I/O 与信号驱动 I/O 的核心区别的是：信号驱动 I/O 仅在数据就绪阶段异步，数据拷贝阶段仍阻塞；而异步 I/O 的数据就绪和数据拷贝两个阶段均异步，进程全程不阻塞。
在 Linux 中，异步 I/O 可以通过 POSIX 异步 I/O 接口（如aio_read、aio_write、aio_error、aio_waitcomplete等）实现 。下面是一个使用aio_read实现异步读操作的代码示例：
#include <stdio.h>#include <unistd.h>#include <fcntl.h>#include <aio.h>#include <signal.h>#include <string.h>#include <errno.h>#define BUFFER_SIZE 1024struct aiocb aiocb_obj; // 异步I/O控制块char buffer[BUFFER_SIZE];// 异步I/O完成后的信号处理函数voidaio_complete_handler(int signum, siginfo_t *info, void *context){ ssize_t bytes_read; // 检查是否是当前异步I/O操作完成的信号 if (info->si_value.sival_ptr == &aiocb_obj) { // 获取读取的字节数 bytes_read = aio_return(&aiocb_obj); if (bytes_read == -1) { perror("aio_return"); return; } buffer[bytes_read] = '\0'; printf("Asynchronous IO completed, read %zd bytes: %s\n", bytes_read, buffer); }}intmain(){ int fd; struct sigaction sa; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 初始化异步I/O控制块 memset(&aiocb_obj, 0, sizeof(struct aiocb)); aiocb_obj.aio_fildes = fd; // 关联文件描述符 aiocb_obj.aio_buf = buffer; // 关联用户缓冲区 aiocb_obj.aio_nbytes = BUFFER_SIZE; // 读取的字节数 aiocb_obj.aio_offset = 0; // 读取的偏移量 aiocb_obj.aio_sigevent.sigev_notify = SIGEV_SIGNAL; // 通知方式：信号 aiocb_obj.aio_sigevent.sigev_signo = SIGUSR1; // 通知信号：SIGUSR1 aiocb_obj.aio_sigevent.sigev_value.sival_ptr = &aiocb_obj; // 传递异步I/O控制块地址 // 注册SIGUSR1信号处理函数 memset(&sa, 0, sizeof(sa)); sa.sa_sigaction = aio_complete_handler; // 信号处理函数（带参数） sa.sa_flags = SA_SIGINFO; // 允许信号处理函数接收额外信息 if (sigaction(SIGUSR1, &sa, NULL) == -1) { perror("sigaction"); close(fd); return 1; } // 发起异步读操作 if (aio_read(&aiocb_obj) == -1) { perror("aio_read"); close(fd); return 1; } // 进程继续执行其他任务（模拟业务逻辑） printf("Asynchronous IO initiated, doing other tasks...\n"); while (1) { sleep(2); printf("Still doing other tasks...\n"); } // 实际不会执行到这里，仅作示例 close(fd); return 0;}
在这个示例中，首先初始化异步 I/O 控制块aiocb，指定文件描述符、用户缓冲区、读取字节数等参数，并设置通知方式为SIGUSR1信号 。然后注册SIGUSR1信号的处理函数，发起异步读操作aio_read后，进程立即返回并执行其他任务 。当内核完成数据就绪和拷贝后，会发送SIGUSR1信号，触发处理函数，进程在处理函数中获取读取结果并使用。
异步 I/O 的优点是显而易见的，它实现了完全异步，进程全程不阻塞，能够最大程度地利用 CPU 资源，提高系统的整体性能和吞吐量 。在高并发、大负载的场景下，异步 I/O 可以让进程在等待 I/O 操作完成的同时，处理更多的业务逻辑，避免 CPU 资源闲置。
其缺点也同样突出：实现难度大，需要开发者熟练掌握异步 I/O 的系统调用和信号/回调机制，而且程序的调试和维护难度较高 。此外，并非所有的 Linux 系统和文件系统都完美支持 POSIX 异步 I/O，存在一定的兼容性问题；同时，异步 I/O 的 overhead（开销）相对较大，在小数据量、低并发的场景下，优势不明显，甚至可能不如阻塞 I/O 高效。
因此，异步 I/O 适用于对 I/O 性能要求极高、高并发、大负载的场景 。比如高性能的文件服务器、大数据处理系统、高并发的网络服务等，这些场景中 I/O 操作频繁且数据量较大，使用异步 I/O 可以显著提升系统的处理能力和响应速度。
三、I/O 机制的实现方式
3.1系统调用
在 Linux 内核 I/O 机制中，系统调用是应用程序与内核进行交互的重要接口 。其中，open、read、write、close等系统调用是最为常用的文件操作接口，它们在内核中的实现过程和相关参数含义对于理解 Linux 内核 I/O 机制至关重要。
open系统调用用于打开一个文件或创建一个新文件 ，其函数原型为int open(const char *pathname, int flags, mode_t mode); 。其中，pathname是要打开或创建的文件的路径名；flags是打开文件的标志，它可以是多个标志的按位或组合，常见的标志有O_RDONLY（只读打开）、O_WRONLY（只写打开）、O_RDWR（读写打开）、O_CREAT（如果文件不存在则创建）、O_EXCL（与O_CREAT一起使用，确保文件是新创建的，若文件已存在则返回错误）等；mode参数用于指定新创建文件的权限，只有在使用O_CREAT标志创建新文件时才会用到，它是一个八进制数，例如0644表示文件所有者具有读写权限，组用户和其他用户具有读权限。
在open系统调用的实现过程中，内核首先会根据pathname查找文件的inode 。如果文件不存在且设置了O_CREAT标志，内核会创建一个新的inode和文件。然后，内核会创建一个新的文件对象，并将其与inode关联起来。最后，内核会在进程的文件表中分配一个新的文件描述符，并返回该文件描述符给应用程序。例如，当应用程序执行open("test.txt", O_RDONLY)时，内核会查找名为test.txt的文件的inode，如果找到，就创建文件对象并关联inode，然后返回一个文件描述符，应用程序可以通过这个文件描述符对test.txt进行后续操作。
read系统调用用于从文件中读取数据 ，函数原型是ssize_t read(int fd, void *buf, size_t count); 。这里，fd是文件描述符，它是由open系统调用返回的，用于标识要读取的文件；buf是用户空间的缓冲区，用于存储读取的数据；count是要读取的字节数。在read系统调用的实现过程中，内核会根据文件描述符找到对应的文件对象，然后从文件的当前位置开始读取数据 。如果文件的当前位置已经超过了文件的大小，read会返回 0，表示已经到达文件末尾。如果读取过程中发生错误，read会返回一个负数，并设置errno变量来表示错误类型。例如，当应用程序执行read(fd, buffer, 1024)时，内核会根据fd找到对应的文件，从文件当前位置读取最多 1024 字节的数据到buffer中，并返回实际读取的字节数。
write系统调用用于向文件中写入数据 ，函数原型为ssize_t write(int fd, const void *buf, size_t count); 。fd同样是文件描述符；buf是用户空间中包含要写入数据的缓冲区；count是要写入的字节数。在write系统调用的实现过程中，内核会根据文件描述符找到对应的文件对象，然后将用户缓冲区中的数据写入文件 。如果写入成功，write会返回实际写入的字节数；如果写入过程中发生错误，write会返回一个负数，并设置errno变量。例如，当应用程序执行write(fd, buffer, 512)时，内核会将buffer中的 512 字节数据写入fd对应的文件中，并返回实际写入的字节数。
close系统调用用于关闭一个文件描述符 ，函数原型是int close(int fd); 。fd是要关闭的文件描述符。在close系统调用的实现过程中，内核会根据文件描述符找到对应的文件对象，减少文件对象的引用计数 。如果引用计数变为 0，内核会释放文件对象以及与之关联的资源，如关闭文件对应的设备、释放缓冲区等。最后，内核会从进程的文件表中删除该文件描述符的记录。如果close操作成功，会返回 0；如果失败，会返回 -1，并设置errno变量。例如，当应用程序执行close(fd)时，内核会对fd对应的文件对象进行处理，释放相关资源，完成文件关闭操作。
3.2内核数据结构
在 Linux 内核 I/O 机制中，有许多重要的数据结构与 I/O 操作密切相关 ，它们协同工作，共同完成文件的管理和 I/O 操作。这些数据结构包括file、dentry、inode、bio等，深入了解它们之间的关系和在 I/O 操作中的作用，对于理解 Linux 内核 I/O 机制的工作原理至关重要。
file结构体是内核中表示一个打开文件的重要数据结构 ，每个打开的文件在内核中都有一个对应的file结构体。它包含了文件的打开模式（如只读、只写、读写等）、当前读写位置、文件操作函数指针集合（file_operations）等重要信息 。文件操作函数指针集合定义了对该文件可以进行的各种操作，如read、write、open、close等函数的指针 。通过这些函数指针，内核可以调用相应的函数来执行具体的文件操作。例如，当应用程序调用read系统调用时，内核会根据file结构体中的read函数指针，找到对应的read操作函数，并执行该函数来完成文件读取操作。
dentry结构体（目录项）是用于表示文件系统中文件或目录的名称和位置信息的数据结构 ，它在文件路径的查找和解析过程中发挥着关键作用。当我们通过文件路径打开一个文件时，内核会根据路径中的各个部分，依次查找对应的dentry 。每个dentry都包含了文件名以及指向其父目录dentry和子目录dentry的指针，通过这些指针，内核可以构建出文件系统的目录树结构 。例如，对于路径/home/user/test.txt，内核会首先找到根目录/的dentry，然后根据home找到home目录的dentry，再根据user找到user目录的dentry，最后根据test.txt找到文件test.txt的dentry。通过这种方式，内核能够准确地定位到要操作的文件。
inode结构体（索引节点）则包含了文件的元数据信息 ，如文件的权限、大小、创建时间、修改时间、文件所有者、文件所属组等 。每个文件在文件系统中都有一个唯一的inode ，dentry通过指向inode，将文件的名称和元数据联系起来。当内核需要获取文件的属性信息时，会通过dentry找到对应的inode，从而获取文件的元数据。例如，当应用程序调用stat函数获取文件的属性时，内核会根据文件的dentry找到对应的inode，并将inode中的元数据信息返回给应用程序。
bio结构体（块 I/O）主要用于管理块设备的 I/O 操作 ，它包含了 I/O 操作的目标设备、要传输的数据块列表、数据传输方向（读或写）等信息 。在进行块设备 I/O 操作时，内核会创建一个或多个bio结构体来描述 I/O 请求 。例如，当从磁盘读取数据时，内核会创建一个bio结构体，其中指定了磁盘设备、要读取的数据块位置和大小等信息，然后将这个bio结构体传递给块设备驱动程序，由驱动程序执行实际的 I/O 操作。
这些内核数据结构之间存在着紧密的联系 。file结构体通过dentry结构体与inode结构体关联起来 ，dentry是文件路径和inode之间的桥梁，而inode则提供了文件的元数据信息。bio结构体则在块设备 I/O 操作中，与file、inode等数据结构协同工作，实现数据在内存和块设备之间的传输 。例如，当应用程序对一个文件进行写入操作时，内核会根据file结构体找到对应的dentry和inode，然后创建bio结构体来描述写入操作的具体信息，将数据从内存传输到块设备中。这种相互关联的数据结构体系，使得 Linux 内核能够高效、灵活地管理和处理各种 I/O 操作。
四、高效数据传输的关键原因
4.1缓冲区的作用与优化
在 Linux I/O 中，缓冲区扮演着至关重要的角色，它是数据在内存中的临时存储区域，就像一个数据的 “中转站”。当应用程序进行 I/O 操作时，缓冲区可以减少磁盘 I/O 操作的次数 。比如，在读取文件时，如果没有缓冲区，每次读取一个字节都需要进行一次磁盘 I/O 操作，这将极大地降低效率 。而有了缓冲区，系统可以一次性从磁盘读取多个字节到缓冲区中，应用程序再从缓冲区中读取数据，这样就减少了磁盘 I/O 的次数，提高了数据传输的效率 。
从系统层面来看，缓冲区主要分为内核缓冲区和用户缓冲区 。内核缓冲区是由操作系统内核管理的，用于存储从磁盘读取的数据或者准备写入磁盘的数据 。用户缓冲区则是由应用程序在用户空间中分配的，用于存储应用程序需要处理的数据 。在进行 I/O 操作时，数据通常会先被读取到内核缓冲区，然后再被拷贝到用户缓冲区 。
为了提高数据传输效率，对缓冲区的大小和读写策略进行优化是非常必要的 。在缓冲区大小方面，不同的应用场景需要选择合适的缓冲区大小 。对于大文件的读写操作，较大的缓冲区可以减少 I/O 操作的次数，提高传输效率 。比如，在处理视频文件时，将缓冲区大小设置为几 MB 甚至更大，可以显著提升文件的读取速度 。而对于小文件或者频繁的小数据量读写操作，较小的缓冲区可能更为合适，这样可以避免内存的浪费 。一般来说，缓冲区大小可以根据文件系统的块大小来进行调整，常见的文件系统块大小为 4KB，因此缓冲区大小可以设置为 4KB 的倍数 。
在读写策略上，合理的读写策略也能提升传输效率 。例如，采用预读策略，在应用程序请求数据之前，系统预先将可能需要的数据读取到缓冲区中，这样当应用程序真正读取数据时，就可以直接从缓冲区中获取，减少等待时间 。在写入数据时，可以采用延迟写策略，将数据先写入缓冲区，等到缓冲区满或者满足一定条件时，再一次性将数据写入磁盘，这样可以减少磁盘 I/O 的次数 。
4.2零拷贝技术（Zero - copy）
零拷贝技术是一种能够显著提高数据传输效率的技术，它的核心原理是减少数据在内存中的拷贝次数 。在传统的 I/O 数据传输流程中，数据需要在用户空间和内核空间之间进行多次拷贝 。以从文件读取数据并通过网络发送为例，首先需要将数据从磁盘读取到内核缓冲区，然后再从内核缓冲区拷贝到用户空间缓冲区，接着用户空间缓冲区的数据又要被拷贝到内核的 Socket 缓冲区，最后才能通过网络发送出去 。这个过程涉及到多次 CPU 参与的数据拷贝操作，不仅消耗 CPU 资源，还会增加数据传输的时间 。
而零拷贝技术则通过优化数据传输路径，减少了这些不必要的拷贝次数 。例如，在使用mmap实现零拷贝时，它利用虚拟内存技术，将内核缓冲区与用户缓冲区映射到同一块物理内存 。这样，应用程序可以直接访问内核缓冲区中的数据，而无需将数据拷贝到用户空间缓冲区，从而减少了一次 CPU 拷贝 。在使用sendfile系统调用时，数据可以直接在内核空间中从一个文件描述符传输到另一个文件描述符，比如从文件描述符直接传输到 Socket 描述符，整个过程数据无需经过用户空间，进一步减少了拷贝次数 。
通过减少数据拷贝次数，零拷贝技术带来了诸多优势 。它大大提高了数据传输的速度，因为减少了 CPU 拷贝操作，使得 CPU 可以有更多的时间去处理其他任务，从而提高了系统的整体性能 。同时，由于减少了数据拷贝，也降低了内存带宽的消耗，提高了内存的利用率 。在高并发的网络传输场景中，零拷贝技术的优势尤为明显，它可以显著提升服务器的吞吐量和响应速度 。
在 Linux 系统中，有多种实现零拷贝的方式，其中比较常见的是mmap和sendfile系统调用 。mmap函数用于将文件映射到进程的地址空间，通过将文件内容映射到内存，进程可以像访问内存一样访问文件，而无需进行显式的读操作 。在网络传输场景中，可以先使用mmap将文件映射到内存，然后通过write系统调用将数据发送到 Socket，这个过程中数据只需要从内核缓冲区拷贝到 Socket 缓冲区，减少了一次拷贝 。
#include <stdio.h>#include <sys/mman.h>#include <sys/types.h>#include <sys/stat.h>#include <fcntl.h>#include <unistd.h>#include <string.h>#include <stdlib.h>#define FILE_SIZE 1024intmain(){ int fd, socket_fd; char *file_content; struct stat file_stat; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 获取文件状态 if (fstat(fd, &file_stat) == -1) { perror("fstat"); close(fd); return 1; } // 将文件映射到内存 file_content = (char *)mmap(NULL, file_stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0); if (file_content == MAP_FAILED) { perror("mmap"); close(fd); return 1; } // 模拟创建Socket（实际场景中需结合网络编程逻辑） // 此处仅为示例，简化Socket创建流程 socket_fd = socket(AF_INET, SOCK_STREAM, 0); if (socket_fd == -1) { perror("socket"); munmap(file_content, file_stat.st_size); close(fd); return 1; } // 假设已完成Socket连接（此处省略bind、connect等步骤） // 通过write发送映射到内存的文件内容，减少一次数据拷贝 ssize_t bytes_sent = write(socket_fd, file_content, file_stat.st_size); if (bytes_sent == -1) { perror("write"); } else { printf("Sent %zd bytes via mmap zero-copy\n", bytes_sent); } // 释放映射内存、关闭文件和Socket munmap(file_content, file_stat.st_size); close(fd); close(socket_fd); return 0;}// sendfile示例（直接在内核空间传输数据，完全避免用户空间拷贝）#include <stdio.h>#include <sys/sendfile.h>#include <sys/types.h>#include <sys/stat.h>#include <fcntl.h>#include <unistd.h>#include <netinet/in.h>#include <sys/socket.h>intmain(){ int fd, socket_fd; struct stat file_stat; off_t offset = 0; // 打开文件 fd = open("test.txt", O_RDONLY); if (fd == -1) { perror("open"); return 1; } // 获取文件状态 if (fstat(fd, &file_stat) == -1) { perror("fstat"); close(fd); return 1; } // 创建Socket socket_fd = socket(AF_INET, SOCK_STREAM, 0); if (socket_fd == -1) { perror("socket"); close(fd); return 1; } // 简化Socket连接流程（实际需绑定端口、监听、接受连接） struct sockaddr_in addr; addr.sin_family = AF_INET; addr.sin_port = htons(8080); addr.sin_addr.s_addr = INADDR_ANY; if (bind(socket_fd, (struct sockaddr*)&addr, sizeof(addr)) == -1) { perror("bind"); close(fd); close(socket_fd); return 1; } if (listen(socket_fd, 5) == -1) { perror("listen"); close(fd); close(socket_fd); return 1; } int client_fd = accept(socket_fd, NULL, NULL); if (client_fd == -1) { perror("accept"); close(fd); close(socket_fd); return 1; } // 使用sendfile实现零拷贝传输，数据直接在内核空间从文件描述符到Socket描述符 ssize_t bytes_sent = sendfile(client_fd, fd, &offset, file_stat.st_size); if (bytes_sent == -1) { perror("sendfile"); } else { printf("Sent %zd bytes via sendfile zero-copy\n", bytes_sent); } // 关闭文件和Socket close(fd); close(client_fd); close(socket_fd); return 0;}
除了mmap和sendfile，Linux 还提供了splice、tee等系统调用实现零拷贝，它们的核心思想都是减少数据在用户空间与内核空间的拷贝，只是适用场景略有差异。splice可以将两个文件描述符之间的数据传输完全在内核空间完成，无需经过用户空间；tee则可以实现数据的“分流”，将一个文件描述符的数据同时传输到两个目标文件描述符，同样无需用户空间拷贝。
零拷贝技术的应用场景非常广泛，尤其适用于高并发、大数据量的传输场景。比如，Web 服务器传输静态资源（如 HTML、CSS、图片、视频等）时，使用零拷贝技术可以显著提升资源传输速度，减少 CPU 占用；在大数据处理场景中，数据从磁盘读取后需要快速传输到处理模块，零拷贝技术可以减少数据拷贝开销，提高处理效率；此外，在分布式系统中，节点之间的数据同步、文件传输等场景，零拷贝技术也能发挥重要作用。像 Nginx、Apache 等主流 Web 服务器，都默认支持零拷贝技术，以此提升服务的并发处理能力和响应速度。
4.3I/O 调度算法
在 Linux 系统中，I/O 调度算法负责管理和优化磁盘 I/O 请求的执行顺序，其核心目标是减少磁盘寻道时间，提高磁盘 I/O 效率。磁盘寻道时间是磁盘 I/O 操作中最耗时的环节之一，通过合理安排 I/O 请求的执行顺序，可以最大限度地减少磁头移动距离，从而提升整体 I/O 性能。Linux 系统中常见的 I/O 调度算法主要有以下几种：
- 第一种是 CFQ（Completely Fair Queueing，完全公平队列），它是许多 Linux 发行版的默认调度算法。CFQ 为每个进程分配一个独立的 I/O 队列，按照时间片轮转的方式处理各个队列的 I/O 请求，确保每个进程都能公平地获得磁盘 I/O 资源。这种算法适用于多进程并发 I/O 的场景，能够避免单个进程占用过多的 I/O 资源，保证系统的整体公平性和稳定性。
- 第二种是 Deadline 调度算法，它的核心思想是为每个 I/O 请求设置一个截止时间，优先处理截止时间更近的请求，同时兼顾读请求和写请求的优先级（默认读请求优先级高于写请求）。Deadline 算法能够有效避免 I/O 请求被长期阻塞，尤其适用于对 I/O 响应时间要求较高的场景，比如数据库服务器，能够保证关键 I/O 请求及时得到处理。
- 第三种是 NOOP（No Operation，无操作）调度算法，它是一种最简单的调度算法，不对 I/O 请求进行排序，而是按照请求到达的顺序直接执行。NOOP 算法适用于 SSD（固态硬盘）等没有机械寻道时间的存储设备，因为 SSD 的读写速度主要取决于闪存芯片的性能，无需通过排序减少寻道时间，此时 NOOP 算法的开销最小，效率最高。
- 第四种是 MQ-Deadline 调度算法，它是 Deadline 算法的多队列版本，适用于多队列磁盘（如 NVMe SSD）。MQ-Deadline 为每个磁盘队列分配独立的调度队列，能够更好地利用多队列磁盘的并行处理能力，进一步提升 I/O 性能，尤其适用于高性能存储设备和高并发 I/O 场景。
选择合适的 I/O 调度算法需要结合存储设备类型、应用场景和 I/O 特征来决定。首先，根据存储设备类型选择：对于机械硬盘（HDD），由于其存在明显的寻道时间，建议选择 CFQ 或 Deadline 算法，通过排序减少寻道开销；对于固态硬盘（SSD）或 NVMe 设备，建议选择 NOOP 或 MQ-Deadline 算法，避免不必要的排序开销，充分发挥设备的并行处理能力。
其次，根据应用场景选择：对于多进程并发、对公平性要求较高的场景（如通用服务器），CFQ 算法是较好的选择；对于对 I/O 响应时间敏感的场景（如数据库、实时交易系统），Deadline 或 MQ-Deadline 算法更合适；对于高性能计算、大数据处理等场景，可根据存储设备类型和 I/O 模式，选择能够最大化并行处理能力的算法。
此外，还可以通过调整 I/O 调度算法的参数进行优化。比如，调整 CFQ 算法的时间片大小，平衡不同进程的 I/O 资源分配；调整 Deadline 算法的读/写请求截止时间，适配不同应用的 I/O 响应需求；对于多队列磁盘，可调整 MQ-Deadline 算法的队列优先级，确保关键业务的 I/O 请求优先执行。在 Linux 系统中，可以通过echo命令修改/sys/block/[磁盘设备名]/queue/scheduler文件，临时切换 I/O 调度算法，也可以通过修改系统配置文件实现永久生效。
五、epoll 实战案例（基于Linux I/O 底层机制）
某小型 Web 服务器，需处理 1000+ 并发客户端请求，主要提供静态资源（HTML、图片）访问服务。初期使用阻塞 I/O 模型，出现客户端连接超时、服务器 CPU 利用率偏低但响应缓慢的问题，需优化 I/O 模型提升并发处理能力。
阻塞 I/O 模型下，每个客户端连接对应一个线程，1000+ 并发连接需创建 1000+ 线程，线程上下文切换开销巨大，导致 CPU 大部分时间消耗在切换上，而非处理 I/O 请求；同时，线程阻塞等待 I/O 就绪时，CPU 处于闲置状态，资源利用率极低，最终导致客户端响应缓慢。
选用 I/O 多路复用中的 epoll 模型，单个进程即可监控所有客户端连接的 I/O 事件，减少线程创建数量和上下文切换开销，提高 CPU 利用率和并发处理能力。代码示例如下：
#include <stdio.h>#include <unistd.h>#include <sys/epoll.h>#include <sys/socket.h>#include <netinet/in.h>#include <arpa/inet.h>#include <fcntl.h>#include <string.h>#include <errno.h>#define MAX_EVENTS 1024 // 最大监控事件数#define PORT 8080 // 监听端口#define BUFFER_SIZE 4096 // 缓冲区大小// 设置文件描述符为非阻塞模式intset_nonblocking(int fd){ int flags = fcntl(fd, F_GETFL, 0); if (flags == -1) { perror("fcntl F_GETFL"); return -1; } if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1) { perror("fcntl F_SETFL"); return -1; } return 0;}intmain(){ int listen_fd, epfd, nfds; struct epoll_event event, events[MAX_EVENTS]; struct sockaddr_in addr, client_addr; socklen_t client_addr_len = sizeof(client_addr); char buffer[BUFFER_SIZE]; ssize_t bytes_read, bytes_sent; // 1. 创建监听Socket listen_fd = socket(AF_INET, SOCK_STREAM, 0); if (listen_fd == -1) { perror("socket"); return 1; } // 2. 设置监听Socket为非阻塞 if (set_nonblocking(listen_fd) == -1) { close(listen_fd); return 1; } // 3. 绑定端口和地址 memset(&addr, 0, sizeof(addr)); addr.sin_family = AF_INET; addr.sin_port = htons(PORT); addr.sin_addr.s_addr = INADDR_ANY; if (bind(listen_fd, (struct sockaddr*)&addr, sizeof(addr)) == -1) { perror("bind"); close(listen_fd); return 1; } // 4. 开始监听 if (listen(listen_fd, 1024) == -1) { perror("listen"); close(listen_fd); return 1; } // 5. 创建epoll实例 epfd = epoll_create1(0); if (epfd == -1) { perror("epoll_create1"); close(listen_fd); return 1; } // 6. 将监听Socket添加到epoll监控中 event.data.fd = listen_fd; event.events = EPOLLIN | EPOLLET; // 边缘触发模式 if (epoll_ctl(epfd, EPOLL_CTL_ADD, listen_fd, &event) == -1) { perror("epoll_ctl add listen_fd"); close(listen_fd); close(epfd); return 1; } printf("Web server started, listening on port %d...\n", PORT); // 7. 循环等待I/O事件 while (1) { nfds = epoll_wait(epfd, events, MAX_EVENTS, -1); // 阻塞等待 if (nfds == -1) { perror("epoll_wait"); break; } // 处理就绪事件 for (int i = 0; i < nfds; i++) { int fd = events[i].data.fd; // 监听Socket有新连接 if (fd == listen_fd) { int client_fd = accept(listen_fd, (struct sockaddr*)&client_addr, &client_addr_len); if (client_fd == -1) { perror("accept"); continue; } // 设置客户端Socket为非阻塞 if (set_nonblocking(client_fd) == -1) { close(client_fd); continue; } // 将客户端Socket添加到epoll监控中 event.data.fd = client_fd; event.events = EPOLLIN | EPOLLET; // 边缘触发 if (epoll_ctl(epfd, EPOLL_CTL_ADD, client_fd, &event) == -1) { perror("epoll_ctl add client_fd"); close(client_fd); continue; } printf("New client connected: %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); } // 客户端Socket有数据可读 else if (events[i].events & EPOLLIN) { memset(buffer, 0, BUFFER_SIZE); bytes_read = read(fd, buffer, BUFFER_SIZE); if (bytes_read == -1) { // 非阻塞模式下，EAGAIN表示无数据可读，忽略 if (errno != EAGAIN && errno != EWOULDBLOCK) { perror("read"); epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); close(fd); } continue; } else if (bytes_read == 0) { // 客户端关闭连接 printf("Client disconnected: %d\n", fd); epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); close(fd); continue; } // 响应静态资源（返回简单HTML） const char* response = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Length: 12\r\n\r\nHello World!\n"; bytes_sent = write(fd, response, strlen(response)); if (bytes_sent == -1) { perror("write"); epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); close(fd); } } } } // 关闭资源 close(listen_fd); close(epfd); return 0;}
