如何优雅地处理PHP异步操作的复杂性，GuzzlePromises助你构建高性能应用

<code class="php">// 伪代码：一个典型的回调地狱
ApiA::request(function($resultA) {
    // 处理 resultA
    ApiB::request($resultA->id, function($resultB) {
        // 处理 resultB
        ApiC::request($resultB->data, function($resultC) {
            // 处理 resultC，并最终返回给用户
        });
    });
});</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;

// 1. 创建一个Promise对象
$promise = new Promise();

// 2. 注册成功回调 (onFulfilled) 和失败回调 (onRejected)
$promise->then(
    function ($value) {
        echo "Promise 成功兑现，值是: " . $value . PHP_EOL;
        // 你可以在这里返回一个新的值或一个新的Promise，继续链式调用
        return "处理后的: " . $value;
    },
    function ($reason) {
        echo "Promise 被拒绝，原因是: " . $reason . PHP_EOL;
        // 同样，这里也可以返回一个值或一个新的RejectedPromise
        return new RejectedPromise("错误处理后的原因: " . $reason);
    }
);

// 3. 兑现这个Promise (模拟异步操作成功)
echo "开始兑现 Promise..." . PHP_EOL;
$promise->resolve('原始数据');
echo "Promise 兑现指令已发送。" . PHP_EOL;

echo "--------------------" . PHP_EOL;

// 4. 链式调用示例：告别回调地狱
$chainedPromise = new Promise();
$chainedPromise
    ->then(function ($value) {
        echo "第一步处理: " . $value . PHP_EOL;
        return $value . " -> 第二步"; // 返回一个新值，传递给下一个then
    })
    ->then(function ($value) {
        echo "第二步处理: " . $value . PHP_EOL;
        // 模拟一个异步操作，返回一个Promise
        $innerPromise = new Promise();
        // 假设这里是调用一个API，2秒后返回
        // 实际应用中，这里会是 GuzzleHttp\Client 的异步请求
        // 例如：$client->getAsync('some-api-url')
        echo "模拟内部异步操作..." . PHP_EOL;
        // 真实场景下，你会在一个非阻塞的循环中 resolve/reject 这个 innerPromise
        // 这里为了演示，我们直接 resolve
        $innerPromise->resolve($value . " -> 第三步");
        return $innerPromise; // 返回一个Promise，链条会等待它完成
    })
    ->then(function ($value) {
        echo "第三步处理: " . $value . PHP_EOL;
        return "最终结果: " . $value;
    })
    ->then(function ($finalValue) {
        echo $finalValue . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 统一的错误处理
        echo "链式调用中途出错: " . $reason . PHP_EOL;
    });

// 触发链式调用
$chainedPromise->resolve('初始数据');

// Guzzle Promises还提供了同步等待结果的能力 (不推荐在生产环境阻塞主线程)
// 但在某些测试或特定场景下非常有用
// echo $chainedPromise->wait(); // 会阻塞直到所有链式Promise完成并返回最终值

// 模拟拒绝一个Promise
$rejectedPromise = new Promise();
$rejectedPromise
    ->then(null, function ($reason) {
        echo "捕获到拒绝原因: " . $reason . PHP_EOL;
        throw new \Exception("进一步处理错误: " . $reason); // 抛出异常会传递给下一个otherwise
    })
    ->otherwise(function ($e) {
        echo "最终错误处理: " . $e->getMessage() . PHP_EOL;
    });

$rejectedPromise->reject('数据验证失败');

?></code>