告别PHP异步回调噩梦：使用Composer和GuzzlePromises优雅处理复杂任务

<code class="php">// 伪代码，实际可能是curl或GuzzleHttp\Client::get()
$userData = fetchUserDataFromUserService(); // 耗时200ms
$orderData = fetchOrderDataFromOrderService(); // 耗时300ms
$productData = fetchProductDataFromProductService(); // 耗时250ms

// 总计至少 200 + 300 + 250 = 750ms，这还不包括PHP自身的执行时间
// 页面必须等待所有数据加载完毕才能渲染</code>

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

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils;

// 模拟一个异步获取用户数据的操作
function fetchUserAsync($userId): Promise
{
    return new Promise(function ($resolve, $reject) use ($userId) {
        echo "开始异步获取用户 {$userId} 的数据...\n";
        // 模拟网络延迟和数据返回
        // 真实场景下，这里可能是 GuzzleHttp\Client->getAsync() 返回的 Promise
        // 或者其他异步操作，最终调用 $resolve 或 $reject
        // 为了演示，我们延迟2秒后返回数据
        // 注意：在实际非阻塞环境中，sleep() 仍然会阻塞，这里仅为模拟耗时操作
        // usleep(2000000); // 模拟2秒，但仍然是阻塞的

        // 假设成功获取数据
        if ($userId === 123) {
            $resolve(['id' => $userId, 'name' => '张三', 'age' => 30]);
        } else {
            $reject(new \Exception("用户 {$userId} 未找到！"));
        }
    });
}

// 模拟一个异步获取订单数据的操作
function fetchOrdersAsync($userId): Promise
{
    return new Promise(function ($resolve, $reject) use ($userId) {
        echo "开始异步获取用户 {$userId} 的订单数据...\n";
        // usleep(1000000); // 模拟1秒

        if ($userId === 123) {
            $resolve(['order_id' => 'ORD001', 'amount' => 129.99, 'status' => 'completed']);
        } else {
            $reject(new \Exception("用户 {$userId} 没有订单！"));
        }
    });
}

echo "主程序开始执行...\n";

// 启动第一个异步操作
$userPromise = fetchUserAsync(123);

// 链式调用：当用户数据获取成功后，再获取订单数据
$userPromise
    ->then(function ($user) {
        echo "用户数据已获取： " . $user['name'] . "\n";
        // 返回一个新的Promise，将结果传递给下一个then
        return fetchOrdersAsync($user['id']);
    })
    ->then(function ($order) {
        echo "订单数据已获取： 订单号 " . $order['order_id'] . ", 金额 " . $order['amount'] . "\n";
        return "所有数据处理完毕！";
    })
    ->otherwise(function (\Throwable $reason) {
        // 统一处理链条中任何环节的错误
        echo "处理过程中发生错误： " . $reason->getMessage() . "\n";
    });

// 如果你需要同时发起多个独立的异步请求，可以使用 Promise::all() (GuzzleHttp\Promise\Utils::all())
// 例如：
// $allPromises = Utils::all([
//     fetchUserAsync(123),
//     fetchOrdersAsync(123)
// ]);
// $allPromises->then(function ($results) {
//     echo "所有独立请求都已完成！\n";
//     print_r($results);
// })->otherwise(function ($reason) {
//     echo "至少一个独立请求失败： " . $reason->getMessage() . "\n";
// });


echo "主程序继续执行，不等待Promise完成...\n";

// 在没有事件循环的情况下，我们需要手动运行Guzzle的内部任务队列，
// 这样 Promise 的回调才会被执行。
// 在真正的异步框架中，这一步通常由框架自动处理。
Utils::queue()->run(); 

echo "主程序结束。\n";

// 尝试一个会失败的Promise
echo "\n--- 演示失败情况 ---\n";
fetchUserAsync(999)
    ->then(function ($user) {
        echo "不应该执行到这里： " . $user['name'] . "\n";
    })
    ->otherwise(function (\Throwable $reason) {
        echo "成功捕获错误： " . $reason->getMessage() . "\n";
    });

Utils::queue()->run(); // 再次运行队列以处理新Promise
?></code>