(二)Redis的事件

  Redis服务器是一个事件驱动程序,服务器需要处理以下两类事件:

  • 文件事件:Redis服务器通过套接字(Socket)与客户端 (或其他Redis服务器)进行连接,文件事件就是服务器对套接字操作的抽象。服务器与客户端的通信会产生相应的文件事件,二服务器则通过监听并处理这些事件来完成一系列网络通信操作。
  • 时间事件:Redis服务器中的一些操作需要在给定的时间点执行,而时间事件就是服务器低这类定时操作的抽象。

文件事件

  Redis基于Reactor模式开发了自己的网络事件处理器--文件事件处理器:

  • 文件事件处理器使用I/O多路复用(multiplexing)程序来同时监听多个套接字,并根据套接字目前执行的任务来为套接字关联不同的事件处理器。
  • 当被监听的套接字准备好执行连接应答(accept)、读取(read)、写入(write)、关闭(close)等操作时,与操作相对应的文件事件就会产生,这时文件事件处理器就会调用套接字之前管理好的事件处理器来处理这些事件。
      虽然文件事件处理器以单线程方式运行,但通过使用I/O多路复用程序来监听多个套接字,既实现了高性能的网络通信模型,又可以很好地与Redis服务器中其他同样以单线程方式运行的模块进行对接,这保持了Redis内部但线程设计的简单性。
      I/O多路复用技术见知乎一篇高赞文章解答

文件事件处理器的构成

  文件事件处理器由套接字、I/O多路复用程序、文件事件分派器和事件处理器构成,如下图:

文件事件处理器组成

  文件事件是对套接字操作的抽象,每当一个套接字准备好执行连接应答、写入、读取、关闭等操作时,就会产生一个文件事件。因为一个服务器会连接多个套接字,所以多个文件事件可能会并发地出现。
  I/O多路复用程序负责监听多个套接字,并向文件事件分派器传送那些产生了事件的套接字。
  尽管多个文件事件可能会并发地出现,但I/O多路复用程序总是会将所有产生事件的套接字都放到一个队列里面,然后通过这个队列,以有序(sequentially)、同步(synchronously)、每次一个套接字的方式向文件事件分派器传送套接字。当一个套接字产生的事件被处理完毕后(该套接字为事件所关联的事件处理器执行完毕),I/O多路复用程序才会继续向文件事件分派传送下一个套接字,如下图:

I/O多路复用程序通过队列向文件事件分派器传送套接字

  文件事件分派器接收到I/O多路复用程序传来的套接字,并根据套接字产生的事件类型调用相应的事件处理器。
  服务器会为执行不同任务的套接字关联不同的事件处理器,这些处理器是一个个函数,它们定义了某个事件发生时,服务器应该执行的动作

I/O多路复用程序的实现

  Redis的I/O多路复用程序的所有功能都是通过包装常见的select、epoll、evport、kqueue这些I/O多路复用函数库实现的。因为Redis为每个函数库都实现了相同的API,所以I/O多路复用程序的底层实现是可以互换的(Redis定义相应的规则所以在编译时自动选择性能最高的库来作为其底层实现),如下图:

Redis中的I/O多路复用

事件的类型

  I/O多路复用程序可以监听多个套接字的ae.h/AE_READABLE事件和ae.h/AE_WRITABLE事件,这连累事件和套接字操作之间的关系如下:

  • 当套接字变得可读时(客户端对套接字执行write操作,或者执行close操作),或者有新的可应答(acceptable)套接字出现时(客户端对服务器的监听套接字执行connect操作),套接字产生AE_READABLE事件
  • 当套接字变得可写时(客户端对套接字执行read操作),套接字产生AE_WRITABLE事件
      I/O多路复用程序运行服务器同时监听套接字的AE_READABLE事件和AE_WRITABLE事件,如果一个套接字同时产生了这两种事件,那么文件事件分派器优先处理AE_READABLE事件,该事件处理完之后再处理AE_WRITABLE事件。即套接字可读又可写的话,则服务器先读套接字,后写套接字。

文件事件的处理器

  Redis为文件事件编写了多个处理器,分别用于实现不同的网络通信需求,下面简单介绍:

  • 连接应答处理器:为了对连接服务器的各个客户端进行应答,服务器为监听套接字关联该处理器
  • 关联命令请求处理器:为了介绍客户端传来的命令请求,服务器为客户端套接字关联该处理器
  • 关联命令回复处理器:为了向客户端返回命令的执行结果,服务器为客户端套接字关联该处理器
  • 复制处理器:当主服务器和从服务器进行复制操作时,主从服务器都需要关联该处理器

时间事件

  Redis的时间事件分为下面2类:

  • 定时事件:让一段程序在指定时间之后执行一次。比如说让程序X在当前事件的30ms之后执行一次
  • 周期性事件:让一段程序每隔指定时间执行一次。比如说让程序Y每个30ms就执行一次
      一个时间事件主要由以下3个属性组成:
  • id:服务器为时间事件创建的全局唯一ID。ID按从小到大的顺序递增,新事件的ID号比旧事件大
  • when:毫秒精度的UNIX时间戳,记录了时间事件的到达时间
  • timeProc:时间事件处理器函数。当时间事件到达时,服务器就会调用相应的处理器来处理事件。
      一个时间事件是定时事件还是周期性事件取决于时间事件处理器的返回值。

时间事件实现

  服务器将所有时间事件都放在一个无序链表中,当时间事件处理器被执行时, 它遍历所有链表中的时间事件, 检查它们的到达事件(when 属性), 并执行其中的已到达事件

注:正常模式下的Redis服务器只使用serverCron一个时间事件。

时间事件应用实例:serverCron函数

  持续运行的Redis服务器需要定期对自身资源和状态进行检查和调整,从而确保服务器可以长期、稳定地运行,这些定期操作由redis.c/serverCrom函数负责执行,它的主要工作包括:

  • 更新服务器的各类统计信息,比如时间、内存占用、数据库占用情况等
  • 清理数据库中的过期键值对
  • 关闭和清理连接失效的客户端
  • 尝试进行AOF或RDB持久化操作
  • 如果服务器是主服务器,那么对从服务器进行定期同步
  • 如果处于集群模式,对集群进行定期同步和连接测试
      Redis服务器以周期性事件的方式来运行serverCron函数,在服务器运行期间,每隔一段时间,该函数执行一次,直到服务器关闭为止。服务器默认规定serverCron函数每秒运行10次,平均每间隔100ms运行一次,我们也可以修改redis.conf配置文件的hz选项来调整其每秒执行次数。

事件的调度与执行

  因为服务器中同时存在文件事件和时间事件,所以服务器必须对这两种事件进行调度,决定何时应该处理文件事件,何时处理时间事件,以及花多少时间来处理它们等等。
  文件事件和时间事件之间是合作关系,服务器会轮流处理这两种事件,并且处理过程中也不会进行互相抢占,但因此实际处理时间事件的事件比预定到达的时间会晚一些。

参考资料

《redis设计与实现》(第二版)

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,816评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,729评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,300评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,780评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,890评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,084评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,151评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,912评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,355评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,666评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,809评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,504评论 4 334
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,150评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,882评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,121评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,628评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,724评论 2 351

推荐阅读更多精彩内容

  • Redis服务器是一个事件驱动程序,服务器需要处理以下两类事件: 文件事件(file event):Redis服务...
    猪大金阅读 566评论 0 1
  • Redis服务器是一个事件驱动程序,服务器需要处理以下两类事件: 1.文件事件:Redis服务器通过套接字与客户端...
    Felicia1993阅读 273评论 0 0
  • redis服务器是一个事件驱动程序,服务器需要处理以下两类事件: 文件事件:redis服务器通过套接字与客户端(或...
    黑金星阅读 566评论 0 1
  • 自我管理,如果是一门学问,那么应该是人人必修的学问。 张爱玲说,每个人都是一个国王,在自己的世界里纵横跋扈,你不要...
    梅篆儒阅读 496评论 2 8
  • 国民党的失败=战略x组织动员x情报的全面的失败。 战略的第一步,是了解对方的战略意图,这一点最有效的方法,和打牌一...
    钢铁侠JEFF阅读 325评论 0 0