Redis源码阅读(三)- 事件模型

Redis源码阅读(三)- 事件模型

目录

Redis事件

文件事件

文件事件结构定义

文件事件处理流程

时间事件

时间事件结构定义

事件处理过程

Redis事件处理流程

Redis6多线程

开启IO多线程

总结

---

Redis事件

        Redis是一个基于事件驱动的服务模型，内部抽象为两种事件类型：文件事件、时间事件。

事件结构定义

//redis事件结构定义

typedef struct aeEventLoop {
    int maxfd;   
    int setsize; 
    long long timeEventNextId;
    aeFileEvent *events; 
    aeFiredEvent *fired; 
    aeTimeEvent *timeEventHead;
    int stop;
    void *apidata; 
    aeBeforeSleepProc *beforesleep;
    aeBeforeSleepProc *aftersleep;
    int flags;
} aeEventLoop;

文件事件

        文件事件是Redis对网络处理的抽象。Redis基于IO多路复用模型，也就是我们经常说的nio，当有网络请求是会产生对应的事件，Redis监听到事件产生后开始处理网络请求，如没有网络请求则阻塞当前线程一段时间，这里调用系统的epoll_wait方法实现。

文件事件结构定义

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

文件事件处理流程

时间事件

         时间事件是Redis对定时任务的抽象，定时任务每100ms执行一次，定时任务处理函数为：serverCron。Redis定时任务主要包括但不限定于以下工作：

过期Key删除持久化渐进式rehash客户端超时处理一些统计相关工作集群相关 *** 作和failover 时间事件结构定义

typedef struct aeTimeEvent {
    long long id; 
    monotime when;
    aeTimeProc *timeProc;
    aeEventFinalizerProc *finalizerProc;
    void *clientData;
    struct aeTimeEvent *prev;
    struct aeTimeEvent *next;
    int refcount; 
} aeTimeEvent;

事件处理过程

        众所周知，Redis是单线程模型，所以Redis的时间事件和文件事件是串行处理的。所以Redis最怕的就是阻塞，如果有命令阻塞Redis的主线程，可能会导致超时统计延后，也就是假死的情况，对服务的影响是非常严重的！

Redis事件处理流程

Redis 6多线程

        Redis 6提供了IO多线程的新特性，这里需要注意IO多线程并不是完全的多线程，核心 *** 作还是单线程执行的。由于Redis是纯内存 *** 作，所以Redis的命令执行是非常快的，但IO *** 作占了大部分的CPU时间，多线程的 *** 作主要针对IO *** 作，客户端Read，Write放到多线程中执行，大致流程如下：

开启IO多线程

        IO多线程的特性是默认关闭的，可以通过参数：io-threads-do-reads开启IO多线程，通过参数：io-threads设置IO线程数。官方给出的建议是至少有4个以上核心才建议开启该特性，如果有4个核心建议设置2-3个IO线程，8个核心设置6个IO线程，需要注意的是核心数并不是越多越好，8个以上核心不会有更大的帮助了！       

总结

        Redis使用非阻塞的事件模型，保证了单线程的处理效率。使用时要避免长命令阻塞主线程的问题。

        另外，关于是否开启多线程的特性，我个人是这么理解的，当前内存越来越便宜的前提下，如果你有更多的核心，开启多实例是不是更好的选择？如果你的数据不可分，只能单实例部署，那么IO多线程确实能发挥一定的多核优势！