ient->on('Error', [$this, 'onError']);
}
public function connect() {
if(!$fp = $this->client->connect("127.0.0.1", 9501 , 1)) {
echo "Error: {$fp->errMsg}[{$fp->errCode}]".PHP_EOL;
return;
}
}
public function onConnect($cli) {
fwrite(STDOUT, "输入Email:");
swoole_event_add(STDIN, function() {
fwrite(STDOUT, "输入Email:");
$msg = trim(fgets(STDIN));
$this->send($msg);
});
}
public function onReceive($cli, $data) {
echo PHP_EOL."Received: ".$data.PHP_EOL;
}
public function send($data) {
$this->client->send($data);
}
public function onClose($cli) {
echo "Client close connection".PHP_EOL;
}
public function onError() {
}
}
$client = new Client();
$client->connect();
小结
一、上面的配置总共开启了几个进程?
总共8个进程(1个master进程、1个manager进程、4个task进程、2个worker进程)
重新运行的可能与上图进程号不一致:
master进程:22481
manager进程:22485
task进程:22488、22489、22490、22491
worker进程:22492、22493
参考官方提供的进程图:
二、为什么执行了5次后,worker进程号发生了改变?
因为我们设了置worker进程的max_request=4,一个worker进程在完成最大请求次数任务后将自动退出,进程退出会释放所有的内存和资源,这样的机制主要是解决PHP进程内存溢出的问题。
三、当task执行任务异常,我们kill一个task进程,会再新增一个吗?
会。
四、如何设置 task_worker_num ?
最大值不得超过 SWOOLE_CPU_NUM * 1000。
查看本机 CPU 核数:
echo "swoole_cpu_num:".swoole_cpu_num().PHP_EOL;
根据项目的任务量决定的,比如:1秒会产生200个任务,执行每个任务需要500ms。
想在1s中执行完成200个任务,需要100个task进程。
100 = 200/(1/0.5)
五、如何设置 worker_num ?
默认设置为本机的CPU核数,最大不得超过 SWOOLE_CPU_NUM * 1000。
比如:1个请求耗时10ms,要提供1000QPS的处理能力,那就必须配置10个进程。
10 = 0.01*1000
假设每个进程占用40M内存,10个进程就需要占用400M的内存。
扩展
- Server->taskwait
- Server->taskWaitMulti
- Server->taskCo
参考文档
本文欢迎转发,转发请注明作者和出处,谢谢!