如何解决PHP异步操作回调地狱问题，使用GuzzlePromises助你优雅处理非阻塞任务

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

<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;
    }
);

// 模拟异步操作成功
echo "开始执行异步任务..." . PHP_EOL;
// 假设这里有一些耗时操作...
sleep(1); // 模拟1秒延迟
$promise->resolve('Hello, World!'); // 兑现 Promise

// 模拟异步操作失败
// $promise->reject('出错了！'); // 如果这里拒绝，则会触发 $onRejected 回调

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：收到值 - " . $value . PHP_EOL;
        return $value . ' Guzzle'; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步：处理值 - " . $value . PHP_EOL;
        // 可以在这里返回另一个 Promise，实现更复杂的异步流程
        $anotherPromise = new Promise();
        // 模拟另一个异步操作
        // $anotherPromise->resolve(' Promises!');
        return $anotherPromise; // 将这个 Promise 传递下去
    })
    ->then(function ($value) {
        echo "第三步：最终结果 - " . $value . PHP_EOL;
    })
    ->then(null, function ($reason) { // 链式末尾统一处理错误
        echo "链中发生错误: " . $reason . PHP_EOL;
    });

// 触发第一个 Promise
$promise->resolve('Hello,');

// 触发第二个 Promise (如果它被返回了)
// 注意：如果上一个 then 返回的是 Promise，则下一个 then 会等待该 Promise 完成
// 这里为了演示，我们手动解析第二个 Promise
// 假设在某个异步操作完成后，我们解析了 $anotherPromise
// 实际上，如果上面返回的是 $anotherPromise，那么这里应该由异步操作自身去解析
// 这里为了演示效果，我们假设在某个点，这个 $anotherPromise 被解析了
// $anotherPromise->resolve(' Promises!'); // 这行代码需要放在适当的异步回调中执行

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功: " . $value . PHP_EOL;
        // 模拟一个错误发生
        throw new \Exception('Oops, something went wrong!');
        return '继续执行';
    })
    ->then(function ($value) {
        echo "这行代码不会被执行，因为前面抛出了异常。" . PHP_EOL;
    })
    ->otherwise(function (\Exception $e) { // 使用 otherwise 捕获链中所有拒绝
        echo "捕获到异常: " . $e->getMessage() . PHP_EOL;
        return new RejectedPromise('再次拒绝'); // 也可以再次拒绝，传递新的错误信息
    })
    ->then(null, function ($reason) {
        echo "最终的拒绝原因: " . $reason . PHP_EOL;
    });

$promise->resolve('初始数据');

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个异步操作，最终会解析 Promise
    sleep(1);
    $promise->resolve('异步操作完成！');
});

echo "等待 Promise 完成..." . PHP_EOL;
try {
    $result = $promise->wait(); // 会阻塞直到 Promise 完成
    echo "同步获取到结果: " . $result . PHP_EOL;
} catch (\Exception $e) {
    echo "同步等待时发生错误: " . $e->getMessage() . PHP_EOL;
}