Redis事件

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

事件结构定义

//redis事件结构定义
/* 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;
    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;
    int flags;
} aeEventLoop;

文件事件

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

文件事件结构定义

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

文件事件处理流程

时间事件

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

过期Key删除
持久化
渐进式rehash
客户端超时处理
一些统计相关工作
集群相关操作和failover

时间事件结构定义

/* Time event structure */
typedef struct aeTimeEvent {
    long long id; /* time event identifier. */
    monotime when;
    aeTimeProc *timeProc;
    aeEventFinalizerProc *finalizerProc;
    void *clientData;
    struct aeTimeEvent *prev;
    struct aeTimeEvent *next;
    int refcount; /* refcount to prevent timer events from being
  		   * freed in recursive time event calls. */
} 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个以上核心不会有更大的帮助了！???????