PHP异步编程不再是噩梦：如何使用Composer和GuzzlePromises构建优雅的并发应用

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

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;
use GuzzleHttp\Promise\Utils; // 用于事件循环

// 模拟异步获取用户信息的函数，返回一个Promise
function fetchUserProfile(string $userId): Promise
{
    return new Promise(function ($resolve, $reject) use ($userId) {
        echo "正在异步获取用户 [{$userId}] 的信息..." . PHP_EOL;
        // 模拟网络延迟和成功/失败
        sleep(1);
        if ($userId === 'user123') {
            $resolve(['id' => $userId, 'name' => '张三', 'orders' => ['orderA', 'orderB']]);
        } else {
            $reject(new Exception("用户 [{$userId}] 未找到。"));
        }
    });
}

// 模拟异步获取订单历史的函数
function fetchOrderHistory(array $userProfile): Promise
{
    return new Promise(function ($resolve, $reject) use ($userProfile) {
        echo "正在异步获取用户 [{$userProfile['name']}] 的订单历史..." . PHP_EOL;
        sleep(1);
        if (!empty($userProfile['orders'])) {
            $resolve($userProfile['orders']);
        } else {
            $reject(new Exception("用户 [{$userProfile['name']}] 没有订单。"));
        }
    });
}

// 模拟异步获取商品详情的函数
function fetchItemDetails(array $orderIds): Promise
{
    return new Promise(function ($resolve, $reject) use ($orderIds) {
        echo "正在异步获取订单 [" . implode(', ', $orderIds) . "] 的商品详情..." . PHP_EOL;
        sleep(1);
        $details = [];
        foreach ($orderIds as $orderId) {
            $details[] = "商品_for_{$orderId}";
        }
        $resolve($details);
    });
}

echo "开始处理请求..." . PHP_EOL;

// 链式调用异步操作
$mainPromise = fetchUserProfile('user123') // 第一个Promise
    ->then(function ($userProfile) {
        echo "用户档案获取成功: " . json_encode($userProfile) . PHP_EOL;
        return fetchOrderHistory($userProfile); // 返回一个新的Promise，继续链式调用
    })
    ->then(function ($orderHistory) {
        echo "订单历史获取成功: " . json_encode($orderHistory) . PHP_EOL;
        return fetchItemDetails($orderHistory); // 再次返回新的Promise
    })
    ->then(function ($itemDetails) {
        echo "所有商品详情获取成功: " . json_encode($itemDetails) . PHP_EOL;
        return "所有数据处理完毕！"; // 最终结果
    })
    ->otherwise(function (Throwable $reason) { // 集中处理链中任何环节的错误
        echo "发生错误: " . $reason->getMessage() . PHP_EOL;
        return "数据处理失败。"; // 错误处理后也可以返回一个值或新的Promise
    });

// 在Web请求的末尾，我们通常需要等待所有异步操作完成并获取最终结果
// Guzzle Promises 的 wait() 方法允许你同步地等待Promise完成
// 注意：在真实的异步应用中，你可能需要一个事件循环来驱动Promise，
// 但对于命令行或简单的Web请求，wait() 是一个方便的阻塞方法。
try {
    $finalResult = $mainPromise->wait();
    echo "最终结果: " . $finalResult . PHP_EOL;
} catch (Exception $e) {
    echo "最终等待时捕获到异常: " . $e->getMessage() . PHP_EOL;
}

echo "请求处理完成。" . PHP_EOL;

// 模拟一个失败的例子
echo PHP_EOL . "--- 尝试获取不存在的用户 ---" . PHP_EOL;
$errorPromise = fetchUserProfile('nonexistent_user')
    ->then(function ($userProfile) {
        echo "不应该执行到这里！" . PHP_EOL;
    })
    ->otherwise(function (Throwable $reason) {
        echo "成功捕获到错误: " . $reason->getMessage() . PHP_EOL;
        return "错误处理完成。";
    });

try {
    $errorResult = $errorPromise->wait();
    echo "错误处理后的结果: " . $errorResult . PHP_EOL;
} catch (Exception $e) {
    echo "最终等待时捕获到异常 (错误用户): " . $e->getMessage() . PHP_EOL;
}

?></code>