总结一下ae处理框架： 处理IO事件的一些感悟： 1. 创建eventloop（这个地方还没有建立socket服务器监听）(initServer->aeCreateEventLoop) 2. 然后接着使用listenToPort将所有需要监听的端口进行socket建立以及bind，然后listen。（initServer->listenToPort->anetTcpServer->_anetTcpServer->anetListen）将普通的监听fd放在server.ipfd，将tls的监听fd放在server.tlsfd 2. 有了这个监听的fd，就得注册到IO多路复用的事件集合中，让后续client可以连接，（initServer->createSocketAcceptHandler(记住这个地方传入了回调函数acceptTcpHandler，当有客户端连接以后，调的就是它)->aeCreateFileEvent->aeApiAddEvent(底层添加事件的调用)）。 3. 把这个监听的scoket放进去，我们就等着连接事件的到来，main函数已经启动的时候调用了aeMain函数，一直在循环监听（main->aeMain->aeProcessEvents->aeApiPoll->(这里如果有事件，就会调用事件回调，rfileProc or wfileProc， 这两个函数是FilteEvent的回调函数注册，刚才的acceptTcpHandler就注册在这个上面了)）当我们收到客户端监听事件以后，开始在accpetTcpHandler处理任务了。 4. （acceptTcpHandler->anetTcpAccept(这个函数玩命把这个监听的socket accept一下，然后就返回了我们想要的conn fd叫cfd)->acceptCommonHandler）。 5. 第四步，最后一个函数就开始处理我们这个链接的cfd的事件注册，重点在调用这个函数createClient，从这函数瞅了半天，发现没有createFileEvent，原来在connSetReadHandler这里，老牛逼了，这些读写事件都被提前注册在conn这个实例里面了，叫type的这个变量。到了connSetReadHandler这个函数里面，那就是该注册连接的cfd了，然后你看到，这个函数传入了readQueryFromClient（这个回调，意思是说，如果这个fd被触发了，那么我们就调它么？显然你从conn中得知，不是的，很遗憾，那么是啥呢，你得乖乖看CT_Socket这个变量，这个玩意就是初始化给了conn的type，然后connSetReadHandler这个函数调用的就是connSocketSetReadHandler它，隐藏在CT_Socket这里面，妈呀，挺绕的。），那么接下来我们看看connSocketSetReadHandler这个函数里面到底干了个啥，不就是注册个fd的事件么，至于这么麻烦么，进去一看，发现真有aeCreateFileEvent，果然，不负真心，上面说的传入的readQueryFromClient，不是fd被触发以后的回调，是因为aeCreateFileEvent这个里面传入的是connSocketEventHandler这个回调，也就是说，我们在后续创建conn以后的读写事件都是在connSocketEventHandler这个函数调用的。 6. 那么我们假设现在已经有了一个连接的事件，客户端发来一条消息，那么就会触发这个cfd，进而回调在这个函数上，进去探探，搞了半天，里面就调了一个conn的读事件，和写事件（还有那个屏障，写法也是牛逼，这个函数可以理解为proxy，触发的是上层注册进来的读事件或者写事件，就是第五步，注册在conn里面的read_handler or write_handler），还得看函数readQueryFromClient，将数据读取，然后放在client里面，然后processInputBuffer处理实际的命令请求，processCommandAndResetClient->processCommand(各种reject不符合条件的命令)->call(核心了)。 7. 重点来了，c->cmd->proc(c); call的一行调用，看struct redisCommand的定义，注册在server.c的redisCommandTable（查找命令：c->cmd = c->lastcmd = lookupCommand(c->argv[0]->ptr); 在processCommand这个函数的某一行）。 8. 我们把它串起来了。 备注：本人走读的代码都是最新版本，望知。细节慢慢在补充吧。

感谢老师的文章，一样首先回答老师的问题：Redis事件驱动框架是如何区分文件的？ 答： 首先，观察可以发现这几份文件都是命名了相同的代码名字和结构体，例如都有aeApiState结构体，都有aeApiCreate，aeApiResize，aeApiAddEvent，aeApiPoll等方法，那么这里就可以发现其实无论我们使用那一份文件，都不会对调用方造成影响，其次我们观察发现在ae.c文件头部中有这样一段代码： #ifdef HAVE_EVPORT #include "ae_evport.c" #else #ifdef HAVE_EPOLL #include "ae_epoll.c" #else #ifdef HAVE_KQUEUE #include "ae_kqueue.c" #else #include "ae_select.c" #endif #endif #endif 这段代码大致就是根据当前操作系统类型来决定使用那一份头文件，而对操作系统识别在config.h这份文件中，主要划分了（HAVE_EVPORT，HAVE_EPOLL，HAVE_KQUEUE，和默认ae_select.c）这四种类型，所以大致逻辑如下： 1、config.h中确定当前操作系统类型并打上标记 2、通过标记选择对应的IO复用文件ae_xxxx.c 3、编译期间使用对应的文件进行编译 4、通过统一实现的方法调用例如：aeApiPoll 所以从这里也能看出，如果我们想强行选择select这种方式进行IO多路复用，可以直接修改ae.c上面的这段宏定义 最后顺便拓展一下本篇文章外的内容，本篇文章除了老师提到的事件驱动框架的核心方法外，老师还提到了几个方法，我个人觉得也比较重要可以深度阅读一下其在Redis项目中出现的位置和实现： 1、readQueryFromClient 2、beforeSleep 3、handleClientsWithPendingWrites 4、writeToClient 原因： 1、readQueryFromClient主要是和querybuf打交道（对应读事件），里面涉及到RESP编解码可以深度阅读一下（个人发现Redis处理粘包拆包的方式很独特）。 2、beforeSleep和afterSleep是搭配的（在aeMain的大循环中每次都被调用），通过这两个钩子函数Redis实现了很多主干路的功能，和一些分治思想的功能。 3、handleClientsWithPendingWrites可以关注一下其调用方handleClientsWithPendingWritesUsingThreads函数，在这两个方法中都要调用writeToClient方法（对应写事件），而在他们中通过一种巧妙的方式实现了Redis6 IO多线程的方案（可以先预习），handleClientsWithPendingWrites是在只有一个线程或者禁用IO线程的时候使用的。

通过不同的操作系统，include不同的头文件。 在ae.c中 /* Include the best multiplexing layer supported by this system. * The following should be ordered by performances, descending. */ #ifdef HAVE_EVPORT #include "ae_evport.c" #else #ifdef HAVE_EPOLL #include "ae_epoll.c" #else #ifdef HAVE_KQUEUE #include "ae_kqueue.c" #else #include "ae_select.c" #endif #endif #endif 在config.h中，根据操作系统，设置相关的值 /* Test for polling API */ #ifdef __linux__ #define HAVE_EPOLL 1 #endif #if (defined(__APPLE__) && defined(MAC_OS_X_VERSION_10_6)) || defined(__FreeBSD__) || defined(__OpenBSD__) || defined (__NetBSD__) #define HAVE_KQUEUE 1 #endif #ifdef __sun #include <sys/feature_tests.h> #ifdef _DTRACE_VERSION #define HAVE_EVPORT 1 #endif #endif