如何解决PHP中耗时阻塞的异步操作？GuzzlePromises助你实现优雅的异步流程！

<code class="php">// 模拟一个耗时的同步操作
function syncFetchData($label, $delay = 1) {
    echo "开始同步获取：{$label}...\n";
    sleep($delay); // 模拟网络延迟或计算耗时
    echo "完成同步获取：{$label}。\n";
    return "{$label} 数据";
}

echo "--- 同步操作开始 ---\n";
$userData = syncFetchData("用户信息", 2);
$productsData = syncFetchData("商品列表", 3);
$orderData = syncFetchData("订单状态", 1);
echo "所有数据已同步获取完毕。\n";
// 总耗时约 2 + 3 + 1 = 6 秒</code>

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

<code class="php"><?php

require 'vendor/autoload.php'; // 引入 Composer 自动加载

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

// 模拟一个返回 Promise 的异步操作
function asyncFetchData($label, $delay = 1, $shouldFail = false) {
    // Promise 构造函数接受一个执行器函数，该函数会立即执行
    // 执行器函数接收 resolve 和 reject 两个回调
    return new Promise(function ($resolve, $reject) use ($label, $delay, $shouldFail) {
        // 在实际应用中，这里会发起一个非阻塞的 HTTP 请求（例如使用 GuzzleHttp\Client）
        // 或者其他异步 I/O 操作。
        // 为了演示，我们用一个延迟来模拟异步耗时。
        echo "异步任务：开始获取 {$label}...\n";

        // 模拟一个异步完成，例如在事件循环的下一个tick中完成
        // 在没有完整事件循环框架的情况下，这里无法做到真正的非阻塞并行
        // 但我们演示 Promise 的管理能力
        if ($shouldFail) {
            // 模拟失败
            $reject(new \Exception("获取 {$label} 失败！"));
        } else {
            // 模拟成功
            $resolve("{$label} 数据");
        }
    });
}

echo "--- 异步操作开始（通过 Promise 管理）---\n";

// 创建多个 Promise 对象
$promiseUser = asyncFetchData("用户信息", 2);
$promiseProducts = asyncFetchData("商品列表", 3);
$promiseOrder = asyncFetchData("订单状态", 1, true); // 模拟订单状态获取失败

// 链式调用：当用户信息获取成功后，处理它
$promiseUser->then(
    function ($value) {
        echo "异步回调：成功获取并处理 {$value}\n";
        return "处理后的 " . $value; // 返回新值，传递给下一个 then
    },
    function ($reason) {
        echo "异步回调：用户信息获取失败 - " . $reason->getMessage() . "\n";
        // 可以在这里返回一个成功值，中断失败链
        return "默认用户信息";
    }
)->then(function ($value) {
    echo "异步回调：继续处理用户信息链 - " . $value . "\n";
});

// 处理商品列表的 Promise
$promiseProducts->then(
    function ($value) {
        echo "异步回调：成功获取并处理 {$value}\n";
    },
    function ($reason) {
        echo "异步回调：商品列表获取失败 - " . $reason->getMessage() . "\n";
    }
);

// 处理订单状态的 Promise (它会失败)
$promiseOrder->then(
    function ($value) {
        echo "异步回调：成功获取并处理 {$value}\n";
    },
    function ($reason) {
        echo "异步回调：订单状态获取失败 - " . $reason->getMessage() . "\n";
        // 返回一个 RejectedPromise 会将失败传递下去
        return new RejectedPromise("订单状态失败已传递: " . $reason->getMessage());
    }
)->then(
    null, // 不处理成功
    function ($reason) {
        echo "异步回调：再次捕获订单状态失败 - " . $reason . "\n";
    }
);


// 强制等待所有 Promise 完成（在实际异步环境中，你可能不会这样做，而是依赖事件循环）
// GuzzleHttp\Promise\Utils::all() 可以等待多个 Promise，但这里我们只展示单个 Promise 的 wait()
// 警告：直接调用 wait() 会阻塞当前进程，直到 Promise 解决。
// 在没有事件循环的情况下，要让 Promise 真正“动起来”，需要显式地 resolve 或 reject。
// 上面的例子中，我们直接在 Promise 构造函数中 resolve/reject，这使得它们是“立即”完成的。
// 真正的异步需要配合如 ReactPHP 或 Swoole 等事件循环/协程框架。

// 演示 wait() 的用法：它会阻塞直到 Promise 完成
$finalResultPromise = new Promise(function ($resolve) {
    echo "Waitable Promise: 正在执行耗时操作...\n";
    sleep(2); // 模拟耗时
    $resolve("Waitable Promise: 耗时操作已完成！");
});

try {
    $result = $finalResultPromise->wait();
    echo $result . "\n";
} catch (\Exception $e) {
    echo "Waitable Promise: 发生错误 - " . $e->getMessage() . "\n";
}

echo "所有 Promise 定义完毕。程序继续执行...\n";
// 注意：在没有事件循环的情况下，上面定义的 Promise 链式回调会在它们被 resolve/reject 时立即执行
// 而不是在程序结束时才执行。</code>