如何使用Composer和GuzzlePromises解决PHP异步操作的痛点

<pre class="brush:php;toolbar:false;">// 1. 获取用户基本信息 (可能需要 200ms)
$userInfo = $userService->getUser(123);

// 2. 获取用户订单列表 (可能需要 300ms)
$orders = $orderService->getOrders($userInfo['id']);

// 3. 获取用户未读消息 (可能需要 150ms)
$notifications = $notificationService->getNotifications($userInfo['id']);

// 总耗时：200ms + 300ms + 150ms = 650ms
// 用户需要等待 650ms 才能看到页面

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

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

$promise = new Promise();

$promise->then(
    // $onFulfilled: Promise 成功完成时执行
    function ($value) {
        echo "Promise 成功：{$value}\n";
    },
    // $onRejected: Promise 失败时执行
    function ($reason) {
        echo "Promise 失败：{$reason}\n";
    }
);

// 模拟异步操作完成，解决 Promise
$promise->resolve('数据已成功获取！');
// 输出: Promise 成功：数据已成功获取！

// 模拟异步操作失败，拒绝 Promise
// $promise->reject('API 调用失败！');
// 输出: Promise 失败：API 调用失败！

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

$firstPromise = new Promise();

$firstPromise
    ->then(function ($value) {
        echo "第一步：获取到 {$value}，开始处理...\n";
        // 返回一个新的值，传递给下一个 then
        return "处理后的 " . $value;
    })
    ->then(function ($processedValue) {
        echo "第二步：处理完成，结果是 {$processedValue}，准备最终输出。\n";
        // 再次返回一个值，或者一个新的 Promise
        return "最终结果：" . $processedValue;
    })
    ->then(function ($finalResult) {
        echo $finalResult . "\n";
    });

// 解决第一个 Promise，触发整个链式调用
$firstPromise->resolve('原始数据');

/*
输出：
第一步：获取到 原始数据，开始处理...
第二步：处理完成，结果是 处理后的 原始数据，准备最终输出。
最终结果：处理后的 原始数据
*/

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

$promiseWithError = new Promise();

$promiseWithError
    ->then(function ($value) {
        echo "尝试处理：{$value}\n";
        // 模拟一个错误发生
        throw new \Exception("处理过程中出现意外错误！");
    })
    ->then(
        function ($value) {
            echo "这行代码不会被执行。\n";
        },
        function ($reason) {
            echo "捕获到错误：{$reason->getMessage()}\n";
            // 可以选择返回一个新的 RejectedPromise 继续传递错误
            // return new RejectedPromise("更深层次的错误: " . $reason->getMessage());
            // 或者返回一个普通值，让后续链条转为 Fulfilled 状态
            return "错误已恢复，继续执行！";
        }
    )
    ->then(function ($value) {
        echo "链条继续：{$value}\n"; // 如果上一个 then 恢复了错误，这行会执行
    });

$promiseWithError->resolve('有效数据');

/*
输出：
尝试处理：有效数据
捕获到错误：处理过程中出现意外错误！
链条继续：错误已恢复，继续执行！
*/

<pre class="brush:php;toolbar:false;">$promise->then(function ($value) {
    throw new \Exception("错误！");
})->otherwise(function ($reason) {
    echo "使用 otherwise 捕获到错误：" . $reason->getMessage();
});
$promise->resolve('data');

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

$slowPromise = new Promise(function () use (&$slowPromise) {
    // 模拟一个耗时操作
    sleep(2);
    $slowPromise->resolve('耗时操作完成！');
});

echo "开始等待...\n";
$result = $slowPromise->wait(); // 会阻塞 2 秒
echo "等待结束，结果是：{$result}\n";