0

0

对swoole的架构分析

不言

不言

发布时间:2018-08-06 10:13:38

|

2951人浏览过

|

来源于php中文网

原创

本篇文章给大家带来的内容是关于对swoole的架构分析,有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助。

结构图如下:

swoole主要由Master进程(主进程)和Manager进程配合使用完成其功能。

Master进程

是一个多线程的程序。其中有一组很重要的线程,称之为Reactor线程。它就是真正处理TCP连接,收发数据的线程。

Manager进程

管理worker/task进程。worker/task进程都是由Manager进程Fork并管理的。

Reactor线程

主线程(Master进程)在Accept新的连接后,会将这个连接分配给一个固定的Reactor线程,并由这个线程负责监听此socket。在socket可读时读取数据,并进行协议解析,将请求投递到Worker进程。

  • 负责维护客户端TCP连接、处理网络IO、处理协议、收发数据

  • 完全是异步非阻塞的模式

  • 全部为C代码,除Start/Shudown事件回调外,不执行任何PHP代码

  • TCP客户端发来的数据缓冲、拼接、拆分成完整的一个请求数据包

  • Reactor以多线程的方式运行

Work进程

类似与php-fpm进程。

  • 接受由Reactor线程投递的请求数据包,并执行PHP回调函数处理数据

  • 生成响应数据并发给Reactor线程,由Reactor线程发送给TCP客户端

  • 可以是异步模式,也可以是同步模式

  • Worker以多进程的方式运行

TaskWorker进程

异步处理其他任务的进程,使用方方式类似与Gearman。

  • 接受由Worker进程通过swoole_server->task/taskwait方法投递的任务

  • 处理任务,并将结果数据返回(swoole_server->finish)给Worker进程

  • TaskWorker以多进程的方式运行

关系

可以理解为Reactor就是nginxWorker就是php-fpmReactor线程异步并行地处理网络请求,然后再转发给Worker进程中去处理(在回调函数中处理)。ReactorWorker间通过UnixSocket进行通信。

事件处理流程

了解swoole事件处理流程,先了解两种网络事件处理模式。

Reactor模式

它要求主线程(I/O处理单元)只负责监听文件描述符上是否有事件发生,有的话就立即将该事件通知工作线程/进程(逻辑单元)。除此之外,主线程不做任何其他工作。读写数据,接受新的连接,以及处理客户请求均在工作线程中完成。

Proactor模式

两种实现

使用I/O异步模型实现Proactor模式。原理:将所有I/O操作都交给主线程,主线程配合和内核来处理,业务逻辑操作就交给逻辑单元。例如使用aio_read来实现。

工作流程:

  1. 主线程调用aio_read函数向内核注册socket上的读完成事件。

    viable
    viable

    基于GPT-4的AI非结构化数据分析平台

    下载
  2. 主线程继续处理其他I/O事件。

  3. 当socket上的数据被读入用户缓冲区后,内核向应用程序(逻辑单元)发送一个信号,通知应用程序数据可用。

  4. 应用程序读取数据(客户端的请求),处理完后,调用aio_write函数向内核注册socket上的写事件。

  5. 主线程继续处理其他逻辑。

  6. 当用户缓冲区的数据写入socket后,内核向应用程序发送一个信号,通知应用程序数据发送完毕。

  7. 应用程序预先定义好的信号处理函数来处理善后处理,比如关闭socket.

使用I/O同步模型实现Proactor模式。原理:主线程执行I/O事件数据的读写操作,业务逻辑操作就交给逻辑单元。例如使用epoll来实现。

工作流程:

  1. 主线程往epoll内核事件表中注册socket上的读就绪事件。

  2. 主线程调用epoll_wait等待socket上有数据可读。

  3. epoll_wait有返回后,主线程从socket上读取数据,然后将读取到的数据封装成一个请求对象(客户端的请求),并插入请求队列。

  4. 于是队列的消费者线程处理请求对象,然后在epoll内核事件表中注册socket上的写就绪事件。

  5. 主线程调用epoll_wait等待socket可写。

  6. 当socket可写时,epoll_wait通知主线程。主线程往socket写入请求结果。

swoole事件架构图

从图可以看出,如果我们把Reactor线程和Work进程组合起来,看成工作线程的话,swoole使用的是reactor事件处理模式。

一个请求经历的步骤如下:

1. 服务器主线程等待客户端连接。

2. Reactor线程处理接连socket,读取socket上的请求数据(Receive),将请求封装好后投递给work进程。

3. Work进程就是逻辑单元,处理业务数据。

4. Work进程结果返回给Reactor线程。

5. Reactor线程将结果写回socket(Send)。

每个模块的工作请回顾上面的结构介绍。

相关推荐:

如何自定义一个Model?ThinkPHP3.2自定义基类Model的用法

如何用PHP读取excel文件内容、获取单元格数据

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2021

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

1345

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

1250

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

948

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

1402

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

1231

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1440

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1303

2023.11.13

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

74

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL 教程
PostgreSQL 教程

共48课时 | 6.4万人学习

Django 教程
Django 教程

共28课时 | 2.7万人学习

React 教程
React 教程

共58课时 | 3.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号