告别“回调地狱”：如何使用GuzzlePromises优雅地处理PHP异步操作

composer require guzzlehttp/promises

<?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于访问任务队列和 Promise::all()

// 模拟异步操作：获取用户ID
function fetchUserId(): Promise
{
    $promise = new Promise();
    // 实际应用中这里可能是网络请求、数据库查询等耗时操作
    // 我们通过将任务添加到 Guzzle 的内部队列来模拟异步，并在稍后手动运行队列
    Utils::queue()->add(function () use ($promise) {
        echo "正在获取用户ID...\n";
        sleep(1); // 模拟耗时1秒
        $promise->resolve(123); // 假设用户ID是123
    });
    return $promise;
}

// 模拟异步操作：根据用户ID获取订单列表
function fetchOrders(int $userId): Promise
{
    $promise = new Promise();
    Utils::queue()->add(function () use ($promise, $userId) {
        echo "正在获取用户 {$userId} 的订单...\n";
        sleep(1); // 模拟耗时1秒
        if ($userId === 123) {
            $promise->resolve(['order_A', 'order_B']);
        } else {
            $promise->reject('用户不存在，无法获取订单');
        }
    });
    return $promise;
}

// 模拟异步操作：根据订单获取商品详情
function fetchProductDetails(string $orderId): Promise
{
    $promise = new Promise();
    Utils::queue()->add(function () use ($promise, $orderId) {
        echo "正在获取订单 {$orderId} 的商品详情...\n";
        sleep(0.5); // 模拟耗时0.5秒
        $details = [
            'order_A' => ['笔记本电脑', '无线鼠标'],
            'order_B' => ['机械键盘'],
        ];
        if (isset($details[$orderId])) {
            $promise->resolve($details[$orderId]);
        } else {
            $promise->reject("订单 {$orderId} 详情未找到");
        }
    });
    return $promise;
}

echo "--- 异步流程开始 ---\n";

fetchUserId() // 第一步：获取用户ID
    ->then(function ($userId) { // 当用户ID获取成功后执行
        echo "成功获取用户ID: {$userId}\n";
        return fetchOrders($userId); // 返回一个新的 Promise，链式调用下一个异步操作
    })
    ->then(function ($orders) { // 当订单列表获取成功后执行
        echo "成功获取订单列表: " . implode(', ', $orders) . "\n";
        $productPromises = [];
        foreach ($orders as $orderId) {
            $productPromises[] = fetchProductDetails($orderId); // 为每个订单创建一个获取详情的 Promise
        }
        // 使用 Utils::all() 等待所有商品详情的 Promise 都完成
        return Utils::all($productPromises);
    })
    ->then(function ($allProductDetails) { // 当所有商品详情都获取成功后执行
        echo "所有商品详情获取完毕:\n";
        foreach ($allProductDetails as $details) {
            echo "- " . implode(', ', $details) . "\n";
        }
        return "? 整个流程成功完成！"; // 返回最终成功消息
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节发生的拒绝（错误）
        echo "❌ 流程失败: {$reason}\n";
        return "流程未能成功完成。"; // 即使失败，也可以返回一个值，避免下游继续抛出异常
    })
    ->then(function ($finalMessage) { // 无论成功或失败，最后都会执行这里
        echo $finalMessage . "\n";
    });

// 关键步骤：运行 Guzzle 的内部任务队列
// Guzzle Promises 依赖一个任务队列来异步地处理 Promise 的解决和拒绝。
// 在实际使用事件循环（如 ReactPHP）的异步框架中，这通常由框架自动处理。
// 在我们这个简单的例子中，需要手动运行队列，直到所有 Promise 都处理完毕。
echo "\n--- 运行任务队列，等待异步操作完成 ---\n";
while (Utils::queue()->run()) {
    // 队列不为空时，持续运行，直到所有任务都被处理
}
echo "--- 异步流程执行完毕 ---\n";