解决PHP异步操作的“回调地狱”与阻塞问题，GuzzlePromise助你构建高效非阻塞应用

<pre class="brush:php;toolbar:false;">// 伪代码，展示回调地狱的雏形
callLogisticsApi(orderId, function($logisticsResult) {
    updateInventory(orderId, function($inventoryResult) {
        sendEmail(orderId, function($emailResult) {
            // ... 更多嵌套
        });
    });
});

guzzlehttp/promises

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

then()

then()

onFulfilled

onRejected

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

$promise = new Promise();

// 模拟一个异步操作，比如API请求
// 假设这个操作需要一些时间
// 最终会通过 resolve 或 reject 来改变 promise 的状态
// 这里我们先手动 resolve
$promise->then(
    // 成功回调
    function ($value) {
        echo "操作成功！结果是: " . $value . PHP_EOL;
        return "处理后的结果: " . $value; // 返回一个新值，传递给下一个 then
    },
    // 失败回调
    function ($reason) {
        echo "操作失败！原因: " . $reason . PHP_EOL;
        throw new \Exception("处理失败: " . $reason); // 抛出异常，传递给下一个 then 的失败回调
    }
);

// 假设异步操作成功完成
$promise->resolve('订单创建成功');
// 输出：操作成功！结果是: 订单创建成功

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

// 假设异步操作失败
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) { // 第一个参数为 null 表示不处理成功
    echo "另一个操作失败！原因: " . $reason . PHP_EOL;
});
$anotherPromise->reject('物流API连接超时');
// 输出：另一个操作失败！原因: 物流API连接超时

then()

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

$orderPromise = new Promise();

$orderPromise
    ->then(function ($orderId) {
        echo "1. 订单创建成功，ID: {$orderId}" . PHP_EOL;
        // 模拟调用物流API，返回一个新的 Promise
        return new Promise(function ($resolve) use ($orderId) {
            echo "   -> 正在调用物流API..." . PHP_EOL;
            // 假设物流API在1秒后返回成功
            sleep(1);
            $resolve("物流单号: L" . $orderId . "001");
        });
    })
    ->then(function ($trackingNumber) {
        echo "2. 物流信息已获取: {$trackingNumber}" . PHP_EOL;
        // 模拟更新库存，返回一个 Promise
        return new Promise(function ($resolve) use ($trackingNumber) {
            echo "   -> 正在更新库存..." . PHP_EOL;
            sleep(0.5);
            $resolve("库存更新完成 for " . $trackingNumber);
        });
    })
    ->then(function ($message) {
        echo "3. " . $message . PHP_EOL;
        // 模拟发送邮件，返回一个 Promise
        return new Promise(function ($resolve) {
            echo "   -> 正在发送确认邮件..." . PHP_EOL;
            sleep(0.3);
            $resolve("邮件发送成功！");
        });
    })
    ->then(function ($finalMessage) {
        echo "4. 所有操作完成: " . $finalMessage . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作链中发生错误: " . $reason . PHP_EOL;
    });

// 启动第一个 Promise
$orderPromise->resolve(12345);

// 注意：在实际的异步环境中（如ReactPHP），你需要运行事件循环来驱动 Promise 的执行。
// 在同步脚本中，你可能需要调用 wait() 来强制 Promise 完成。
// 但为了演示链式调用的效果，我们这里先不强调 wait()。
// Guzzle Promise 在内部通过任务队列处理，保持堆栈深度恒定，避免无限递归。
\GuzzleHttp\Promise\Utils::queue()->run(); // 确保所有任务被执行

otherwise()

reject

onRejected

otherwise()

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

$failingPromise = new Promise();

$failingPromise
    ->then(function ($value) {
        echo "第一步成功: " . $value . PHP_EOL;
        throw new \Exception("模拟第二步失败！"); // 抛出异常
    })
    ->then(function ($value) {
        echo "第二步成功: " . $value . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何位置的错误
        echo "捕获到错误: " . $reason->getMessage() . PHP_EOL;
    });

$failingPromise->resolve('初始数据');
\GuzzleHttp\Promise\Utils::queue()->run();
// 输出：
// 第一步成功: 初始数据
// 捕获到错误: 模拟第二步失败！

guzzlehttp/promises