*Reids 事件库

Redis实现了自己的事件库,代码在ae.c中。想要理解Redis事件库的工作原理,最好的方法就是去理解Redis如何使用它。

*事件循环初始化

redis.c中的initServer函数初始化了redisServer结构体变量的众多成员,其中一个就是Redis事件循环(event loop)el


1 aeEventLoop *el{.plain}


initServer调用aeCreateEventLoop(定义在ae.c)初始化server.el的成员。aeEventLoop的定义如下:


01 typedef{.keyword .bold} struct{.keyword .bold} aeEventLoop{.plain}



02 {{.plain}



03     {.spaces}int{.color1 .bold} maxfd;{.plain}



04     {.spaces}long{.color1 .bold} long{.color1 .bold} timeEventNextId;{.plain}



05     {.spaces}aeFileEvent events[AE_SETSIZE]; {.plain}/* 已经注册的事件 */{.comments}



06     {.spaces}aeFiredEvent fired[AE_SETSIZE]; {.plain}/* 已经就绪的事件 */{.comments}



07     {.spaces}aeTimeEvent *timeEventHead;{.plain}



08     {.spaces}int{.color1 .bold} stop;{.plain}



09     {.spaces}void{.keyword .bold} *apidata; {.plain}/* 这是polling API使用的专有数据 */{.comments}



10     {.spaces}aeBeforeSleepProc *beforesleep;{.plain}



11 } aeEventLoop;{.plain}


*aeCreateEventLoop

aeCreateEventLoop首先为aeEventLoop结构体分配内存,然后调用ae_epoll.c:aeApiCreate

aeApiCreate分配aeApiState的空间,它有两个成员:epfd保存epoll_create调用返回的epoll文件描述符,events是Linux epoll库中定义的epoll_event结构类型。后面会再介绍events的使用。

接下来是ae.c:aeCreateTimeEvent,但是在那之前,initServer会先调用anet.c:anetTcpServer创建一个监听描述符(listening descriptor),默认监听6379端口。返回的监听描述符保存在server.fd

*aeCreateTimeEvent

aeCreateTimeEvent接收如下参数:

  • eventLoop:即redis.c中的 server.el
  • milliseconds:从当前时间开始距离定时器过期的毫秒数。
  • proc:函数指针,保存了定时器过期后调用的函数地址。
  • clientData: 通常是NULL
  • finalizerProc:指向定时事件被移除前要调用的函数。

initServer调用aeCreateTimeEventserver.el中的timeEventHead成员添加一个定时事件,timeEventHead是指向定时事件链表的指针。如下是 redis.c:initServer函数中调用aeCreateTimeEvent的代码。


1 aeCreateTimeEvent(server.el {.plain}/*eventLoop*/{.comments}, 1 {.plain}/*milliseconds*/{.comments}, serverCron {.plain}/*proc*/{.comments}, NULL {.plain}/*clientData*/{.comments}, NULL {.plain}/*finalizerProc*/{.comments});{.plain}


redis.c:serverCron执行很多后台操作来保持Redis正常运转。

*aeCreateFileEvent

aeCreateFileEvent函数实质就是执行epoll_ctl系统调用,以将anetTcpServer创建的监听描述符增加到EPOLLIN事件队列,并将它和aeCreateEventLoop创建的epoll描述符相关联。

下面解释了 redis.c:initServer中调用aeCreateFileEvent具体做的工作。

initServer传递了如下参数给aeCreateFileEvent

  • server.elaeCreateEventLoop创建的事件循环,epoll描述符是从server.el里获取的。
  • server.fd监听描述符,作为从eventLoop->events中获取相关文件事件结构体的索引,结构体中存储了回调函数等信息。
  • AE_READABLE:表示必须监视server.fdEPOLLIN事件。
  • acceptHandler:当被监听的事件就绪时执行的函数,函数指针存储在eventLoop->events[server.fd]->rfileProc

以上完成了Redis事件循环的初始化。

*事件循环的处理

redis.c:main通过调用ae.c:aeMain来处理前一阶段初始化好的事件循环。

ae.c:aeMain在一个while循环中调用ae.c:aeProcessEvents来处理就绪的定时事件和文件事件。

*aeProcessEvents

ae.c:aeProcessEvents在事件循环上调用ae.c:aeSearchNearestTimer寻找最先要过期的定时事件。我们的示例中,事件循环里只有ae.c:aeCreateTimeEvent创建的一个定时事件(译者注:即前面调用ae.c:aeCreateTimeEvent使用的回调redis.c:serverCron

请记住,aeCreateTimeEvent创建的定时事件很可能已经过期了,因为过期时间只有1毫秒。定时器过期后,timeval结构体的tvp变量会把成员变量秒和毫秒都重置为0。

tvp结构体变量和事件循环变量作为参数传给了ae_epoll.c:aeApiPoll

aeApiPoll函数在epoll描述符上调用了epoll_wait,然后用下面内容填充 eventLoop->fired数组。

  • fd:准备好做读/写操作的描述符,操作类型取决于mask值。
  • mask:标识读/写事件可以在对应描述符上执行。(译者注:有读事件mask |= AE_READABLE,有写事件mask |= AE_WRITABLE

aeApiPoll返回已就绪事件的个数。来看个实际的例子,假设有客户端发起了连接请求,那么aeApiPoll将会注意到,使用监听描述符填充eventLoop->fired数组的描述符成员,把mask设为AE_READABLE

现在,aeProcessEvents调用redis.c:acceptHandler回调函数。acceptHandler监听描述符上执行accept,返回一个客户端连接描述符redis.c:createClient通过下面这样调用ae.c:aeCreateFileEvent,向连接描述符添加一个文件事件。


1 if{.keyword .bold} (aeCreateFileEvent(server.el, c->fd, AE_READABLE,{.plain}



2     {.spaces}readQueryFromClient, c) == AE_ERR) {{.plain}



3     {.spaces}freeClient(c);{.plain}



4     {.spaces}return{.keyword .bold} NULL;{.plain}



5 }{.plain}


credisClient结构体变量,c->fd是连接描述符。

然后,ae.c:aeProcessEvent调用ae.c:processTimeEvents

*processTimeEvents

ae.processTimeEvents从 eventLoop->timeEventHead开始,依次遍历链表上的定时事件。

对每个过期的定时事件,processTimeEvents调用相应的回调函数。这个示例只会调用唯一注册的定时事件回调函数redis.c:serverCron,回调函数返回的时间表示多少毫秒后它将被再次调用。返回的时间被ae.c:aeAddMilliSeconds记录下来,ae.c:aeMain中的while循环会在下次迭代中继续处理定时事件。

就这些了。