告别PHP异步回调地狱：如何使用Composer和GuzzlePromises优雅处理并发操作

guzzlehttp/promises

guzzlehttp/promises

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

autoload.php

onFulfilled

onRejected

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "操作成功： " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "操作失败： " . $reason . PHP_EOL;
    }
);

// 模拟异步操作成功
$promise->resolve('数据已获取'); // 输出: 操作成功： 数据已获取

// 模拟异步操作失败
// $promise->reject('API调用失败'); // 输出: 操作失败： API调用失败

.then()

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

$firstPromise = new Promise();

$firstPromise
    ->then(function ($value) {
        echo "第一步成功： " . $value . PHP_EOL;
        // 返回一个新的值，它会传递给下一个 then
        return $value . ' + 额外处理';
    })
    ->then(function ($newValue) {
        echo "第二步成功： " . $newValue . PHP_EOL;
        // 甚至可以返回一个新的 Promise，实现异步操作的顺序执行
        $anotherPromise = new Promise();
        // 模拟一个稍后会解决的异步操作
        // sleep(1); // 实际应用中这里是异步I/O
        $anotherPromise->resolve('最终结果');
        return $anotherPromise;
    })
    ->then(function ($finalResult) {
        echo "所有步骤完成，最终结果： " . $finalResult . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 使用 otherwise() 捕获链中任何位置的拒绝
        echo "链中发生错误： " . $reason . PHP_EOL;
    });

// 启动第一个 Promise
$firstPromise->resolve('原始数据');
// 输出:
// 第一步成功： 原始数据
// 第二步成功： 原始数据 + 额外处理
// 所有步骤完成，最终结果： 最终结果

guzzlehttp/promises

wait()

cancel()

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

$apiCallPromise = new Promise(function () use (&$apiCallPromise) {
    // 模拟一个耗时的API调用
    // sleep(2);
    $apiCallPromise->resolve('API返回的数据');
});

echo "开始等待..." . PHP_EOL;
$result = $apiCallPromise->wait(); // 会阻塞当前执行，直到 Promise 完成
echo "等待结束，结果：" . $result . PHP_EOL; // 输出: API返回的数据

// 对于尚未完成的 Promise，可以尝试取消
$longRunningTask = new Promise(
    function () { /* 实际的耗时操作 */ },
    function () { echo "任务被取消了！" . PHP_EOL; } // 取消回调
);
// $longRunningTask->cancel(); // 尝试取消任务

guzzlehttp/promises