php 异步实现

PHP 异步实现方法

PHP 传统上是同步执行的脚本语言，但可以通过多种方式实现异步操作，提高程序的并发性能。

多进程与进程管理

使用 pcntl_fork 创建子进程处理异步任务，主进程继续执行其他逻辑。适合 CLI 环境，不适用于 Web 场景。

$pid = pcntl_fork();
if ($pid == -1) {
    die('Could not fork');
} else if ($pid) {
    // 父进程
    pcntl_wait($status); // 可选等待子进程
} else {
    // 子进程执行异步任务
    sleep(5);
    exit();
}

消息队列

通过 Redis、RabbitMQ 等中间件实现任务队列。生产者将任务放入队列，消费者异步处理。

// 生产者示例（Redis）
$redis = new Redis();
$redis->connect('127.0.0.1');
$redis->lPush('task_queue', json_encode(['task' => 'async_job']));

Swoole 扩展

Swoole 提供了完整的异步编程支持，包括 TCP/UDP/HTTP 服务器、协程等特性。

$server = new Swoole\Http\Server("0.0.0.0", 9501);
$server->on('Request', function($request, $response) {
    Swoole\Coroutine::create(function() {
        // 异步任务
        sleep(2);
    });
    $response->end("Hello");
});
$server->start();

ReactPHP 事件循环

基于事件循环的库，适合 I/O 密集型异步操作。

$loop = React\EventLoop\Factory::create();
$loop->addTimer(0.5, function () {
    echo "异步执行\n";
});
$loop->run();

协程实现

PHP 8.1+ 内置了纤程（Fiber），配合协程调度器可实现轻量级异步。

$fiber = new Fiber(function() {
    echo "开始异步任务\n";
    Fiber::suspend();
    echo "任务恢复\n";
});
$fiber->start();
$fiber->resume();

选择建议

• Web 应用推荐 Swoole 或 Workerman
• 后台任务处理推荐消息队列
• 简单 CLI 脚本可用多进程
• 新项目可考虑 PHP 8.1+ 的纤程特性

每种方案都有适用场景，需根据项目类型、PHP 版本和性能要求综合选择。