task timer

 

Fpm多进程的php解析器,当一个新的请求进来的时候,fpm会创建一个进程取处理请求,这样的话在很大程度上系统的开销用于创建和销毁进程,导致了整个程序的效率并不是特别的高;

Swoole采用了和fpm完全不同的架构;如果所示,整个swoole扩展分为三个部分;

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

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

Master为主进程,这个进程用于处理核心的事件驱动的,它拥有若干个reactor线程,reactor是干嘛的呢?每个reactor子线程都运行了一个epll函数的实例,swoole所有的对于事件的监听,都会在这些线程当中实现。

比如来自客户端的连接,本地通讯用的管道,以及异步操作用的文件,文件描述符都会注册在这个epoll当中。

Manager 进程:worker/task进程都是由Manager进程Fork并管理的,manager进程不会运行任何用户层的业务逻辑,它仅仅只做进程的管理和分配

  1. 子进程结束运行时,manager进程负责回收此子进程,避免成为僵尸进程。并创建新的子进程
  2. 服务器关闭时,manager进程将发送信号给所有子进程,通知子进程关闭服务
  3. 服务器reload时,manager进程会逐个关闭/重启子进程

 

Worker进程:处理主要逻辑

Swoole提供了完善的进程管理机制,当Worker进程异常退出,如发生PHP的致命错误、被其他程序误杀,或达到max_request次数之后正常退出。主进程会重新拉起新的Worker进程。 Worker进程内可以像普通的apache+php或者php-fpm中写代码。不需要像Node.js那样写异步回调的代码。

进程和进程之间是通过管道来通信的。

ReactorWorkerTaskWorker的关系

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提供的TaskWorker是一套更完整的方案,将任务的投递、队列、php任务处理进程管理合为一体。通过底层提供的API可以非常简单地实现异步任务的处理。另外TaskWorker还可以在任务执行完成后,再返回一个结果反馈到Worker

 

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

 

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

 

底层会为Worker进程、TaskWorker进程分配一个唯一的ID

不同的WorkerTaskWorker进程之间可以通过sendMessage接口进行通信

 

 

关系

 

 

 

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

 

 

 

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

 

 

 

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

 

 

 

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

 

 

 

底层会为Worker进程、TaskWorker进程分配一个唯一的ID

 

不同的WorkerTaskWorker进程之间可以通过sendMessage接口进行通信

 

ask/Finish特性的用途

 

task模块用来做一些异步的慢速任务,比如webim中发广播,发送邮件等。

 

 

 

task进程必须是同步阻塞的

 

task进程支持定时器

 

node.js 假如有10万个连接,要发广播时,那会循环10万次,这时候程序不能做任何事情,不能接受新的连接,也不能收包发包。

 

 

 

swoole不同,丢给task进程之后,worker进程可以继续处理新的数据请求。任务完成后会异步地通知worker进程告诉它此任务已经完成。

 

 

 

当然task模块的作用还不仅如此,实现PHP的数据库连接池,异步队列等,还需要进一步挖掘。

 

Task传递参数:对象(序列化对象)

 

 

 

可以通过$server->taskworker属性来判断当前是Worker进程还是Task进程

https://wiki.swoole.com/wiki/page/p-event/onWorkerStart.html

 

 

 

Timer定时器

 

https://wiki.swoole.com/wiki/page/244.html

 

 

原文地址:https://www.cnblogs.com/sunlong88/p/8996785.html