如何解决PHP异步操作中的“回调地狱”和阻塞问题，GuzzlePromises助你优雅驾驭并发！

<pre class="brush:php;toolbar:false;">// 假设这是同步调用
$dataA = callApiA(); // 阻塞，直到API A返回
$dataB = callApiB($dataA); // 阻塞，直到API B返回
$result = processData($dataB);
echo $result;

fulfilled

rejected

pending

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

resolve

reject

<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
// $promise->reject('操作过程中发生了错误！'); // 如果执行这行，则输出: Promise 失败，原因为: 操作过程中发生了错误！

then()

then()

then()

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

$firstPromise = new Promise();
$secondPromise = new Promise();

$firstPromise
    ->then(function ($value) use ($secondPromise) {
        echo "第一步完成，值是: " . $value . PHP_EOL;
        // 返回第二个 Promise，后续链会等待它完成
        return $secondPromise;
    })
    ->then(function ($value) {
        echo "第二步完成，值是: " . $value . PHP_EOL;
    });

// 解决第一个 Promise，触发第一个 then 回调
$firstPromise->resolve('数据A'); // 输出: 第一步完成，值是: 数据A

// 解决第二个 Promise，触发第二个 then 回调
$secondPromise->resolve('数据B'); // 输出: 第二步完成，值是: 数据B

onRejected

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 假设这里发生了错误
        throw new \Exception('第一步操作失败！');
    })
    ->then(null, function ($reason) { // 第二个参数是 onRejected 回调
        echo "在第二步捕获到错误: " . $reason->getMessage() . PHP_EOL;
        // 你也可以选择继续抛出或返回一个 RejectedPromise 来向下传递错误
        // return new RejectedPromise('新的错误原因');
    })
    ->then(function ($value) {
        echo "这个不会被执行，因为前面有错误。" . PHP_EOL;
    }, function ($reason) {
        echo "如果前面返回了 RejectedPromise，这里会再次捕获: " . $reason . PHP_EOL;
    });

$promise->resolve('开始'); // 输出: 在第二步捕获到错误: 第一步操作失败！

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1); // 暂停1秒
    $promise->resolve('我等到了！');
});

echo "开始等待 Promise..." . PHP_EOL;
$result = $promise->wait(); // 阻塞1秒
echo "Promise 结果: " . $result . PHP_EOL; // 输出: Promise 结果: 我等到了！

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Utils;
// ... 你的事件循环设置 ...

// 在事件循环的每次 tick 中运行任务队列
// $loop->addPeriodicTimer(0, [Utils::queue(), 'run']);