当前位置：首页 > PHP

php 异步实现

2026-01-29 23:47:28PHP

PHP 异步实现方法

PHP 本身是同步阻塞的语言，但可以通过一些扩展和库实现异步编程。以下是几种常见的实现方式：

使用 Swoole 扩展

Swoole 是一个高性能的 PHP 协程框架，支持异步 IO、多线程和协程。

安装 Swoole：

pecl install swoole

异步 TCP 服务器示例：

$server = new Swoole\Server('127.0.0.1', 9501);

$server->on('connect', function ($server, $fd) {
    echo "Client connected\n";
});

$server->on('receive', function ($server, $fd, $from_id, $data) {
    $server->send($fd, "Server: {$data}");
});

$server->on('close', function ($server, $fd) {
    echo "Client closed\n";
});

$server->start();

使用 ReactPHP

ReactPHP 是一个事件驱动的非阻塞 I/O 库，适合构建异步应用。

安装 ReactPHP：

composer require react/event-loop

异步 HTTP 请求示例：

$loop = React\EventLoop\Factory::create();
$client = new React\HttpClient\Client($loop);

$request = $client->request('GET', 'http://example.com');
$request->on('response', function ($response) {
    $response->on('data', function ($chunk) {
        echo $chunk;
    });
});
$request->end();
$loop->run();

使用 AMPHP

AMPHP 是一个基于协程的并发框架，提供协程和异步 I/O 支持。

安装 AMPHP：

composer require amphp/amp

协程示例：

use Amp\Loop;

Loop::run(function () {
    $future1 = Amp\call(function () {
        return "Result 1";
    });

    $future2 = Amp\call(function () {
        return "Result 2";
    });

    $results = yield [$future1, $future2];
    print_r($results);
});

使用 PHP 原生 PCNTL 扩展

PCNTL 扩展允许 PHP 实现多进程编程，适用于简单的异步任务。

多进程示例：

$pid = pcntl_fork();

if ($pid == -1) {
    die('Could not fork');
} elseif ($pid) {
    // Parent process
    pcntl_wait($status);
} else {
    // Child process
    echo "Child process\n";
    exit;
}

使用消息队列

消息队列（如 RabbitMQ、Redis）可以实现任务异步处理。

Redis 队列示例：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// Producer
$redis->lPush('task_queue', 'task data');

// Consumer
while (true) {
    $task = $redis->rPop('task_queue');
    if ($task) {
        processTask($task);
    }
}

使用 Generator 协程

PHP 5.5+ 支持 Generator，可以模拟简单的协程。

协程示例：

php 异步实现

function task1() {
    for ($i = 1; $i <= 3; $i++) {
        echo "Task 1: {$i}\n";
        yield;
    }
}

function task2() {
    for ($i = 1; $i <= 3; $i++) {
        echo "Task 2: {$i}\n";
        yield;
    }
}

$tasks = [task1(), task2()];

while (!empty($tasks)) {
    foreach ($tasks as $key => $task) {
        $task->current() === false ? unset($tasks[$key]) : $task->next();
    }
}