+
80
-

swoole的进程模型是怎样的?

php

请问swoole的进程模型是怎样的?

网友回复

+
0
-

swoole是一个多进程模型的框架,当启动一个进程swoole应用时,一共会创建2+n+m个进程,n为worker进程数,m为TaskWorker进程数,1个master进程和一个manager进程,关系如下图所示

Master进程为主进程,该进程会创建Manager进程、Reactor线程等工作进/线程

其中三种进程之间的关系是:

Reactor线程:

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

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

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

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

Reactor以多线程的方式运行;

Worker进程

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

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

可以是异步非阻塞模式,也可以是同步阻塞模式;

Worker以多进程的方式运行;

TaskWorker进程

task进程是swoole当中独立于worker进程的工作进程。用于处理一些耗时较长的逻辑,这些逻辑如果在工作当中处理时并不会影响worker进程处理来自于客户端的请求。由此大大提高了swoole扩展的并发能力。 在worker进程当中,通过调用 task() 方法,发送数据通知到task进程,task进程会在 onTask() 回调当中接收到这些数据并进行处理,处理完成之后调用 finish() 函数或者直接return返回消息给 worker进程,worker进程的 onFinish() 函数收到这些数据并进行处理。 注意:

Task进程和worker进程间通过 Unix Sock 管道通信(也可配置通过消息队列通信)

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

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

完全是同步阻塞模式;

TaskWorker以多进程的方式运行;

swoole代码示例
<?php
$server = new Swoole\Server("0.0.0.0", 9505);
//开启taskworker需要配置task_worker_num的数量
$server->set(['worker_num'=>4,'task_worker_num'=>4,'daemonize'=>false]);

$server->on('receive', function($server, $fd, $reactor_id, $data) {
    $task_id = $server->task("Async");//投递任务
    echo "Dispatch AsyncTask: [id=$task_id]\n";
});

$server->on('task', function ($server, $task_id, $reactor_id, $data) {
    echo "New AsyncTask[id=$task_id]\n";//收到任务
    sleep(2000);//模拟异步任务
    $server->finish("$data -> OK");
});

$server->on('finish', function ($server, $task_id, $data) {
    echo "AsyncTask[$task_id] finished: {$data}\n";
});

echo "server is running \n";
$server->start();
Task进程常见问题

Task传递数据大小(Task传递数据本身是没有限制的);

数据小于8k:直接通过管道传递;

数据大于8k:写入临时文件传递。

Task 传递对象(Task参数传递对象的问题)

可以通过序列化传递一个对象的拷贝(也就是说,并不是传递了一个引用,因为在Task当中,它和worker进程是两个完全不同的进程,他们的内存空间是不一样的,因此变量存储的地方也不一样,所以,Task对于一个对象的改变并不会反映到woker进程中);

数据库连接,网络连接对象不可这样传递,会引起 PHP 程序报错。

Task 的 onFinish 回调

Task 的 onFinish 回调会发回调用task方法的worker进程(回调给调用它方法的worker进程,并不会回调给其他worker进程)。
我知道答案,我要回答