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

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

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

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

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

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

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