当前位置：首页 > PHP

php实现异步

2026-01-13 13:37:37PHP

PHP 实现异步的方法

PHP 本身是同步执行的脚本语言，但可以通过以下方法模拟异步操作或实现异步效果：

使用多进程（pcntl_fork）

通过 pcntl_fork 创建子进程实现异步，适用于 CLI 环境：

$pid = pcntl_fork();
if ($pid == -1) {
    die('无法创建子进程');
} elseif ($pid) {
    // 父进程继续执行
    pcntl_wait($status); // 可选：等待子进程结束
} else {
    // 子进程执行异步任务
    sleep(5); // 模拟耗时操作
    file_put_contents('async.log', '任务完成');
    exit();
}

使用消息队列（如 RabbitMQ）

通过消息队列解耦任务处理：

php实现异步

安装 RabbitMQ 和 PHP 的 AMQP 扩展

生产者代码：

$connection = new AMQPConnection(['host' => 'localhost']);
$channel = $connection->channel();
$channel->queue_declare('async_tasks');
$msg = new AMQPMessage('任务数据');
$channel->basic_publish($msg, '', 'async_tasks');

使用 Gearman 任务分发

Gearman 是专门的分布式任务处理系统：

$client = new GearmanClient();
$client->addServer();
$client->doBackground('async_task', '任务数据');

使用 swoole 扩展

Swoole 提供了真正的异步 IO 支持：

php实现异步

Swoole\Runtime::enableCoroutine();
go(function () {
    Co::sleep(1); // 非阻塞睡眠
    echo "异步任务完成\n";
});

使用 HTTP 异步请求（curl_multi）

通过 curl_multi_* 函数实现并行 HTTP 请求：

$handles = [];
$mh = curl_multi_init();

for ($i = 0; $i < 5; $i++) {
    $ch = curl_init("http://example.com/?q=$i");
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($mh, $ch);
    $handles[] = $ch;
}

do {
    curl_multi_exec($mh, $running);
} while ($running > 0);

foreach ($handles as $ch) {
    echo curl_multi_getcontent($ch);
    curl_multi_remove_handle($mh, $ch);
}

使用 ignore_user_abort 后台执行

结合 ignore_user_abort 和 fastcgi_finish_request：

ignore_user_abort(true);
set_time_limit(0);
echo "请求已响应，任务继续在后台运行";
fastcgi_finish_request();

// 后台执行的任务
sleep(10);
file_put_contents('background.log', '完成');