告别回调地狱与阻塞等待：如何使用GuzzlePromises优雅管理PHP异步操作

<pre class="brush:php;toolbar:false;">// 伪代码：同步执行多个耗时操作
$data1 = fetch_from_api_1(); // 等待这里完成
$data2 = fetch_from_api_2(); // 再等待这里完成
$data3 = fetch_from_api_3(); // 继续等待...

process_data($data1, $data2, $data3);

fetch_from_api_x()

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

guzzlehttp/promises

then()

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo 'Promise 成功完成，值为: ' . $value . PHP_EOL;
    },
    function ($reason) {
        echo 'Promise 被拒绝，原因为: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成
// 假设这里是某个耗时操作完成后，我们手动解决 Promise
$promise->resolve('这是异步操作的结果');
// 输出：Promise 成功完成，值为: 这是异步操作的结果

$promise->resolve('...')

onFulfilled

guzzlehttp/promises

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo '第一步完成，接收到: ' . $value . PHP_EOL;
        // 返回一个新值，传递给下一个 then
        return $value . ' + 第二步处理';
    })
    ->then(function ($value) {
        echo '第二步完成，接收到: ' . $value . PHP_EOL;
        // 甚至可以返回另一个 Promise，实现 Promise 转发
        $anotherPromise = new Promise();
        // 模拟另一个异步操作
        // $anotherPromise->resolve('来自另一个 Promise 的结果');
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo '最终结果: ' . $value . PHP_EOL;
    });

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

// 假设在某个时间点，第二个 Promise 也完成了
// 如果不调用，第三个 then 不会执行
// $anotherPromise->resolve('来自另一个 Promise 的结果');

guzzlehttp/promises

guzzlehttp/promises

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 这是一个会在 wait() 被调用时执行的函数，用于解析 Promise
    sleep(1); // 模拟耗时操作
    $promise->resolve('等待结束，结果已返回');
});

echo '程序继续执行其他任务...' . PHP_EOL;
$result = $promise->wait(); // 这里会阻塞，直到 Promise 完成
echo '获取到结果: ' . $result . PHP_EOL;
// 输出：
// 程序继续执行其他任务...
// 获取到结果: 等待结束，结果已返回 (等待了1秒)

cancel()

reject()

onFulfilled

onRejected

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        throw new Exception('第一步出错啦！'); // 抛出异常
    })
    ->then(null, function ($reason) { // 第二个 then 的 onRejected 回调
        echo '捕获到错误: ' . $reason->getMessage() . PHP_EOL;
        return '错误已被处理'; // 返回一个值，将链条从拒绝状态转为解决状态
    })
    ->then(function ($value) {
        echo '错误处理后继续: ' . $value . PHP_EOL;
    });

$promise->resolve('开始');
// 输出：
// 捕获到错误: 第一步出错啦！
// 错误处理后继续: 错误已被处理

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises