Reactor反应堆-北京尧图网络

在 Linux 环境中，reactor 指的是一种基于 I/O 多路复用的事件驱动设计模式，其核心思想是通过一个专门的组件（反应器）监听多个 I/O 事件（如网络连接、数据读写等），当事件发生时触发对应的回调函数进行处理，从而让单个进程或线程能高效处理大量并发连接，避免传统阻塞 I/O 中因等待而造成的资源浪费。它通常依赖 Linux 的 select、poll 或 epoll 等系统调用来实现事件监听，常见于高性能网络服务器开发，比如通过 libevent、libev 等库来快速构建基于 reactor 模式的应用，以应对高并发场景下的 I/O 处理需求。在多进程线程中，write更简单。LT:只要可写就持续通知，有剩余空间ET:仅在缓冲区从满变为不满时通知一次把一个sockfd托管给select，poll，epoll原因是因为sockfd上事件没有就绪，用托管来提高效率。默认sockfd新建的情况下，读事件默认不是就绪的，因为输入缓冲区没有数据，所以默认添加epoll。而写事件是就绪的，因为输出缓冲区本来就有空间，所以，在前期，我们可以直接写，但是到了后期输出缓冲区可能会满，那时才需要epoll监听。对于写，我们直接发，发送条件不满足，开启写事件关心，后续剩余的数据，epoll会协助我自动进行发送。补充细节：1.如果我们开头直接对一个sockfd设置写关心，epoll就会立即就绪。2.未来我全部发完了，就要对关闭这个fd写事件关心3.如果写缓冲区没满，数据也发完了，我们就不用开启对写事件关心。4.直接发，我怎么知道写入条件不满足了呢，errno是EAGAIN即可。所以，对写事件关心最好是ET非阻塞。LT阻塞根本发挥不了作用，LT非阻塞与ET差不多。以上是用单进程+epoll+非阻塞实现的，下面是加入多线程和多进程的思路。主reactor线程+工作者线程池#include sys/epoll.h #include pthread.h #include fcntl.h #include unistd.h // 线程安全的任务队列 struct task_queue_t { // ... 使用互斥锁(pthread_mutex_t)和条件变量(pthread_cond_t)实现 }; void* reactor_thread(void* arg) { int epoll_fd = epoll_create1(0); int listen_fd; // 已初始化的监听socket struct epoll_event event, events[MAX_EVENTS]; // 将listen_fd加入epoll event.events = EPOLLIN; event.data.fd = listen_fd; epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listen_fd, event); while (1) { int nfds = epoll_wait(epoll_fd, events, MAX_EVENTS, -1); for (int i = 0; i nfds; ++i) { if (events[i].data.fd == listen_fd) { // 处理新连接 int conn_fd = accept4(listen_fd, NULL, NULL, SOCK_NONBLOCK); event.events = EPOLLIN | EPOLLET; // 边缘触发模式 event.data.fd = conn_fd; epoll_ctl(epoll_fd, EPOLL_CTL_ADD, conn_fd, event); } else if (events[i].events EPOLLIN) { // 数据可读 int conn_fd = events[i].data.fd; char buffer[BUFFER_SIZE]; ssize_t count = read(conn_fd, buffer, BUFFER_SIZE); if (count 0) { // 封装任务，推送给工作者线程池 task_t* task = create_task(conn_fd, buffer, count); task_queue_push(global_task_queue, task); } } // ... 处理 EPOLLOUT, EPOLLHUP 等事件 } } } void* worker_threa

Reactor反应堆

相关推荐

GPT_Vuln-analyzer GEO-IP地理定位实战：一键查询IP归属地、ISP与时区信息

【AI大模型】235B参数，119种语言，Qwen3却连“Strawberrrrry“都数不清？

【AI大模型】深入理解Token与分词器：Transformer学习的关键突破

更多资讯

怎么考水电工证的，外省证能转过来吗？报名流程全解析

新疆电工证在哪里查询多少钱？学历不高也能报名的实操指南

电工证掉了只要有编号怎么补救？官方报名入口在这儿

电工证多久能查考在外省的证千万别踩坑

电工证的其他用途你知道还能干啥吗？通过率揭秘

弱电有电工证吗保姆级教程：工地太忙根本没时间复习考试怎么办

今日更新

特种工指挥考试题库怎么刷才不会白交培训费？官方报名入口在这！

电工证考试多少分合格在哪考别再交冤枉钱了

福清应急管理局电工证真实经历：工地太忙根本没时间复习考试怎么办

本周精选

安监局电工证分数查询怎么查才能知道含金量高不高

新疆电工作业干活累吗良心建议助你避开考不过的坑

中牟县电工证怎么报名外省证能转吗

本月热门

面向复杂光照与角度的宠物面部识别鲁棒性增强策略

基于DRV8818与STM32的双极步进电机驱动方案实战解析

DRV8818PWPR+PIC18F45K80双极步进电机控制方案实战

读完文章，想聊聊您的网站？