【Linux 实战 - 25】Reactor 事件驱动模型原理与实现

在高并发网络编程中如何高效处理成千上万的连接是核心挑战。Reactor反应器模式作为一种经典的事件驱动设计模式通过 I/O 多路复用技术实现了单线程或多线程高效处理多连接的目标被广泛应用于 Nginx、Redis、Netty 等高性能网络框架中。一、什么是 Reactor 模式Reactor 模式是一种基于事件驱动的并发处理模式其核心思想是将 I/O 事件的监听、分发与业务处理解耦通过I/O 多路复用如 epoll、select监听多个文件描述符fd的事件当事件就绪时将其分发给对应的事件处理器Handler执行。传统多线程模型 vs Reactor 模型传统多线程模型每个连接创建一个线程资源消耗大并发上限低。Reactor 模型单线程或线程池通过 I/O 多路复用监听多连接事件就绪时才处理资源利用率高。二、Reactor 的核心组件Reactor 模式由 5 个关键部分组成组件作用Event Loop事件循环持续调用 I/O 多路复用器监听事件分发事件给处理器。DemultiplexerI/O 多路复用器如 epoll、select监听多个 fd 的读写事件。Event Handler事件处理器接口定义事件处理方法如handle_read()、handle_write()。Concrete Handler具体事件处理器实现 Event Handler 接口处理实际业务逻辑。Acceptor特殊的事件处理器处理新连接的建立accept并注册新 fd 到 Reactor。三、Reactor 的工作原理单线程版单线程 Reactor 是最基础的实现其工作流程如下初始化创建 Reactor、注册 Acceptor监听 socket 的读事件。事件循环调用epoll_wait()阻塞等待事件就绪。若就绪事件是新连接Acceptor 调用accept()建立连接将新 fd 注册到 Reactor。若就绪事件是数据可读 / 可写分发给对应的 Concrete Handler 处理。业务处理Handler 执行handle_read()读取数据、处理业务必要时注册写事件。四、基于 epoll 的 Reactor 实现C 语言示例以下是一个简化的单线程 Reactor 实现使用 epoll 作为 I/O 多路复用器支持 TCP 连接的建立与数据回显。1. 核心数据结构#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include sys/epoll.h #define MAX_EVENTS 1024 #define BUFFER_SIZE 1024 // 事件处理器接口 typedef struct EventHandler { int fd; void (*handle_read)(struct EventHandler *self); void (*handle_write)(struct EventHandler *self); char buffer[BUFFER_SIZE]; int buffer_len; } EventHandler; // Reactor结构体 typedef struct Reactor { int epoll_fd; struct epoll_event events[MAX_EVENTS]; EventHandler *handlers[MAX_EVENTS]; // 存储fd对应的处理器 } Reactor;2. Reactor 初始化与事件注册// 创建Reactor Reactor *reactor_create() { Reactor *reactor (Reactor *)malloc(sizeof(Reactor)); reactor-epoll_fd epoll_create1(0); memset(reactor-handlers, 0, sizeof(reactor-handlers)); return reactor; } // 注册事件到Reactor void reactor_register(Reactor *reactor, int fd, EventHandler *handler, uint32_t events) { struct epoll_event ev; ev.events events; ev.data.fd fd; epoll_ctl(reactor-epoll_fd, EPOLL_CTL_ADD, fd, ev); reactor-handlers[fd] handler; } // 事件循环 void reactor_run(Reactor *reactor) { while (1) { int n epoll_wait(reactor-epoll_fd, reactor-events, MAX_EVENTS, -1); for (int i 0; i n; i) { int fd reactor-events[i].data.fd; EventHandler *handler reactor-handlers[fd]; if (reactor-events[i].events EPOLLIN) { handler-handle_read(handler); // 处理读事件 } if (reactor-events[i].events EPOLLOUT) { handler-handle_write(handler); // 处理写事件 } } } }3. 具体事件处理器回显服务// 处理读事件回显数据 void echo_handle_read(EventHandler *self) { int n read(self-fd, self-buffer, BUFFER_SIZE); if (n 0) { close(self-fd); free(self); return; } self-buffer_len n; // 注册写事件准备回显数据 struct epoll_event ev; ev.events EPOLLOUT; ev.data.fd self-fd; epoll_ctl(epoll_fd, EPOLL_CTL_MOD, self-fd, ev); } // 处理写事件发送回显数据 void echo_handle_write(EventHandler *self) { write(self-fd, self-buffer, self-buffer_len); // 重新注册读事件 struct epoll_event ev; ev.events EPOLLIN; ev.data.fd self-fd; epoll_ctl(epoll_fd, EPOLL_CTL_MOD, self-fd, ev); } // 创建回显处理器 EventHandler *echo_handler_create(int fd) { EventHandler *handler (EventHandler *)malloc(sizeof(EventHandler)); handler-fd fd; handler-handle_read echo_handle_read; handler-handle_write echo_handle_write; return handler; }4. Acceptor处理新连接void acceptor_handle_read(EventHandler *self) { struct sockaddr_in client_addr; socklen_t client_len sizeof(client_addr); int client_fd accept(self-fd, (struct sockaddr *)client_addr, client_len); // 创建回显处理器并注册到Reactor EventHandler *echo_handler echo_handler_create(client_fd); reactor_register(reactor, client_fd, echo_handler, EPOLLIN); } // 创建Acceptor EventHandler *acceptor_create(int listen_fd) { EventHandler *handler (EventHandler *)malloc(sizeof(EventHandler)); handler-fd listen_fd; handler-handle_read acceptor_handle_read; return handler; }5. 主函数int main() { // 创建监听socket int listen_fd socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_addr.s_addr htonl(INADDR_ANY); server_addr.sin_port htons(8080); bind(listen_fd, (struct sockaddr *)server_addr, sizeof(server_addr)); listen(listen_fd, 10); // 创建Reactor并注册Acceptor Reactor *reactor reactor_create(); EventHandler *acceptor acceptor_create(listen_fd); reactor_register(reactor, listen_fd, acceptor, EPOLLIN); // 运行事件循环 reactor_run(reactor); return 0; }五、Reactor 模式的优缺点优点高并发单线程处理多连接避免线程切换开销。解耦事件监听、分发与业务处理分离代码结构清晰。扩展性可通过多线程 Reactor主从 Reactor进一步提升性能。缺点单线程瓶颈若 Handler 处理耗时过长如 CPU 密集型任务会阻塞整个事件循环。依赖 I/O 多路复用需结合 epoll/kqueue 等系统调用跨平台性略差。六、总结Reactor 模式是高性能网络编程的基石通过事件驱动 I/O 多路复用实现了高效的并发处理。在实际应用中可根据需求选择单线程 Reactor适用于连接数少、业务逻辑简单的场景如 Redis。多线程 Reactor主 Reactor 处理连接从 Reactor 处理读写如 Netty。掌握 Reactor 模式是深入理解 Linux 网络编程与高性能框架的关键一步。下篇预告【Linux 实战 - 26】轻量级 HTTP 服务器原理与 C 语言 Socket 实现原创不易如果本文对你有帮助欢迎点赞、收藏、关注三连有任何问题都可以在评论区留言我会及时回复。