告别PHP阻塞等待：GuzzlePromises助你构建高效异步应用

<pre class="brush:php;toolbar:false;">// 伪代码，同步执行
$userData = fetch_user_data_from_api_a(); // 等待1秒
$orderDetails = fetch_order_details_from_api_b(); // 等待1.5秒
$recommendations = fetch_recommendations_from_api_c(); // 等待0.8秒

// 总共耗时约 1 + 1.5 + 0.8 = 3.3 秒

<code class="bash">composer require guzzlehttp/promises</code>

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

// 创建一个 Promise
$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "Promise 成功兑现，值是: " . $value . "\n";
    },
    function ($reason) {
        echo "Promise 被拒绝，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作完成并解决 Promise
// 假设这里是某个耗时操作的最终结果
$promise->resolve('这是异步操作的结果！');
// 输出: Promise 成功兑现，值是: 这是异步操作的结果！

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

$firstPromise = new Promise();

$firstPromise
    ->then(function ($initialValue) {
        echo "第一步：接收到 '" . $initialValue . "'\n";
        // 返回一个新值，这个值将传递给下一个 then
        return strtoupper($initialValue) . " processed";
    })
    ->then(function ($processedValue) {
        echo "第二步：接收到 '" . $processedValue . "'\n";
        // 也可以返回一个新的 Promise，让后续链条等待它完成
        $anotherPromise = new Promise();
        // 模拟另一个异步操作
        // $anotherPromise->resolve("最终结果");
        return $anotherPromise; // 后续 then 将等待这个 Promise 解决
    })
    ->then(function ($finalResult) {
        echo "第三步：最终结果是 '" . $finalResult . "'\n";
    });

// 解决第一个 Promise，启动链式调用
$firstPromise->resolve('hello world');

// 如果第二个 then 返回了一个 Promise，你需要手动解决它
// 假设在某个时刻，第二个 then 返回的 Promise 解决了
// $anotherPromise->resolve("异步链条的最终数据");

// 注意：在实际应用中，这些 resolve/reject 操作通常由异步 I/O 库（如 Guzzle HTTP 客户端）在内部处理。
// 对于上面的例子，为了看到第三步的输出，我们需要手动解决第二个 then 返回的 Promise
// 假设我们现在解决它：
// 实际场景中，你可能需要一个事件循环来处理这些异步操作
// 为了演示，这里假设我们同步地解决它
$secondThenReturnedPromise = $firstPromise->wait(false); // 获取第二个 then 返回的 Promise
if ($secondThenReturnedPromise instanceof Promise) {
    $secondThenReturnedPromise->resolve("异步链条的最终数据");
}

/* 预期的输出 (如果第二个 then 返回的 Promise 立即解决):
第一步：接收到 'hello world'
第二步：接收到 'HELLO WORLD processed'
第三步：最终结果是 '异步链条的最终数据'
*/

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

$errorPromise = new Promise();

$errorPromise
    ->then(function ($value) {
        echo "成功回调，但这里抛出异常！\n";
        throw new \Exception("处理数据时出错！");
    })
    ->then(
        function ($value) {
            // 这个成功回调不会被执行
            echo "第二个成功回调: " . $value . "\n";
        },
        function ($reason) {
            // 这个失败回调会被执行
            echo "捕获到错误： " . $reason->getMessage() . "\n";
            // 也可以返回一个 RejectedPromise 继续向下传递错误
            // return new GuzzleHttp\Promise\RejectedPromise("更具体的错误");
        }
    )
    ->otherwise(function ($reason) { // otherwise 是 then(null, $onRejected) 的语法糖
        echo "最终错误处理: " . $reason->getMessage() . "\n";
    });

$errorPromise->resolve('正常数据');
// 输出:
// 成功回调，但这里抛出异常！
// 捕获到错误： 处理数据时出错！
// 最终错误处理: 处理数据时出错！

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

$finalPromise = new Promise(function () use (&$finalPromise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $finalPromise->resolve('这是等待后的结果');
});

echo "程序继续执行...\n";
$result = $finalPromise->wait(); // 程序将在这里阻塞，直到 $finalPromise 解决
echo "Promise 最终结果: " . $result . "\n";
// 输出:
// 程序继续执行...
// Promise 最终结果: 这是等待后的结果