PHP 多进程处理任务
码农天地 -PHP 多进程处理任务
pcntl
模块(非 Unix 类系统不支持此模块)一个 PHP 多进程简单例子大概是这个样子:
// 5 个子进程处理任务
for ($i = 0; $i < 5; $i++) {
$pid = pcntl_fork();
if ($pid == -1) {
die("could not fork");
} elseif ($pid) {
echo "I'm the Parent $i\n";
} else { // 子进程处理
echo "I'm 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
封装的扩展包来使用。
pcntl
封装的扩展包以下是我使用 spatie/async
来优化一个多进程请求的例子
原代码(耗时 20s 左右)- https://github.com/guanguans/...:
/**
* @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 左右)- https://github.com/guanguans/...:
/**
* @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;
}
相关链接https://www.php.net/manual/zh/book.pcntl.phphttps://github.com/spatie/asynchttps://github.com/guanguans/music-php原文链接https://github.com/guanguans/guanguans.github.io 特别申明:本文内容来源网络,版权归原作者所有,如有侵权请立即与我们联系(cy198701067573@163.com),我们将及时处理。
php介绍
PHP即“超文本预处理器”,是一种通用开源脚本语言。PHP是在服务器端执行的脚本语言,与C语言类似,是常用的网站编程语言。PHP独特的语法混合了C、Java、Perl以及 PHP 自创的语法。利于学习,使用广泛,主要适用于Web开发领域。
下一篇: 不一样的面向对象(一)