告别PHP异步编程的“回调地狱”：GuzzlePromises与Composer助你优雅处理并发请求

<code class="php">// 伪代码：一个典型的“回调地狱”场景
function processOrder($orderId, $callback) {
    // 1. 调用用户服务获取用户积分 (异步操作 A)
    callUserService('getUserPoints', $orderId, function($points) use ($orderId, $callback) {
        // 2. 调用商品服务检查库存 (异步操作 B)
        callProductService('checkStock', $orderId, function($stockStatus) use ($orderId, $points, $callback) {
            if ($stockStatus === 'available') {
                // 3. 调用物流服务推送订单 (异步操作 C)
                callLogisticsService('pushOrder', $orderId, function($logisticsId) use ($points, $callback) {
                    // 所有操作完成后，执行最终回调
                    $callback("订单处理成功，积分：{$points}，物流ID：{$logisticsId}");
                });
            } else {
                $callback("库存不足，订单处理失败");
            }
        });
    });
}

// 调用示例
processOrder(123, function($result) {
    echo $result;
});</code>

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

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

$promise = new Promise();

// 模拟一个异步操作，比如2秒后返回结果
// 实际应用中，这里可能是一个网络请求、文件读取等
$someAsyncTask = function() use ($promise) {
    sleep(2); // 模拟耗时
    if (rand(0, 1)) {
        $promise->resolve('异步操作成功完成！');
    } else {
        $promise->reject('异步操作失败了！');
    }
};

// 启动异步任务（这里只是模拟，实际可能是通过事件循环或线程池）
// 在真实的异步框架中，你不会直接在这里调用 $someAsyncTask()
// 而是将其注册到事件循环中
// 为了演示，我们暂时直接调用
// $someAsyncTask(); // 如果直接调用，会阻塞</code>

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

$fetchUserDataPromise = new Promise();
$fetchProductDataPromise = new Promise();

// 模拟获取用户数据
$fetchUserDataPromise->then(function ($userId) {
    echo "获取用户数据成功：用户ID {$userId}\n";
    // 返回一个新的Promise，用于后续操作
    return $fetchProductDataPromise; // 模拟下一个异步操作
}, function ($reason) {
    echo "获取用户数据失败：{$reason}\n";
    throw new \Exception("用户数据获取失败"); // 抛出异常以传播失败
})->then(function ($productId) {
    echo "获取商品数据成功：商品ID {$productId}\n";
    return "所有数据获取完毕！";
}, function ($reason) {
    echo "获取商品数据失败：{$reason}\n";
    return "部分数据获取失败，但流程继续。"; // 捕获并处理失败，不中断链条
})->then(function ($finalMessage) {
    echo "最终结果：{$finalMessage}\n";
});

// 模拟异步操作的完成顺序
$fetchUserDataPromise->resolve(123); // 触发第一个then
// 模拟一段时间后，第二个异步操作完成
// sleep(1); // 模拟延迟
$fetchProductDataPromise->resolve(456); // 触发第二个then</code>

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解析Promise
    sleep(1);
    $promise->resolve('这是异步操作的结果！');
});

try {
    echo "开始等待Promise...\n";
    $result = $promise->wait(); // 阻塞当前执行，直到Promise完成
    echo "Promise已完成，结果是: " . $result . "\n";
} catch (RejectionException $e) {
    echo "Promise被拒绝了: " . $e->getReason() . "\n";
} catch (\Exception $e) {
    echo "发生异常: " . $e->getMessage() . "\n";
}</code>

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

$promise = new Promise();

$promise->then(null, function ($reason) {
    echo "Promise被拒绝了，原因：{$reason}\n";
    // 可以在这里返回一个新的Promise，或者抛出异常
    return new RejectedPromise('再次拒绝，因为：' . $reason);
})->otherwise(function ($reason) { // otherwise 是 then(null, $onRejected) 的语法糖
    echo "再次捕获拒绝：{$reason}\n";
    return '错误已处理，返回默认值'; // 返回非Promise值，将链条转为成功状态
})->then(function ($value) {
    echo "链条最终成功：{$value}\n";
});

$promise->reject('网络连接失败'); // 触发拒绝</code>