10 | Redis事件驱动框架（中）：Redis实现了Reactor模型吗？

Reactor模型可以分为3种： 单线程Reactor模式 一个线程： 单线程：建立连接（Acceptor）、监听accept、read、write事件（Reactor）、处理事件（Handler）都只用一个单线程。 多线程Reactor模式 一个线程 + 一个线程池： 单线程：建立连接（Acceptor）和 监听accept、read、write事件（Reactor），复用一个线程。 工作线程池：处理事件（Handler），由一个工作线程池来执行业务逻辑，包括数据就绪后，用户态的数据读写。 主从Reactor模式 三个线程池： 主线程池：建立连接（Acceptor），并且将accept事件注册到从线程池。 从线程池：监听accept、read、write事件（Reactor），包括等待数据就绪时，内核态的数据I读写。 工作线程池：处理事件（Handler），由一个工作线程池来执行业务逻辑，包括数据就绪后，用户态的数据读写 具体的可以参考并发大神 doug lea 关于Reactor的文章。 http://gee.cs.oswego.edu/dl/cpjslides/nio.pdf 再提一点，使用了多路复用，不一定是使用了Reacto模型，Mysql使用了select（为什么不使用epoll，因为Mysql的瓶颈不是网络，是磁盘IO），但是并不是Reactor模型 回到问题，那些也是reactor nginx：nginx是多进程模型，master进程不处理网络IO，每个Wroker进程是一个独立的单Reacotr单线程模型。 netty：通信绝对的王者，默认是多Reactor，主Reacotr只负责建立连接，然后把建立好的连接给到从Reactor，从Reactor负责IO读写。当然可以专门调整为单Reactor。 kafka：kafka也是多Reactor，但是因为Kafka主要与磁盘IO交互，因此真正的读写数据不是从Reactor处理的，而是有一个worker线程池，专门处理磁盘IO，从Reactor负责网络IO，然后把任务交给worker线程池处理。

1、为了高效处理网络 IO 的「连接事件」、「读事件」、「写事件」，演化出了 Reactor 模型 2、Reactor 模型主要有 reactor、acceptor、handler 三类角色： - reactor：分配事件 - acceptor：接收连接请求 - handler：处理业务逻辑 3、Reactor 模型又分为 3 类： - 单 Reactor 单线程：accept -> read -> 处理业务逻辑 -> write 都在一个线程 - 单 Reactor 多线程：accept/read/write 在一个线程，处理业务逻辑在另一个线程 - 多 Reactor 多线程 / 进程：accept 在一个线程/进程，read/处理业务逻辑/write 在另一个线程/进程 4、Redis 6.0 以下版本，属于单 Reactor 单线程模型，监听请求、读取数据、处理请求、写回数据都在一个线程中执行，这样会有 3 个问题： - 单线程无法利用多核 - 处理请求发生耗时，会阻塞整个线程，影响整体性能 - 并发请求过高，读取/写回数据存在瓶颈 5、针对问题 3，Redis 6.0 进行了优化，引入了 IO 多线程，把读写请求数据的逻辑，用多线程处理，提升并发性能，但处理请求的逻辑依旧是单线程处理 课后题：除了 Redis，你还了解什么软件系统使用了 Reactor 模型吗？ Netty、Memcached 采用多 Reactor 多线程模型。 Nginx 采用多 Reactor 多进程模型，不过与标准的多 Reactor 多进程模型有些许差异。Nginx 的主进程只用来初始化 socket，不会 accept 连接，而是由子进程 accept 连接，之后这个连接的所有处理都在子进程中完成。

main(server.c)->aeCreateEventLoop(aeApiCreate epoll_create)->aeCreateFileEvent(aeApiAddEvent epoll_ctl)->aeMain(server.c)->aeProcessEvents(aeApiPoll epoll_wait)

上篇文章回答的时候自己提到的-Redis基于多种IO复用实现了同一方法但是多套代码文件的思路，没想到这期老师就提到了。回答老师的问题：还有什么软件系统使用了Reactor模型？ 答： 最典型的就是netty，java靠netty得以实现了高性能的服务 总结： 本篇文章老师主要介绍了Redis是如何实现Reactor模型，其本质上就是围绕三个事件的实现【连接请求，读事件，写事件】，而Redis为了方便实现，封装了事件驱动框架aeEventLoop，其本质上是一个不断处理事件的循环。能同时分发处理来自成百上千个客户端的读，写，连接等请求。

只知道netty用过Reactor模型，看了评论学到了

kafka使用了Reactor编程模型，它使用一个Acceptor,多个Processor处理网络连接，读写请求，以及一个线程池处理消息读写

ae_epoll.c，对应 Linux 上的 IO 复用函数 epoll； ae_evport.c，对应 Solaris 上的 IO 复用函数 evport； ae_kqueue.c，对应 macOS 或 FreeBSD 上的 IO 复用函数 kqueue； ae_select.c，对应 Linux（或 Windows）的 IO 复用函数 select。 你好 我想问下 这个不同操作系统是不是在编译的时候就确定了对应的是哪一个实现？

ae_epoll.c，对应 Linux 上的 IO 复用函数 epoll；ae_evport.c，对应 Solaris 上的 IO 复用函数 evport；ae_kqueue.c，对应 macOS 或 FreeBSD 上的 IO 复用函数 kqueue；ae_select.c，对应 Linux（或 Windows）的 IO 复用函数 select。

ae_epoll.c，对应 Linux 上的 IO 复用函数 epoll； ae_evport.c，对应 Solaris 上的 IO 复用函数 evport； ae_kqueue.c，对应 macOS 或 FreeBSD 上的 IO 复用函数 kqueue； ae_select.c，对应 Linux（或 Windows）的 IO 复用函数 select。

对于写事件还不是很理解，连接事件是客户端发来连接请求，读事件是客户端发来命令请求需要读取，那么写事件对应的是什么触发的？