Redis 2.8.9源码 - ae模块

本文为作者原创,转载请注明出处:http://my.oschina.net/fuckphp/blog/505956

Redis 的 ae模块的代码主要分布在 ae.c ae.h 还有 ae_*.c 中,分别实现了epoll、evport、kqueue、select几种网络模型,本文将以epoll为例,对Redis的ae模块进行学习。

Redis ae.c 事件模块笔记

1.ae模块的核心结构

aeEventLoop

aeEveltLoop 主要定义描述了redis ae模块的主循环信息,在整个事件的循环周期内(aeEveltLoop.stop!=0),保存了io事件和时间事件的事件列表等信息。

typedef struct aeEventLoop {
    int maxfd;   /* 当前注册的最大描述符 */
    int setsize; /* 最大文件描述符个数 */
    long long timeEventNextId;  //自增id 用于给每个事件分配id
    time_t lastTime;     /* 用于校准系统时间,每次事件事件执行前更新该时间 */
    aeFileEvent *events; /* 存放注册的事件 */
    aeFiredEvent *fired; /* 已经触发的事件保存在这里 */
    aeTimeEvent *timeEventHead; /* 时间事件单向链表 包含了未来将会事件的事件 */
    int stop;
    void *apidata; /* 用户的自定义数据用于传递给回调函数 */
    aeBeforeSleepProc *beforesleep; /* 每一个事件循环都会执行一次 */
} aeEventLoop;

aeFileEvent

aeFileEvent 描述了redis ae模块关于io类事件的主要信息,包含当前事件的读写模式回调函数等,注册一个io事件后aeFileEvent结构被记录在aeEventLoop的events属性中,根据文件描述来决定结构在events属性中的位置

/* File event structure */
typedef struct aeFileEvent {
    int mask; /* one of AE_(READABLE|WRITABLE) 读写模式的定义*/
    aeFileProc *rfileProc; /* 读操作回调函数的定义 */
    aeFileProc *wfileProc; /* 写操作回调函数的定义 */
    void *clientData; /* 用户自定义数据用于传递给回调函数 */
} aeFileEvent;

aeTimeEvent

aeTimeEvent 描述了redis时间事件的主要信息,Redis的事件事件结构就是一个链表节点,多个时间事件组成链表,Redis每个循环周期会遍历该链表(保存在aeEventLoop.timeEventHead中),进行时间校准后,执行触发的时间事件。

/* Time event structure */
typedef struct aeTimeEvent {
    long long id; /* 时间事件的id,根据aeEventLoop.timeEventNextId属性自增来生成 */
    long when_sec; /* 执行当前事件的时间 单位 秒 */
    long when_ms; /* 执行当前事件的时间 单位 毫秒 */
    aeTimeProc *timeProc; /* 事件触发时候执行 */
    aeEventFinalizerProc *finalizerProc; /* 事件执行完成并且从时间事件链表中删除的时候执行 */
    void *clientData; /* 用户自定义数据用于传递给回调函数 */
    struct aeTimeEvent *next; /* 指向链表的下一个节点 */
} aeTimeEvent;

aeFiredEvent

aeFiredEvent 保存了每次被触发io事件的文件描述符和读写模式信息

/* A fired event */
typedef struct aeFiredEvent {
    int fd;    /* 触发io事件的文件描述符 */
    int mask; /* 描述当前触发的读写模式 */
} aeFiredEvent;

2.ae模块核心结构之间的关系

该部分使用一张简单的图片来表示,具体内容可以结合上文注释来理解(图片偷自 @C_Z 的文章 :) )

3.ae模块执行主流程

创建 aeEventLoop同时初始化 io事件列表和事件事件链表和相关的状态信息,同时创建epoll对象

创建 时间事件 设置时间事件触发的回调函数,执行时间并加入到主循环的timeEventHead链表中

创建 io事件 根据 设置 epoll监听的文件表述符描述符读写状态同时更新到aeEventLoop的events事件列表相应位置中(根据文件描述符来定位指针的偏移量)

主流流程执行

偷懒。。稍候补图。。。。

执行 aeBeforeSleepProc 回调函数

读取最近一个时间事件的距离事件

执行epoll_wait 监听文件描述符,监听超时时间截止到下一个时间事件触发之前或者有io事件触发

将触发的io事件放入aeEventLoop.FiredEvent中

读取触发的io事件列表并执行对应的读写事件

校准系统时间,如果系统时间与lastTime不符合实际情况,则将时间事件链表中所有事件都标记为立即执行

执行每一一个时间事件的回调函数

根据回调函数返回值决定,当前事件该从时间事件链表删除还是重新设置下次执行时间

如果时间事件从俩表删除则执行 aeEventFinalizerProc 回调函数

进入下一个循环周期 知道 aeEventLoop.stop == 0

Redis2.8.9源码   src/ae.h   src/ae.c     src/ae_epoll.c

时间: 2024-10-15 20:14:12

Redis 2.8.9源码 - ae模块的相关文章

nginx源码分析--模块分类

ngx-modules Nginx 主要的模块大致可以分为四类: handler – 协同完成客户端请求的处理.产生响应数据.比如模块, ngx_http_rewrite_module, ngx_http_log_module, ngx_http_static_module. filter – 对 handler 产生的响应数据做各种过滤处理.比如模块, ngx_http_not_modified_filter_module, ngx_http_header_filter_module. ups

Android之源码之模块编译和调试

Android之源码之模块编译调试 (一) 进行源码模块修改进行编译的调试 1.首先是从git或者svn上拉一套完整的工程下来,然后全编一下,一般这个时间比较长,大概会得2,3个小时左右, 2,编译成功之后,进到源码的中要修改的模块,例如:package/apps/Contacts/模块下,对要修改的文件进行修改 3.然后在终端Terminal回到项目的根目录下,Android6.0,M的代码,原始的命令是要先source的,如:source xxx.sh xxx_project 4.然后在这个

Spring Boot源码中模块详解

Spring Boot源码中模块详解 一.源码 spring boot2.1版本源码地址:https://github.com/spring-projects/spring-boot/tree/2.1.x 二.模块 Spring Boot 包含许多模块,以下是一些简单的概述: 1,spring-boot 为Spring Boot其他部分功能提供主要的lib包,其中包含:(1)SpringApplication类提供了静态便利的方法使编写独立的SpringApplication更加容易.它唯一的任

jQuery源码 Ajax模块分析

写在前面: 先讲讲ajax中的相关函数,然后结合函数功能来具体分析源代码. 相关函数: >>ajax全局事件处理程序 .ajaxStart(handler) 注册一个ajaxStart事件处理器.当一个Ajax请求开始,并且同时无其它未完成的Ajax请求时,jQuery触发ajaxStart事件. .ajaxSend(handler) 注册一个ajaxSend事件处理器.当一个Ajax请求被发送时触发ajaxSend事件. .ajaxSuccess(handler) 注册一个ajaxSucce

Redis java客户端 jedis 源码分析系列二:单实例 jedis

在使用Jedis的过程中最简单的用法就是单实例单连接的jedis,如下代码所示: public void testJedis(){ Jedis jedis = new Jedis("127.0.0.1"); jedis.set("key", "value"); jedis.get("key"); jedis.close(); } 让我们深入到内部去看一看其结构,如下图所示: 此处请先忽略 JedisPool 类和 Pool&l

redis 4.0.8 源码包安装集群

系统:centos 6.9软件版本:redis-4.0.8,rubygems-2.7.7,gcc version 4.4.7 20120313,openssl-1.1.0h,zlib-1.2.11 yum install c++ gcc 1.安装redis tar -xf redis-4.0.8.tar.gz cd redis-4.0.8 make make install PREFIX=/redis-cluster 2.安装ruby和rubygems及相关组件(zlib和openssl) 安装

深入了解Redis【一】源码下载与参考资料准备

引言 一直在使用redis,但是却没有系统的了解过它的底层实现,准备边学习边记录,深入了解redis. 打算分析以下几个方面: redis的基本类型及底层原理与java对比,每种数据类型的使用场景 redis底层对象 key的一致性Hash算法 单线程的redis"快" redis的过期策略以及内存淘汰机制 redis分布式锁原理 redis备份方式 多机环境下主从赋值.哨兵.集群的优缺点 哨兵机制与选举算法 集群机制的分片原理 缓存的key并发竞争问题 缓存和数据库双写一致性问题 缓

redis 5.0.7 源码阅读——双向链表

redis中动态字符串sds相关的文件为:adlist.h与adlist.c 一.数据结构 redis里定义的双向链表,与普通双向链表大致相同 单个节点: 1 typedef struct listNode { 2 struct listNode *prev; 3 struct listNode *next; 4 void *value; 5 } listNode; 链表: 1 typedef struct list { 2 listNode *head; 3 listNode *tail; 4

redis 5.0.7 源码阅读——跳跃表skiplist

redis中并没有专门给跳跃表两个文件.在5.0.7的版本中,结构体的声明与定义.接口的声明在server.h中,接口的定义在t_zset.c中,所有开头为zsl的函数. 一.数据结构 单个节点: typedef struct zskiplistNode { //key,唯一 sds ele; //分值,可重复 double score; //后退指针 struct zskiplistNode *backward; //层 struct zskiplistLevel { //前进指针 struc