swoole事件处理步骤
发布时间:2022-07-02 16:04:48 所属栏目:PHP教程 来源:互联网
导读:本篇文章的主要内容是关于对swoole事件处理流程的解析,感兴趣的朋友可以了解一下,希望本文能对你有所帮助。 了解swoole事件处理流程,先了解两种网络事件处理模式。 Reactor模式 它要求主线程(I/O处理单元)只负责监听文件描述符上是否有事件发生,有的话就
本篇文章的主要内容是关于对swoole事件处理流程的解析,感兴趣的朋友可以了解一下,希望本文能对你有所帮助。 了解swoole事件处理流程,先了解两种网络事件处理模式。 Reactor模式 它要求主线程(I/O处理单元)只负责监听文件描述符上是否有事件发生,有的话就立即将该事件通知工作线程/进程(逻辑单元)。除此之外,主线程不做任何其他工作。读写数据,接受新的连接,以及处理客户请求均在工作线程中完成。 Proactor模式 两种实现 使用I/O异步模型实现Proactor模式。原理:将所有I/O操作都交给主线程,主线程配合和内核来处理,业务逻辑操作就交给逻辑单元。例如使用aio_read来实现。 工作流程: 主线程调用aio_read函数向内核注册socket上的读完成事件。 主线程继续处理其他I/O事件。 当socket上的数据被读入用户缓冲区后,内核向应用程序(逻辑单元)发送一个信号,通知应用程序数据可用。 应用程序读取数据(客户端的请求),处理完后,调用aio_write函数向内核注册socket上的写事件。 主线程继续处理其他逻辑。 当用户缓冲区的数据写入socket后,内核向应用程序发送一个信号,通知应用程序数据发送完毕。 应用程序预先定义好的信号处理函数来处理善后处理,比如关闭socket. 使用I/O同步模型实现Proactor模式。原理:主线程执行I/O事件数据的读写操作,业务逻辑操作就交给逻辑单元。例如使用epoll来实现。 工作流程: 主线程往epoll内核事件表中注册socket上的读就绪事件。 主线程调用epoll_wait等待socket上有数据可读。 epoll_wait有返回后,主线程从socket上读取数据,然后将读取到的数据封装成一个请求对象(客户端的请求),并插入请求队列。 于是队列的消费者线程处理请求对象,然后在epoll内核事件表中注册socket上的写就绪事件。 主线程调用epoll_wait等待socket可写。 当socket可写时,epoll_wait通知主线程。主线程往socket写入请求结果。 可以看出,如果我们把Reactor线程和Work进程组合起来,看成工作线程的话,swoole使用的是reactor事件处理模式。 一个请求经历的步骤如下: 1. 服务器主线程等待客户端连接。 2. Reactor线程处理接连socket,读取socket上的请求数据(Receive),将请求封装好后投递给work进程。 3. Work进程就是逻辑单元,处理业务数据。 4. Work进程结果返回给Reactor线程。 5. Reactor线程将结果写回socket(Send)。 (编辑:开发网_开封站长网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |