告别漫长等待：如何使用Composer和GuzzlePromises提升PHP异步操作效率

<code class="php">// 伪代码：同步请求多个API
$data1 = fetchDataFromApi1(); // 等待API1响应
$data2 = fetchDataFromApi2(); // 等待API2响应
$data3 = fetchDataFromApi3(); // 等待API3响应

// 处理所有数据...</code>

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

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 模拟一个异步操作，比如2秒后完成
// 在实际应用中，这通常是一个非阻塞的I/O操作，例如GuzzleHttp\Client的异步请求
// 为了演示，我们用一个简单的延迟来模拟
echo "任务开始...\n";
$timeStart = microtime(true);

// 假设我们有一个后台进程或另一个线程在处理这个任务
// 当任务完成时，我们会调用resolve或reject
// 这里我们用一个简单的定时器来模拟异步完成
$loop = React\EventLoop\Factory::create();
$loop->addTimer(2, function () use ($promise, $timeStart) {
    if (rand(0, 1)) { // 随机成功或失败
        $promise->resolve('数据已成功获取！耗时：' . round(microtime(true) - $timeStart, 2) . '秒');
    } else {
        $promise->reject(new \Exception('数据获取失败！'));
    }
});

// 注册Promise的成功和失败回调
$promise->then(
    function ($value) {
        echo "Promise成功兑现: " . $value . "\n";
    },
    function (\Throwable $reason) {
        echo "Promise被拒绝: " . $reason->getMessage() . "\n";
    }
);

echo "主程序继续执行其他任务...\n";

// 在真实异步场景中，你需要一个事件循环来驱动Promise的执行
// 例如：
// GuzzleHttp\Promise\Utils::queue()->run();
// 但在很多简单的脚本中，我们可能需要等待所有Promise完成
// 此时可以使用wait()方法，它会阻塞直到Promise完成
try {
    echo "最终结果: " . $promise->wait() . "\n"; // 这行会阻塞直到Promise完成
} catch (\Throwable $e) {
    echo "最终结果（失败）: " . $e->getMessage() . "\n";
}

echo "所有任务完成。\n";</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();
$firstPromise
    ->then(function ($value) {
        echo "第一步完成，收到: " . $value . "\n";
        // 返回一个新的值，这个值会传递给下一个then
        return "处理后的 " . $value;
    })
    ->then(function ($value) {
        echo "第二步完成，收到: " . $value . "\n";
        // 返回一个新的Promise，下一个then会等待这个Promise完成
        $nextStepPromise = new Promise();
        $nextStepPromise->resolve("最终数据 " . $value);
        return $nextStepPromise;
    })
    ->then(function ($value) {
        echo "第三步完成，收到: " . $value . "\n";
    });

$firstPromise->resolve('原始数据'); // 触发Promise链的开始

// 同样，需要等待Promise链完成
$firstPromise->wait();</code>