源码分析版本：4.0.1

文件结构

redis的网络通信模块由8个文件构成

作用如下

统一网络库底层接口

被统一的网络事件处理接口如下，参考：ae_epoll.c, ae_evport.c, ae_kqueue.c,ae_select.c

#统一网络库上层接口
参考 ae.h, ae.c，封装通用的结构体和函数

网络读写事件aeFileEvent结构体

/* File event structure */
typedef struct aeFileEvent {
    int mask; /* one of AE_(READABLE|WRITABLE) */
    aeFileProc *rfileProc;
    aeFileProc *wfileProc;
    void *clientData;
} aeFileEvent;
1
2
3
4
5
6
7

这个结构体封装了网络数据读写事件的处理函数原型，和客户端传过来的数据。
aeFileProc是处理函数的原型的宏定义，宏定义参考如下：

typedef void aeFileProc(
    struct aeEventLoop *eventLoop,
    int fd,
    void *clientData,
    int mask
);
1
2
3
4
5
6

实际使用时，网络读写事件的函数处理需要自行编写

定时事件aeTimeEvent结构体

/* 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 *next;
} aeTimeEvent;
1
2
3
4
5
6
7
8
9
10

这个定时事件是redis用来处理后台定时任务使用的，比如处理客户端连接超时，服务端断开操作活跃的fd

/* A fired event */
typedef struct aeFiredEvent {
    int fd;
    int mask;
} aeFiredEvent;
1
2
3
4
5

就是正在等待读、正在等待写的网络fd，一般以一个数组出现
mask字段表示是等待读，还是等待写，对应的值如下

#define AE_READABLE 1
#define AE_WRITABLE 2
1
2

网络库上层接口核心结构体aeEventLoop

/* 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
2
3
4
5
6
7
8
9
10
11
12
13
14

操作aeEventLoop相关函数

主要是对aeEventLoop结构体进行操作，这里拿几个核心的函数举例

aeCreateEventLoop()

这个函数主要是创建aeEventLoop结构体，并根据setsize参数给events, fired分配内容空间然后再调用aeApiCreate驱动底层的网络库，比如epoll的epoll_create()，然后保存到aeEventLoop的apidata属性上

aeMain()

主要是启动无限循环、轮询处理活跃的fd，如果epoll，底层则调用epoll_wait获取可读写的fd：ae.c::aeMain() -> ae.c::aeProcessEvents() -> ae_epoll.c::aeApiPool() -> ae_epoll.c::epoll_wait()

aeCeateFileEvent()

注册网络fd到底层网络库上，并注册当读写事件发生时，需要执行的业务回调函数拿epoll举例，调用到epoll经过的步骤：ae.c::aeCreateFileEvent() -> ae_epoll.c::aeApiAddEvent() -> epoll_ctl()

anet.h & anet.c

主要是封装socket操作，屏蔽系统底层socket操作的差异性，提供更好用的api，比如创建tcp server等

这里就拿创建tcp server来看看它的流程

anetTcpServer()

anet.c::anetTcpServer() -> anet.c::_anetTcpServer() -> ::socket() -> anet.c::anetListen() -> ::listen()
核心代码就是调用系统socket库的listen函数建立起了一个tcp的server

参考资料：

http://qiankunli.github.io/2018/06/15/redis.html
https://juejin.cn/post/6844903909387927560