企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# Reactor、Worker、TaskWorker的关系 [TOC] 三种角色分别的职责是: ## Reactor线程 * 负责维护客户端`TCP`连接、处理网络`IO`、处理协议、收发数据 * 完全是**异步非阻塞**的模式 * 全部为`C`代码,除`Start`/`Shudown`事件回调外,不执行任何PHP代码 * 将`TCP`客户端发来的数据缓冲、拼接、拆分成完整的一个请求数据包 * `Reactor`以多线程的方式运行 ## Worker进程 * 接受由`Reactor`线程投递的请求数据包,并执行`PHP`回调函数处理数据 * 生成响应数据并发给`Reactor`线程,由`Reactor`线程发送给`TCP`客户端 * 可以是异步非阻塞模式,也可以是同步阻塞模式 * `Worker`以多进程的方式运行 ## TaskWorker进程 * 接受由`Worker`进程通过`swoole_server->task/taskwait`方法投递的任务 * 处理任务,并将结果数据返回(使用`swoole_server->finish`)给`Worker`进程 * 完全是**同步阻塞**模式 * `TaskWorker`以多进程的方式运行 ## 关系 可以理解为`Reactor`就是`nginx`,`Worker`就是`php-fpm`。`Reactor`线程异步并行地处理网络请求,然后再转发给`Worker`进程中去处理。`Reactor`和`Worker`间通过`UnixSocket`进行通信。 在`php-fpm`的应用中,经常会将一个任务异步投递到`Redis`等队列中,并在后台启动一些`php`进程异步地处理这些任务。`Swoole`提供的`TaskWorker`是一套更完整的方案,将任务的投递、队列、`php`任务处理进程管理合为一体。通过底层提供的`API`可以非常简单地实现异步任务的处理。另外`TaskWorker`还可以在任务执行完成后,再返回一个结果反馈到`Worker`。 `Swoole`的`Reactor`、`Worker`、`TaskWorker`之间可以紧密的结合起来,提供更高级的使用方式。 一个更通俗的比喻,假设`Server`就是一个工厂,那`Reactor`就是销售,接受客户订单。而`Worker`就是工人,当销售接到订单后,`Worker`去工作生产出客户要的东西。而`TaskWorker`可以理解为行政人员,可以帮助`Worker`干些杂事,让`Worker`专心工作。 > 底层会为`Worker`进程、`TaskWorker`进程分配一个唯一的`ID` > 不同的`Worker`和`TaskWorker`进程之间可以通过`sendMessage`接口进行通信