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;
参考博客
事件处理机制
[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