《Redis官方文档》Redis事件库-阿里云开发者社区

开发者社区> 青衫无名> 正文

《Redis官方文档》Redis事件库

简介:
+关注继续查看

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

事件循环初始化

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

1 aeEventLoop *el

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

01 typedef struct aeEventLoop
02 {
03     int maxfd;
04     long long timeEventNextId;
05     aeFileEvent events[AE_SETSIZE]; /* 已经注册的事件 */
06     aeFiredEvent fired[AE_SETSIZE]; /* 已经就绪的事件 */
07     aeTimeEvent *timeEventHead;
08     int stop;
09     void *apidata; /* 这是polling API使用的专有数据 */
10     aeBeforeSleepProc *beforesleep;
11 } aeEventLoop;

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 /*eventLoop*/, 1 /*milliseconds*/, serverCron /*proc*/, NULL /*clientData*/, NULL /*finalizerProc*/);

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 (aeCreateFileEvent(server.el, c->fd, AE_READABLE,
2     readQueryFromClient, c) == AE_ERR) {
3     freeClient(c);
4     return NULL;
5 }

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循环会在下次迭代中继续处理定时事件。
就这些了。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Android官方开发文档Training系列课程中文版:OpenGL绘图之响应触摸事件
原文地址:http://android.xsoftlab.net/training/graphics/opengl/touch.html 使图形按照程序设计的轨迹旋转对OpenGL来说还是不能发挥出它应有的实力。
854 0
ActiveReports 报表控件官方中文入门教程 (1)-安装、激活以及产品资源
原文:ActiveReports 报表控件官方中文入门教程 (1)-安装、激活以及产品资源 本系列文章主要是面向初次接触 ActiveReports 产品的用户,可以帮助您在三天之内轻松的掌握ActiveReports控件的基本使用方法,包括安装、激活、创建报表、绑定数据源以及发布等内容。
960 0
Android官方开发文档Training系列课程中文版:管理音频播放之音频输出硬件的处理
原文地址:http://android.xsoftlab.net/training/managing-audio/audio-output.html 当用户使用Android设备享受音频时,它有多重的可选择替代方案。
730 0
+关注
3598
文章
840
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载