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

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
THE END
分享
二维码
< <上一篇
下一篇>>