文件事件
文件事件的处理器
Redis为文件事件编写了多个处理器,这些事件处理器分别用于实现不同的网络通信需求,比如说:
- 1.为了对连接服务器的各个客户端进行应答,服务器要为监听套接字关联连接应答处理器
- 2.为了接收客户端传来的命令请求,服务器要为客户端套接字关联命令请求处理器
- 3.为了向客户端返回命令的执行结果,服务器要为客户端套接字关联命令回复处理器。
- 4.当主服务器和从服务器进行复制操作时,主从服务器都需要关联特别为复制功能编写的复制处理器
在这些事件处理器里面,服务器最常用的要数与客户端进行通信的连接应答处理器、命令请求处理器
和命令回复处理器
连接应答处理器
networking.c/acceptTcpHandler函数是Redis的连接应答处理器,这个处理器用于对
连接服务器监听套接字的客户端进行应答,具体实现为sys/socket.h/accept函数的包装。
当Redis服务器进行初始化的时候,程序会将这个连接应答处理器和服务器监听套接字的
AE_READABLE事件关联起来,当有客户端用sys/socket.h/connect函数连接服务器监听
套接字的时候,套接字就会产生AE_READABLE事件,引发连接应答处理器执行,并执行
相应的套接字应答操作,,如图所示
命令请求处理器
networking.c/readQueryFromClient函数是Redis的命令请求处理器,这个处理器负责
从套接字中读入客户端发送的命令请求内容,具体实现为unistd.h/read函数的包装。
当一个客户端通过连接应答处理器成功连接到服务器之后,服务器会将客户端套接字的
AE_READABLE事件和命令请求处理器关联起来,当客户端向服务器发送命令请求的时候,
套接字就会产生AE_READABLE事件,引发命令请求处理器执行,并执行相应的套接字读入
操作
命令回复处理器
networking.c/sendReplyToClient函数是Redis的命令回复处理器,这个处理器负责将
服务器执行命令后得到的命令回复通过套接字返回给客户端,具体实现为unistd.h/write
函数的包装。当服务器有命令回复需要传送给客户端的时候,服务器会将客户端套接字的
AE_WRITABLE事件和命令回复处理器关联起来,当客户端准备好接收服务器传回的命令时,
就会产生AE_WRITABLE事件,引发命令回复处理器执行,并执行相应的套接字写入操作。
当命令回复发送完毕之后,服务器就会解除命令回复处理器与客户端套接字的AE_WRITABLE
事件之间的关联。
一次完整的客户端与服务器连接事件示例
假设一个Redis服务器正在运作,那么这个服务器的监听套接字的AE_READABLE事件应该处于监听
状态之下,而该事件所对应的处理器为连接应答处理器。如果这时有一个Redis客户端向服务器发起
连接,那么监听套接字将产生AE_READABLE事件,触发连接应答处理器执行。处理器会对客户端的
连接请求进行应答,然后创建客户端套接字,以及客户端状态,并将客户端套接字的AE_READABLE事件与命令请求处理器进行关联,使得客户端可以向主服务器发送命令请求。之后,假设客户端向主服务器发送一个命令请求,那么客户端套接字将产生AE_READABLE事件,引发命令请求处理器执行,处理器读取客户端的命令内容,然后传给相关程序去执行。
执行命令将产生相应的命令回复,为了将这些命令回复传送回客户端,服务器会将客户端套接字的AE_WRITABLE事件与命令回复处理器进行关联。当客户端尝试读取命令回复的时候,客户端套接字将产生AE_WRITABLE事件,触发命令回复处理器执行,当命令回复处理器将命令回复全部写入到套接字之后,服务器就会解除客户端套接字的AE_WRITABLE事件与命令回复处理器之间的关联
时间事件
Redis的时间时间分为以下两类:
- 1.定时事件:让一段程序在指定的时间之后执行一次。比如说,让程序X在当前时间的30毫秒之后zhixingyici
- 2.周期性事件:让一段程序每隔指定事件就执行一次。比如说,让程序Y每隔30毫秒就执行一次。一个时间事件主要由以下三个属性组成:
id:服务器为事件事件创建的全局唯一ID(标识号),ID号从小到大的顺序递增,新事件的ID号比旧事件的ID号要大
when:毫秒精度的UNIX时间戳,记录了时间事件的到达(arrive)时间
timeProc:时间处理器,一个函数。当时间事件到达时,服务器就会调用相应的处理器来处理事件
一个时间事件是定时事件还是周期性事件取决于时间处理器的返回值:
- 1.如果事件处理器返回ae.h/AE_NOMORE,那么这个事件为定时事件:该事件在达到一次之后就会被删除,之后不再到达
- 2.如果事件处理器返回一个非AE_NOMORE得整数值,那么这个事件为周期性事件:当一个时间事件到达之后,服务器会根据时间事件处理器返回得值,对时间事件的when属性进行更新,让这个事件在一段时间之后到达,并以这种方式一直更新并运行下去。比如说,一个时间事件的处理器返回整数值30,那么服务器应该对这个时间事件进行更新,让这个事件在30毫秒之后再次到达。目前Redis只使用了周期性事件,而没有使用定时事件
实现
服务器将所有时间事件都放在一个无须链表中,每当时间事件执行器运行时,它就遍历整个链表,查找所有已到达的时间事件,并调用相应的事件处理器。
例子
举个例子。链表中包含了三个不同的时间事件:因为新的时间事件总是i插入到链表的表头,所以三个时间事件分别按ID逆序排序,表头事件的ID为3,中间事件的ID为2,表尾事件的ID为1.
注意
我们说保存时间事件的链表为无序链表,指的不是链表不按ID排序,而是说,该链表不按when属性的大小排序。正因为链表没有按照when属性进行排序,所以当时间事件执行器运行的时候,它必须遍历链表中的所有时间事件,这样才能确保服务器中所有已到达的时间事件都会被处理。无序链表并不影响事件处理器的性能。正常模式下的Redis服务器只使用serverCron一个时间事件,而在benchmark模式下,服务器也只使用两个时间事件。在这种情况下,服务器几乎是将无须链表退化成一个指针来使用,所以使用无须链表来保存时间事件,并不影响事件执行的性能
时间事件应用实例:serverCron函数
持续运行的Redis服务器需要定期对自身的资源和状态进行检查和调整,从而确保服务器可以长期、稳定地运行,这些定期操作由redis.c/serverCron函数负责执行,它的主要工作包括:
-
1.更新服务器的各类统计信息,比如时间、内存占用、数据库占用情况等
-
2.清理数据库中的过期键值对
-
3.关闭和清理连接失效的客户端
-
4.尝试进行AOF或者RDB持久化操作
-
5.如果服务器是主服务器,那么对从服务器进行定期同步
-
6.如果处于集群模式,对集群进行定期同步和连接测试
Redis服务器以周期性时间的方式来运行servrCron函数,在服务器运行期间,每隔一段时间(100毫秒),serverCron就会执行一次,直到服务器关闭为止,Redis2.6版本中,服务器默认规定serverCron每秒运行10次,
平均每隔100毫秒运行一次。从Redis2.8开始,用户可以通过修改hz选项来调整serverCron的每秒执行次数。