Redis 的 I/O 多路复用是怎么工作的？从事件循环到 Reactor 一次讲清

阿麦

发布时间：2026-08-24 | 68人浏览过

原创

前言

很多人知道 Redis 快，却不一定说得清它为什么能在单线程里同时处理大量连接。真正的关键不只是“单线程”，而是 I/O 多路复用配合 Reactor 事件模型；下面会按工作机制、系统调用差异和代码示例逐层拆开，让你能看懂 Redis 的高并发基础到底建立在什么之上。

很多人第一次接触 Redis 时，都会把它的高性能简单归因于“单线程”。但真正决定它能否在高并发下稳住吞吐的，是背后的 I/O 多路复用和事件驱动模型。本文从“它到底怎么同时盯住那么多连接”讲起，再落到 Redis 的 Reactor 结构和 ae.c 中的 epoll 示例代码，帮助你把概念、流程和实现对应起来。

为什么 Redis 能用单线程扛住大量连接

Redis 的高性能，很大程度上来自 I/O 多路复用。它不是为每个连接都创建一个线程，而是在单个线程里同时监听多个套接字；一旦某个套接字已经准备好读取或写入，Redis 就立刻处理对应事件。

这种做法的关键价值在于：把“等待网络数据到来”的成本交给操作系统，把真正的业务处理集中在少量活跃连接上。这样既减少了线程资源消耗，也避免了频繁上下文切换带来的额外开销。

I/O 多路复用到底是怎么工作的

I/O 多路复用允许单个线程监视多个文件描述符或套接字。当某个连接进入可读、可写或异常状态时，操作系统通知应用程序，应用程序再执行对应的读取、写入或错误处理逻辑。

在 Redis 这样的网络服务里，它的工作方式可以拆成 5 个步骤：

监听多个通道：服务器把多个客户端连接作为被监听对象，这些通道通常就是 socket。
监控状态变化：系统持续关注这些连接是否可读、可写，或者是否出现异常。
事件通知：当某个连接满足应用程序设定的条件时，操作系统把事件交回来。
事件处理：应用程序根据事件类型调用处理函数，例如读取客户端请求、写回响应数据。
非阻塞操作：这些连接通常会设置成非阻塞模式；如果数据暂时不可读或不可写，调用会立即返回，而不是卡住线程。

这也是它和传统“一连接一线程”模型的根本区别：线程不再被单个连接拖住，而是始终围绕“谁准备好了就先处理谁”来运转。

select、poll、epoll、kqueue 有什么区别

Redis 并不是自己发明了一套监听机制，它依赖的是操作系统提供的 I/O 多路复用能力。常见实现主要有 select、poll、epoll 和 kqueue。

select

select 是最早期的 I/O 多路复用技术之一。
它可以监视一组文件描述符，判断它们是否处于可读、可写或异常状态。
它的典型限制在于使用固定大小的位集合来跟踪文件描述符，因此可监视数量存在上限。

poll

poll 和 select 的思路相近。
区别在于它不受最大文件描述符数量上限的直接限制。
poll 使用动态分配的数组来跟踪文件描述符，而不是固定大小的位集合。

epoll

epoll 是 Linux 提供的高效事件通知机制。
它不需要每次调用时都重复传递整组文件描述符，而是在初始化时创建一个 epoll 实例，再通过接口增删监听对象。
由于使用内核数据结构跟踪状态变化，epoll 在大量文件描述符场景下通常更高效。

kqueue

kqueue 是 BSD 系统上的高效事件机制，常见于 macOS 和 FreeBSD。
它支持注册并处理多种类型的事件，不仅包括文件描述符事件，也包括定时器事件等。

如果只看 Redis 的常见部署环境，Linux 上最常提到的是 epoll；但从设计上说，Redis 的事件框架本身会根据平台能力选择合适的底层实现。

用分步骤图解释 epoll 示例代码从创建实例到处理 EPOLLIN 事件的过程 — **epoll 示例代码拆解图**示例代码虽然简化，但已经覆盖了 epoll 版 Reactor。

用结构关系图展示 Redis Reactor 模式中的分派器、处理器和事件创建器 — **Redis Reactor 结构关系图**Reactor 模式不是抽象名词，在 Redis。

用流程图展示 I/O 多路复用从监听到处理事件的完整路径 — **Redis 事件循环流程图**把 Redis 网络层常见的“监听、等待、分发、处理”流程拆开后。

一个事件循环会经历哪些步骤

从程序运行角度看，I/O 多路复用一般会围绕一个持续循环展开，Redis 也不例外。这个循环通常包含以下阶段：

初始化：创建一个 I/O 多路复用实例，例如建立一个 epoll 实例，或者准备一次 select 调用所需的数据结构。
注册文件描述符：把需要监听的文件描述符添加进去。
等待事件：调用 select、poll、epoll_wait 或 kevent，等待事件发生。
处理事件：事件返回后，程序按类型调用对应处理函数。
继续循环：处理完成后回到等待阶段，持续监听新的网络事件。

对高性能网络服务器来说，核心并不只是“能等到事件”，而是“能用尽量低的额外成本管理大量空闲连接，只把 CPU 花在真正活跃的连接上”。

Redis 的 Reactor 模式是怎么落地的

Redis 的高性能网络事件处理器，本质上就是一个基于 Reactor 模式的事件驱动系统。它通过非阻塞 I/O 多路复用，同时监控多个套接字，并在套接字准备好执行读取或写入时调用相应的处理器。

Reactor 的三个核心角色

事件分派器（Reactor）：负责监听和分发事件。在 Redis 中，这一层通过 epoll、select、kqueue 等机制监控多个套接字，再把发生的事件分派给对应处理器。
事件处理器：负责真正执行逻辑，例如读取客户端请求、发送命令响应。文中提到的处理器包括连接应答处理器、命令请求处理器和命令回复处理器。
事件创建器：负责新增事件、删除事件，维护当前哪些文件描述符需要被监听。

这种结构的好处是职责清晰：分派器负责“发现谁有事”，处理器负责“具体怎么做”，事件创建器负责“监听名单怎么维护”。

从 ae.c 示例看 epoll 版 Reactor 流程

在 Redis 中，Reactor 模式的实现代码主要位于 ae.c。下面这段简化示例展示了使用 epoll 实现 Reactor 的基本工作流程：

int epfd = epoll_create1(0);
if (epfd == -1) {
    perror("epoll_create1");
    exit(EXIT_FAILURE);
}
struct epoll_event event, events[MAX_EVENTS];
// 设置事件
event.events = EPOLLIN | EPOLLET;
event.data.fd = STDIN_FILENO;
if (epoll_ctl(epfd, EPOLL_CTL_ADD, STDIN_FILENO, &event) == -1) {
    perror("epoll_ctl");
    exit(EXIT_FAILURE);
}
// 事件循环
while (1) {
    int nfds = epoll_wait(epfd, events, MAX_EVENTS, -1);
    if (nfds == -1) {
        perror("epoll_wait");
        exit(EXIT_FAILURE);
    }
    for (int n = 0; n < nfds; ++n) {
        if (events[n].events & EPOLLIN) {
            handle_read(events[n].data.fd);
        }
    }
}
close(epfd);
return 0;

1. 创建 epoll 实例

int epfd = epoll_create1(0);
if (epfd == -1) {
    perror("epoll_create1");
    exit(EXIT_FAILURE);
}

epoll_create1(0) 创建一个新的 epoll 实例，并返回文件描述符 epfd。
如果创建失败，就打印错误并退出。

2. 准备事件结构

struct epoll_event event, events[MAX_EVENTS];

struct epoll_event 是 epoll 的基本事件结构。
events 数组用于接收 epoll_wait 返回的事件结果。

3. 注册要监听的事件

event.events = EPOLLIN | EPOLLET;
event.data.fd = STDIN_FILENO;
if (epoll_ctl(epfd, EPOLL_CTL_ADD, STDIN_FILENO, &event) == -1) {
    perror("epoll_ctl");
    exit(EXIT_FAILURE);
}

EPOLLIN 表示监听可读事件。
EPOLLET 表示使用边缘触发（Edge Triggered）模式，也就是只在状态变化时收到通知。
event.data.fd = STDIN_FILENO 表示这里监听的是标准输入；实际网络程序中，通常会换成客户端连接对应的文件描述符。
epoll_ctl 用于把这个监听对象加入 epoll 实例。

4. 进入事件循环

while (1) {
    int nfds = epoll_wait(epfd, events, MAX_EVENTS, -1);
    if (nfds == -1) {
        perror("epoll_wait");
        exit(EXIT_FAILURE);
    }
    for (int n = 0; n < nfds; ++n) {
        if (events[n].events & EPOLLIN) {
            handle_read(events[n].data.fd);
        }
    }
}