首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 其他教程 > 开源软件 >

《Redis源码学习札记》事件库

2013-09-16 
《Redis源码学习笔记》事件库Redis没有使用第三方事件库来处理socket(譬如Libevent),而是自己实现了一个非常

《Redis源码学习笔记》事件库
Redis没有使用第三方事件库来处理socket(譬如Libevent),而是自己实现了一个非常精巧的事件库(加上注释不到600行代码),这使得我们可以更加专注于Redis本身代码的阅读,而不必陷于三方库的学习和使用(我自己就是因为该原因选择学习Redis而不是memcache);同时阅读Redis自带的事件库也可以让我们一窥类似Libevent这样的事件库内部实现机制;

Redis事件库中的所有函数几乎都是以ae开头(原因不得而知),其中最重要的就是aeEventLoop对象,它充当着“事件处理器”角色:


其中“文件事件”是一个数组,存放当前Redis所有连接的客户端描述符,而“时间事件”则是一个链表,用来存放计划任务;

事件处理器循环流程(由于图片较大,缩放较为模糊,请双击打开查看原图):


整个执行流程的伪代码:

def aeMain(aeEventLoop):# 开始事件循环while (not aeEventLoop.stop):aeProcessEvents(aeEventLoop, AE_ALL_EVENTS)def aeProcessEvents(aeEventLoop, flags):# 是否需要处理时间事件    if flags & AE_TIME_EVENTS:    # 获取最近一个即将到达的时间事件        arrived_time = aeEventLoop.timeEvents.getNearestArrivedTime()        if (arrived_time < now_time):        # 若最近一个时间事件的arrived_time小于当前时间(说明需要立即执行),则设置文件事件为非阻塞            tvp.sec = 0             tvp.usec = 0         else:        # 否则取两者的时间间隔,作为文件事件的最大阻塞时间            tvp.sec = arrived_time.sec - now_time.sec            tvp.usec = arrived_time.usec - now_time.usec     else    # 文件事件是否阻塞        if flags & AE_DONT_WAIT:            tvp.sec = 0             tvp.usec = 0         else :            tvp = null     # 处理文件事件(IO多路复用)    # 若此时没有描述符就绪,tvp的值决定阻塞行为(立即返回?阻塞一段时间?一直阻塞下去?)    aeEventLoop.fileEvents.poll(tvp)    # 处理达到的时间事件    if (flags & AE_TIME_EVENTS):         aeEventLoop.timeEvents.processArrived()                                                                                                                       


总结:
1.了解事件库运行流程;


热点排行