Reactor、Worker、TaskWorker的关系

三种角色分别的职责是:

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就是nginxWorker就是php-fpmReactor线程异步并行地处理网络请求,然后再转发给Worker进程中去处理。ReactorWorker间通过UnixSocket进行通信。

php-fpm的应用中,经常会将一个任务异步投递到Redis等队列中,并在后台启动一些php进程异步地处理这些任务。Swoole提供的Worker是一套更完整的方案,将任务的投递、队列、php任务处理进程管理合为一体。通过底层提供的API可以非常简单地实现异步任务的处理。另外TaskWorker还可以在任务执行完成后,再返回一个结果反馈到Worker

SwooleReactorWorkerTaskWorker之间可以紧密的结合起来,提供更高级的使用方式。

一个更通俗的比喻,假设Server就是一个工厂,那Reactor就是销售,接受客户订单。而Worker就是工人,当销售接到订单后,Worker去工作生产出客户要的东西。而TaskWorker可以理解为行政人员,可以帮助Worker干些杂事,让Worker专心工作。

底层会为Worker进程、TaskWorker进程分配一个唯一的ID
不同的WorkerTaskWorker进程之间可以通过sendMessage接口进行通信


  • youngman

    这个本身就有异步代理的机制了吧

  • zhouleyu

    这个本身就有异步代理的机制了吧

  • NewbMiao

    要是有个例子就好理解了

  • 雨过天晴6349

    不执行任何PHP代码,牛逼坏了

  • donald

    我倒是觉得worker 像包工头, 活少自己干,活多找task_worker干

  • 郝多

    worker执行PHP代码,必需用进程嘛?太重量级了,未来会用协程coroutine?

  • 韦元晓

    一会叫Task进程 , 一会叫task_worker进程(其实是一个),把人看晕了。

  • -HXCH--

    可以理解为reactor就是nginx,worker就是php-fpm。reactor线程异步并行地处理网络请求,然后再转发给worker进程中去处理。reactor和worker间通过IPC方式通信。

  • 小心跳大

    要是有个例子就好理解了

  • Meebro

    这个描述让人不再混乱

  • 凌动--

    是不是有多少个客户端就有多少个worker进程

  • 按照Worker与Reactor通信模式 所说,Reactor将数据包投递到指定规则的Worker进程。默认情况下,同一个fd的数据会投递到固定的Worker里。同一个Worker进程可以接受N个连接的数据,在这个Worker内,变量是共享的。

  • 建议增加自主选择worker的功能。因为不同worker进程内,变量是不共享的。有时候想让指定的用户到达同一个worker内。例如几个用户到达同一个游戏房间。

  • Xcode_swift

    我觉得task就是具体工作人员,负责干一些业务的事,work是分配

  • 建树

    一个更通俗的比喻,假设Server就是一个工厂,那Reactor就是销售,接受客户订单。而Worker就是工人,当销售接到订单后,Worker去工作生产出客户要的东西。而TaskWorker可以理解为行政人员,可以帮助Worker干些杂事,让Worker专心工作。

    这个描述中我觉得有误,TaskWorker应该是工人,Worker是管理层分发任务的,同时是行政人员。