告别PHP异步回调地狱：如何使用GuzzlePromises构建优雅的并行处理

<code class="php">// 伪代码：一个典型的“回调地狱”
callPaymentApi(orderId, function(paymentResult) {
    if (paymentResult.success) {
        callInventoryApi(orderId, function(inventoryResult) {
            if (inventoryResult.success) {
                callShippingApi(orderId, function(shippingResult) {
                    if (shippingResult.success) {
                        sendSms(orderId, function(smsResult) {
                            // 终于完成了...
                        });
                    } else {
                        // 处理发货失败
                    }
                });
            } else {
                // 处理库存失败
            }
        });
    } else {
        // 处理支付失败
    }
});</code>

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

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

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功：{$value}\n";
        // 返回一个值，这个值会传递给下一个then
        return $value . ' + 第二步';
    })
    ->then(function ($value) {
        echo "第二步成功：{$value}\n";
        // 你甚至可以在这里返回一个新的Promise，实现异步操作的串联
        $anotherPromise = new Promise();
        // 模拟异步操作，稍后解决
        // $anotherPromise->resolve('最终结果');
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "最终成功：{$value}\n";
    }, function ($reason) {
        echo "操作失败：{$reason}\n";
    });

// 模拟异步操作的完成
$promise->resolve('初始数据');
// 如果第二步返回了 $anotherPromise，你需要手动解决它才能触发最终成功
// $anotherPromise->resolve('最终结果');</code>

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：{$value}\n";
        // 模拟一个错误
        throw new \Exception('第一步出错啦！');
        // 或者返回一个被拒绝的Promise
        // return new RejectedPromise('第一步被拒绝了！');
    })
    ->then(function ($value) {
        echo "第二步成功：{$value}\n"; // 这行不会执行
    })
    ->otherwise(function ($reason) { // 捕获链中任何位置的拒绝
        echo "捕获到错误：{$reason->getMessage()}\n";
    });

$promise->resolve('开始');
// 输出：第一步：开始
// 输出：捕获到错误：第一步出错啦！</code>

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(1);
    $promise->resolve('数据已准备好');
});

echo "等待Promise完成...\n";
$result = $promise->wait(); // 会阻塞当前进程1秒
echo "Promise结果：{$result}\n"; // 输出：Promise结果：数据已准备好</code>