如何优雅地处理PHP异步操作？GuzzlePromises助你告别阻塞与回调地狱

<code class="php">// 伪代码：传统串行请求
$dataFromApiA = callApiA(); // 等待 API A 完成
$dataFromApiB = callApiB(); // 等待 API B 完成
$result = processData($dataFromApiA, $dataFromApiB);
// 整个过程耗时 = API A耗时 + API B耗时 + 处理时间</code>

<code class="php">// 伪代码：复杂的回调嵌套（回调地狱）
callApiA(function($dataA) use ($userId) {
    processDataA($dataA, function($processedA) use ($userId) {
        callApiB($processedA, function($dataB) use ($userId) {
            updateUser($userId, $dataB, function($success) {
                // ... 难以阅读和维护
            });
        });
    });
});</code>

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

<code class="php"><?php
require 'vendor/autoload.php';

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

// 模拟一个异步操作，例如从外部 API 获取数据
// 在实际应用中，这里会是发起 cURL 请求或数据库查询等
// 注意：在没有事件循环的情况下，waitFn 只有在 wait() 被调用时才会执行
function simulateAsyncOperation(string $dataToReturn, bool $shouldFail = false): Promise
{
    // Promise 构造函数可以接受一个 waitFn，在 Promise 被等待时执行
    $promise = new Promise(function () use (&$promise, $dataToReturn, $shouldFail) {
        echo "模拟异步操作开始...\n";
        // 模拟耗时操作，例如网络请求
        sleep(1); // 阻塞1秒，仅用于演示 Promise 的概念

        if ($shouldFail) {
            $promise->reject("模拟错误：无法获取数据！");
        } else {
            $promise->resolve($dataToReturn);
        }
        echo "模拟异步操作结束。\n";
    });
    return $promise;
}

echo "--- 场景一：成功链式处理异步结果 ---\n";
$firstPromise = simulateAsyncOperation("用户数据");

$firstPromise
    ->then(function ($data) {
        echo "第一步：成功获取到原始数据: " . $data . "\n";
        // 模拟数据处理，并返回一个新的值（会被包装成一个已解决的 Promise）
        return "处理后的" . $data;
    })
    ->then(function ($processedData) {
        echo "第二步：数据已处理并准备展示: " . $processedData . "\n";
        // 返回一个 Promise，模拟另一个异步操作（例如获取关联数据）
        return simulateAsyncOperation("关联推荐数据");
    })
    ->then(function ($recommendationData) {
        echo "第三步：获取到关联推荐数据: " . $recommendationData . "\n";
    })
    ->otherwise(function (\Exception $reason) { // 统一错误处理，捕获链中任何拒绝
        echo "操作失败: " . $reason->getMessage() . "\n";
    });

// 强制所有 Promise 完成。在没有事件循环的同步PHP脚本中，
// wait() 是触发 Promise 实际执行和链式回调的关键。
// 它会阻塞当前脚本直到 Promise 完成。
echo "等待所有 Promise 完成...\n";
$firstPromise->wait();
echo "所有 Promise 已完成。\n\n";


echo "--- 场景二：处理异步操作的拒绝状态 ---\n";
$failedPromise = simulateAsyncOperation("无效数据", true); // 模拟失败

$failedPromise
    ->then(
        function ($value) {
            echo "不应该执行此成功回调: " . $value . "\n";
        },
        function ($reason) {
            echo "异步操作被拒绝，原因: " . $reason . "\n";
            // 在错误处理后，可以返回一个值，使后续链变为成功状态
            return "已从错误中恢复，继续执行";
        }
    )
    ->then(function ($recoveredValue) {
        echo "从错误中恢复并继续执行: " . $recoveredValue . "\n";
        // 也可以再次返回一个 RejectedPromise 来继续传递拒绝状态
        // return new RejectedPromise("新的拒绝原因");
    })
    ->otherwise(function ($finalReason) {
        echo "最终的错误处理: " . $finalReason . "\n";
    });

echo "等待失败的 Promise 完成...\n";
$failedPromise->wait();
echo "失败的 Promise 已完成。\n";</code>