如何优雅地处理PHP异步操作的“回调地狱”？GuzzlePromises助你构建高效、可维护的应用

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

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

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

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

// 3. 在某个时刻，异步操作完成，我们手动解决（resolve）或拒绝（reject）Promise
// 模拟异步成功
$promise->resolve('这是异步操作的结果');
// 输出: 操作成功，得到值: 这是异步操作的结果

// 模拟异步失败
// $promise->reject('API请求超时');
// 输出: 操作失败，原因: API请求超时

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个异步操作成功后执行
        echo "第一步完成，得到: " . $value . PHP_EOL;
        return $value . ' + 第二步处理'; // 返回一个值，传递给下一个then
    })
    ->then(function ($newValue) {
        // 第二个异步操作成功后执行
        echo "第二步完成，得到: " . $newValue . PHP_EOL;
        // 假设这里返回另一个Promise，后续链条会等待这个Promise完成
        return new Promise(function ($resolve) use ($newValue) {
            echo "模拟异步任务...". PHP_EOL;
            sleep(1); // 模拟耗时操作
            $resolve($newValue . ' + 第三步处理');
        });
    })
    ->then(function ($finalValue) {
        // 第三个异步操作成功后执行
        echo "所有步骤完成，最终结果: " . $finalValue . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 使用otherwise捕获链条中的任何拒绝
        echo "链条中发生错误: " . $reason . PHP_EOL;
    });

// 启动Promise链
$promise->resolve('初始数据');

// 注意：在实际的异步场景中，你可能需要一个事件循环来驱动Promise的异步执行
// 但Guzzle Promises在同步等待时会自动处理任务队列。

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个异步操作，最终会解决Promise
    echo "开始等待..." . PHP_EOL;
    sleep(2); // 模拟耗时
    $promise->resolve('异步操作完成！');
});

// 同步等待Promise完成，并获取其结果
echo "等待结果: " . $promise->wait() . PHP_EOL;
// 输出：
// 开始等待...
// 等待结果: 异步操作完成！