告别阻塞等待：使用Composer和GuzzlePromises玩转PHP异步编程

200ms + 200ms + 200ms = 600ms

curl_multi

curl_multi

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

Promise

pending

fulfilled

rejected

then()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "操作成功，得到值: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "操作失败，原因: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成，兑现 Promise
$promise->resolve('这是异步操作的结果！');
// 输出: 操作成功，得到值: 这是异步操作的结果！

$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "另一个操作失败，原因: " . $reason . PHP_EOL;
});
// 模拟异步操作失败，拒绝 Promise
$anotherPromise->reject('网络连接超时！');
// 输出: 另一个操作失败，原因: 网络连接超时！

resolve()

reject()

then()

guzzlehttp/promises

then()

then()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();
$secondPromise = new Promise();

$firstPromise
    ->then(function ($value) use ($secondPromise) {
        echo "第一步完成，得到: " . $value . PHP_EOL;
        // 返回第二个 Promise，后续链条会等待它完成
        return $secondPromise;
    })
    ->then(function ($value) {
        echo "第二步完成，得到: " . $value . PHP_EOL;
    });

$firstPromise->resolve('用户ID'); // 触发第一步
// 输出: 第一步完成，得到: 用户ID

// 假设第二个异步操作在稍后完成
$secondPromise->resolve('用户详细信息'); // 触发第二步
// 输出: 第二步完成，得到: 用户详细信息

wait()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$dataFetchPromise = new Promise(function () use (&$dataFetchPromise) {
    // 模拟一个耗时操作
    sleep(2); // 模拟2秒的异步操作
    $dataFetchPromise->resolve('从数据库获取的数据');
});

echo "开始等待..." . PHP_EOL;
$result = $dataFetchPromise->wait(); // 脚本会在这里阻塞，直到 Promise 完成
echo "等待结束，结果: " . $result . PHP_EOL;
// 输出:
// 开始等待...
// (暂停2秒)
// 等待结束，结果: 从数据库获取的数据

wait()

false

guzzlehttp/promises

GuzzleHttp\Promise\Utils::all()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils;

$promise1 = new Promise(function () use (&$promise1) {
    sleep(1); $promise1->resolve('结果A');
});
$promise2 = new Promise(function () use (&$promise2) {
    sleep(2); $promise2->resolve('结果B');
});
$promise3 = new Promise(function () use (&$promise3) {
    sleep(0.5); $promise3->resolve('结果C');
});

echo "开始并发等待所有 Promise..." . PHP_EOL;
$allResults = Utils::all([$promise1, $promise2, $promise3])->wait();
print_r($allResults);
// 脚本会等待最慢的 Promise (promise2) 完成，总耗时约2秒。
// 输出:
// 开始并发等待所有 Promise...
// (暂停2秒)
// Array
// (
//     [0] => 结果A
//     [1] => 结果B
//     [2] => 结果C
// )

guzzlehttp/promises