Redis源码解析：事件驱动框架

介绍

为了高效的处理网络请求，演化出了Reactor模型。

Reactor模型主要有reactor，acceptor，handler三种角色

reactor：分配事件
acceptor：建立连接
handler：处理请求

单Reactor单线程

accept->read->处理业务逻辑->write 在一个线程

单Reactor多线程

accept，read，write复用一个线程
处理请求用一个工作线程池

主从Reactor多线程

accpet复用一个线程
read write复用一个线程
处理请求用一个工作线程池

事件驱动

Redis主要处理如下两类事件
文件事件：client发起新连接，client向server写数据，server向client响应数据
时间事件：redis的各种定时任务

文件事件定义

typedef struct aeFileEvent { int mask; aeFileProc *rfileProc; aeFileProc *wfileProc; void *clientData;} aeFileEvent;

mask：用来标识事件类型，主要有AE_READABLE、AE_WRITABLE 和 AE_BARRIER 三种类型事件
rfileProc：AE_READABLE事件的处理函数
wfileProc：AE_WRITABLE事件的处理函数
clientData：指向客户端的私有数据

typedef struct aeTimeEvent { long long id; long when_sec; long when_ms; aeTimeProc *timeProc; aeEventFinalizerProc *finalizerProc; void *clientData; struct aeTimeEvent *prev; struct aeTimeEvent *next;} aeTimeEvent;

id：时间事件id
when_sec：事件到达的秒级时间戳
when_ms：事件到达的毫秒级时间戳
timeProc：时间事件触发后的处理函数
finalizerProc：事件结束后的处理函数
clientData：事件相关的私有数据
prev：链表前向指针
next：链表后向指针

typedef struct aeEventLoop { int maxfd; int setsize; long long timeEventNextId; time_t lastTime; // 文件事件数组 aeFileEvent *events; // 已就绪的文件事件 aeFiredEvent *fired; // 时间事件链表头 aeTimeEvent *timeEventHead; int stop; void *apidata; // 进入事件循环前执行的函数 aeBeforeSleepProc *beforesleep; // 退出事件循环后执行的函数 aeBeforeSleepProc *aftersleep;} aeEventLoop;

参考博客

事件处理机制
[1]https://www.cnblogs.com/gqtcgq/p/7247058.html
[2]https://mcgrady-forever.github.io/2018/02/10/redis-analysis-eventhanding/
好文章
[3]https://zhuanlan.zhihu.com/p/24305679