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

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的各种定时任务

文件事件定义

/* File event structure */typedef struct aeFileEvent { int mask; /* one of AE_(READABLE|WRITABLE|BARRIER) */ aeFileProc *rfileProc; aeFileProc *wfileProc; void *clientData;} aeFileEvent;

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

/* Time event structure */typedef struct aeTimeEvent { long long id; /* time event identifier. */ long when_sec; /* seconds */ long when_ms; /* milliseconds */ aeTimeProc *timeProc; aeEventFinalizerProc *finalizerProc; void *clientData; struct aeTimeEvent *prev; struct aeTimeEvent *next;} aeTimeEvent;

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

/* State of an event based program */typedef struct aeEventLoop { int maxfd; /* highest file descriptor currently registered */ int setsize; /* max number of file descriptors tracked */ long long timeEventNextId; time_t lastTime; /* Used to detect system clock skew */ // 文件事件数组 aeFileEvent *events; /* Registered events */ // 已就绪的文件事件 aeFiredEvent *fired; /* Fired events */ // 时间事件链表头 aeTimeEvent *timeEventHead; int stop; void *apidata; /* This is used for polling API specific data */ // 进入事件循环前执行的函数 aeBeforeSleepProc *beforesleep; // 退出事件循环后执行的函数 aeBeforeSleepProc *aftersleep;} aeEventLoop;

参考博客

事件处理机制 [2]好文章 [3]https://zhuanlan.zhihu.com/p/24305679

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。