服务器一般要处理三类事件:IO事件、信号事件、定时事件。由此产生了两种事件处理模式:编程
- Reactor模式:同步IO模型一般用于实现Reactor模式
- Proactor模式:异步IO模型用于实现Proactor模式
1、Reactor模式
主线程(IO处理单元)只负责监听文件描述符上是否有事件发生,有的话马上将该事件通知工做线程(逻辑单元)。除此以外主线程不作任何其余工做,读写数据、接收新的链接及处理客户请求均在工做线程中完成。服务器
使用同步IO模型epoll_wait实现的Reactor模式的工做流程以下:异步
- 主线程往epoll内核事件表中注册socket上的读就绪事件。
- 主线程调用epoll_wait等待socket上有数据可读。
- 当socket上有数据可读时,epoll_wait通知主线程。主线程则将socket可读事件放入请求队列。
- 睡眠在请求队列上的工做线程被唤醒,它从socket读取数据,并处理客户请求,而后往epoll内核事件表中注册该socket上的写就绪事件。
- 主线程调用epoll_wait等待socket可写。
- 当socket可写时,epoll_wait通知主线程。主线程将socket可写事件放入请求队列。
- 睡眠在请求队列上的某个工做线程被唤醒,它往socket上写入服务器处理客户请求的结果。
全部流程能够总结以下图1socket

图1 Reactor模式函数
工做线程从队列中取出事件后,将根据事件的类型来决定如何处理该事件,上图1所示的Reactor模式中,不必区分所谓的“读工做线程”和“写工做线程”。固然也能够分别使用读写工做线程,对应大型应用,有时候需求区分不一样的线程处理不一样的业务。性能
2、Proactor模式
与Reactor模式不一样,Proactor模式将全部IO操做都交给主线程和内核来处理,工做线程仅仅负责业务逻辑。spa
使用异步IO模型(以aio_read和aio_write为例)实现的Proactor模式的工做流程以下:线程
- 主线程调用aio_read函数向内核注册socket上的读完成事件,并告诉内核用户读缓冲区的位置,以及读操做完成时如何通知应用程序(这里以信号为例,详情sigevent的man手册)
- 主线程继续处理其余逻辑。
- 当socket上的数据被读入用户缓冲区后,内核将向应用程序发送一个信号,以通知应用程序数据已经可用。
- 应用程序预先定义好的信号处理函数选择一个工做线程来处理客户请求。工做线程处理完客户请求以后,调用aio_write函数向内核注册socket上的写完成事件,并告诉内核用户写缓冲区位置,以及写操做完成时如何通知应用程序(仍以信号为例)
- 主线程继续处理其余逻辑。
- 当用户缓冲区的数据被写入socket以后,内核将向应用程序发送一个信号,以通知应用程序数据已经发送完毕。
- 应用程序预先定义好的信号处理函数选择一个工做线程来作善后处理,好比决定是否关闭socket.
全部流程能够总结以下图2对象

图2 Proactor模式队列
在上图2中,链接socket上的读写事件是经过aio_read/aio_write向内核注册的,所以内核将经过信号向应用程序报告链接socket上的读写事件。因此主线程的epoll_wait仅能检测监听socket上的链接请求事件,不能用来检测链接socket上的读写事件。
3、同步IO模拟Proactor模式
咱们可使用同步IO模拟出Proactor模式:主线程直接执行数据的读写操做,读写完成以后,主线程向工做队列通知这一“完成事件”。工做线程直接获取读写的结果,以后只是对读写的结果进行逻辑处理。
使用同步IO模型(epoll_wait)模拟出的Proactor模式的工做流程以下:
- 主线程往epoll内核事件表中注册socket上的读就绪事件。
- 主线程调用epoll_wait等待socket上有数据可读。
- 当socket上有数据可读时,epoll_wait通知主线程。主线程从socket循环读取数据,知道没有更多数据可读,而后将读取到的数据封装成一个请求对象并插入到请求队列。
- 睡眠在请求队列上的某个工做线程被唤醒,它得到请求对象并处理客户请求,而后网epoll内核事件表中注册socket上的写就绪事件。
- 主线程调用epoll_wait等待socket可写。
- 当socket可写时,epoll_wait通知主线程。主线程网socket上写入服务器处理客户端请求的结果。
全部流程能够总结以下图3

图3 同步IO模拟Proactor模式
注(本文内容参考 Linux高性能服务器编程——第八章 游双著)