Redis的事件模型(ae-epoll实现方式)

上一篇我们说到了文件描述符及常见的polling机制,下面来看看ae中对于epoll的封装实现。

Redis的事件模型(ae-epoll实现方式)

具体完整的交互过程是这样的:

(看一下初始化过程及对应的函数及事件的作用)

1、首先调用aeCreateEventLoop创建了一个事件循环。

2、通过anetTcpServer创建了一个TCP服务器,然后绑定端口并且监听对应的网络请求。

3、调用anetNonBlock将套接字的fd设置为非阻塞IO模式

4、然后将套接字的fd的“客户端连接”时间设置为acceptProc。(然后这个回调函数被aeCreateEventLoop中创建的事件循环使用)

5、当TCP连接建立之后,将触发acceptProc中的动作。

6、通过anetTcpAccept接受连接请求,然后更新套接字中的fd的“有数据可读取”事件的回调函数注册为readProc

7、当readProc被调用时,就可以直接取到可读取的数据,并且更新套接字中的fd的“有数据可写入”事件的回调函数writeProc

8、当EventLoop接收到“有数据可供写入”事件时,就会触发writeProc将数据发送给套接字对应的客户端。

大家可以下载下来看一下,Redis 源码的量其实还好。

wget http://download.redis.io/releases/redis-4.0.1.tar.gz

tar -zxvf redis-4.0.1.tar.gz

Redis的事件模型(ae-epoll实现方式)

然后进到src 文件夹下,看一下server.c,下面是初始化过程的代码片段,L:1812

server.c 主函数中initServer调用了aeCreateEventLoop、anetTcpServer、anetNonBlock来完成初始化

Redis的事件模型(ae-epoll实现方式)

处理“客户端连接”事件的函数也是在initServer中进行的 L:1897

Redis的事件模型(ae-epoll实现方式)

当初始化完成之后,aeMain方法被调用

Redis的事件模型(ae-epoll实现方式)

然后在aeMain方法中sProcessEvents方法被陆续的调用来处理各个时间。

很显然,在整个交互的过程中没有线程或者进程间的交互及其他线程的创建,这个模型其实就是一个轻量级的上下文切换的IO模型,并且上下文切换的代价还很小。但是Redis 因为是使用单线程进行交互的,一条命令没有处理完,就不能执行另一条命令,所以很容易出现延迟问题,但由于Redis 操作比较高效并且是内存操作,所以说这个问题其实还好啦,并且这种串行操作也完全的避免了并发问题。

基本上这就是Redis的事件模型~