mirror of https://github.com/dunwu/db-tutorial.git
84 lines
2.7 KiB
Markdown
84 lines
2.7 KiB
Markdown
---
|
|
title: Redis 事件
|
|
date: 2018/06/11
|
|
categories:
|
|
- database
|
|
tags:
|
|
- database
|
|
- nosql
|
|
---
|
|
|
|
# Redis 事件
|
|
|
|
Redis 服务器是一个事件驱动程序。
|
|
|
|
## 文件事件
|
|
|
|
服务器通过套接字与客户端或者其它服务器进行通信，文件事件就是对套接字操作的抽象。
|
|
|
|
Redis 基于 Reactor 模式开发了自己的网络事件处理器，使用 I/O 多路复用程序来同时监听多个套接字，并将到达的事件传送给文件事件分派器，分派器会根据套接字产生的事件类型调用响应的事件处理器。
|
|
|
|
## 时间事件
|
|
|
|
服务器有一些操作需要在给定的时间点执行，时间事件是对这类定时操作的抽象。
|
|
|
|
时间事件又分为：
|
|
|
|
- 定时事件：是让一段程序在指定的时间之内执行一次；
|
|
- 周期性事件：是让一段程序每隔指定时间就执行一次。
|
|
|
|
Redis 将所有时间事件都放在一个无序链表中，通过遍历整个链表查找出已到达的时间事件，并调用响应的事件处理器。
|
|
|
|
## 事件的调度与执行
|
|
|
|
服务器需要不断监听文件事件的套接字才能得到待处理的文件事件，但是不能一直监听，否则时间事件无法在规定的时间内执行，因此监听时间应该根据距离现在最近的时间事件来决定。
|
|
|
|
事件调度与执行由 aeProcessEvents 函数负责，伪代码如下：
|
|
|
|
```py
|
|
def aeProcessEvents():
|
|
|
|
# 获取到达时间离当前时间最接近的时间事件
|
|
time_event = aeSearchNearestTimer()
|
|
|
|
# 计算最接近的时间事件距离到达还有多少毫秒
|
|
remaind_ms = time_event.when - unix_ts_now()
|
|
|
|
# 如果事件已到达，那么 remaind_ms 的值可能为负数，将它设为 0
|
|
if remaind_ms < 0:
|
|
remaind_ms = 0
|
|
|
|
# 根据 remaind_ms 的值，创建 timeval
|
|
timeval = create_timeval_with_ms(remaind_ms)
|
|
|
|
# 阻塞并等待文件事件产生，最大阻塞时间由传入的 timeval 决定
|
|
aeApiPoll(timeval)
|
|
|
|
# 处理所有已产生的文件事件
|
|
procesFileEvents()
|
|
|
|
# 处理所有已到达的时间事件
|
|
processTimeEvents()
|
|
```
|
|
|
|
将 aeProcessEvents 函数置于一个循环里面，加上初始化和清理函数，就构成了 Redis 服务器的主函数，伪代码如下：
|
|
|
|
```py
|
|
def main():
|
|
|
|
# 初始化服务器
|
|
init_server()
|
|
|
|
# 一直处理事件，直到服务器关闭为止
|
|
while server_is_not_shutdown():
|
|
aeProcessEvents()
|
|
|
|
# 服务器关闭，执行清理操作
|
|
clean_server()
|
|
```
|
|
|
|
从事件处理的角度来看，服务器运行流程如下：
|
|
|
|
<div align="center">
|
|
<img src="https://raw.githubusercontent.com/dunwu/database/master/images/redis/Redis事件的调度与执行.png" />
|
|
</div> |