后端开发|php教程
PHP,多进程
后端开发-php教程
借贷公司源码,空电脑装Ubuntu,编写 tomcat服务器,puthon爬虫入门,php限制字符长度,谷歌seo如何快速刷新页面标题lzw
pcntl模块（非 Unix 类系统不支持此模块）
asp单页销售源码,vscode怎么代用css,ubuntu 设置引导,Tomcat句柄数配置,爬虫pyqt,php微信开发代码,品牌seo代理项目平台,网站统计系统 开源,九宫格布局企业微官网模板下载lzw
一个 PHP 多进程简单例子大概是这个样子：
易语言装修管理软件源码,ubuntu如何修复引导,it都会爬虫吗,php引擎加密,seo广告站lzw
// 5 个子进程处理任务for ($i = 0; $i < 5; $i++) { $pid = pcntl_fork(); if ($pid == -1) { die("could not fork"); } elseif ($pid) { echo "Im the Parent $i\n"; } else { // 子进程处理 echo "Im the Child $i\n"; // 业务处理 exit($i); // 一定要注意退出子进程，否则 pcntl_fork() 会被子进程再 fork，带来处理上的影响。 }}// 等待子进程执行结束while (pcntl_waitpid(0, $status) != -1) { $status = pcntl_wexitstatus($status); echo "Child $status completed\n";}复制代码
当然实际应用中我们不能够这样输出代码，不够健壮，也不够优雅，我所以找了个基于pcntl封装的扩展包来使用。
spatie/async – 基于pcntl封装的扩展包
以下是我使用spatie/async来优化一个多进程请求的例子
原代码（耗时 20s 左右）- /guanguans/m…
/** * @param string $keyword * * @return array */public function searchAll(string $keyword): array{ $songAll = []; foreach ($this->platforms as $platform) { $songAll = array_merge($songAll, $this->search($platform, $keyword)); } return $songAll;}/** * @param string $platform * @param string $keyword * * @return mixed */public function search(string $platform, string $keyword){ $meting = $this->getMeting($platform); $songs = json_decode($meting->format()->search($keyword), true); foreach ($songs as $key => &$song) { $detail = json_decode($meting->format()->url($song[url_id]), true); if (empty($detail[url])) { unset($songs[$key]); } $song = array_merge($song, $detail); } unset($song); return $songs;}复制代码
改进后（耗时 4s 左右）- /guanguans/m…
/** * @param string $keyword * * @return array */public function searchAll(string $keyword): array{ $songAll = []; $pool = Pool::create(); foreach ($this->platforms as $platform) { $pool->add(function () use ($platform, $keyword) { return $this->search($platform, $keyword); }, $this->getSerializedOutput())->then(function ($output) use (&$songAll) { $songAll = array_merge($songAll, $output); })->catch(function (\Throwable $exception) { exit($exception->getMessage()); }); } $pool->wait(); return $songAll;}/** * @return mixed */public function search(string $platform, string $keyword){ $meting = $this->getMeting($platform); $songs = json_decode($meting->format()->search($keyword), true); $pool = Pool::create(); foreach ($songs as $key => &$song) { $pool->add(function () use ($meting, $song) { return json_decode($meting->format()->url($song[url_id]), true); })->then(function ($output) use (&$songs, &$song, $key) { $song = array_merge($song, $output); if (empty($song[url])) {unset($songs[$key]); } })->catch(function (\Throwable $exception) { exit($exception->getMessage()); }); } unset($song); $pool->wait(); return $songs;}复制代码
