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

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

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

// 创建一个Promise实例
$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作成功，兑现Promise
$promise->resolve('这是异步操作的结果');
// 输出: 操作成功，结果是: 这是异步操作的结果

// 模拟异步操作失败，拒绝Promise
// $promise->reject('网络连接错误');
// 输出: 操作失败，原因是: 网络连接错误</code>

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

$promise = new Promise();

$promise
    // 第一个then：处理初始值，并返回一个新的Promise（或值）
    ->then(function ($initialValue) {
        echo "第一步：处理初始值 '{$initialValue}'..." . PHP_EOL;
        // 模拟一个耗时操作，返回一个新的Promise
        return new Promise(function ($resolve) use ($initialValue) {
            // 假设这里是调用API 1，并将结果传递下去
            sleep(1); // 模拟耗时
            $resolve("处理过的: " . $initialValue . " + API1数据");
        });
    })
    // 第二个then：接收上一个Promise的结果
    ->then(function ($processedValue) {
        echo "第二步：接收到 '{$processedValue}'..." . PHP_EOL;
        // 模拟调用API 2
        return new Promise(function ($resolve) use ($processedValue) {
            sleep(1); // 模拟耗时
            $resolve("最终结果: " . $processedValue . " + API2数据");
        });
    })
    // 第三个then：接收最终结果
    ->then(function ($finalResult) {
        echo "第三步：得到最终结果 '{$finalResult}'" . PHP_EOL;
        return $finalResult; // 返回最终值
    })
    // 捕获链中任何环节的错误
    ->otherwise(function ($reason) {
        echo "链式操作中发生错误: " . $reason . PHP_EOL;
    });

// 启动Promise链，传入初始值
$promise->resolve('原始数据');

// 注意：在实际异步场景中，你需要一个事件循环来驱动Promise的执行。
// 但对于演示，我们可以使用 wait() 方法强制同步等待结果。
echo "等待所有异步操作完成..." . PHP_EOL;
try {
    $promise->wait(); // 强制等待Promise完成
} catch (\Exception $e) {
    echo "Wait抛出异常: " . $e->getMessage() . PHP_EOL;
}
echo "所有操作完成。" . PHP_EOL;</code>

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

// 模拟两个独立的异步操作
$promiseA = new Promise(function ($resolve) {
    echo "Promise A 开始..." . PHP_EOL;
    sleep(2); // 模拟耗时
    $resolve('数据来自A');
    echo "Promise A 完成。" . PHP_EOL;
});

$promiseB = new Promise(function ($resolve) {
    echo "Promise B 开始..." . PHP_EOL;
    sleep(1); // 模拟耗时
    $resolve('数据来自B');
    echo "Promise B 完成。" . PHP_EOL;
});

echo "同时等待 Promise A 和 Promise B..." . PHP_EOL;

// 使用 Utils::all() 等待所有Promise完成
// 注意：在实际应用中，如果你的PHP环境没有事件循环，
// Guzzle promises的内部任务队列可能需要手动运行，
// 或者依赖如GuzzleHttp\Client发起的请求会自动驱动。
// 这里的 sleep() 模拟了外部异步操作的耗时。
$results = Utils::all([$promiseA, $promiseB])->wait();

echo "所有Promise都已完成，结果如下：" . PHP_EOL;
print_r($results);
// 输出：
// Promise A 开始...
// Promise B 开始...
// (等待1秒后) Promise B 完成。
// (等待1秒后) Promise A 完成。
// 所有Promise都已完成，结果如下：
// Array
// (
//     [0] => 数据来自A
//     [1] => 数据来自B
// )</code>