如何解决PHP异步操作的“回调地狱”与阻塞问题，GuzzlePromises助你优雅掌控未来

<pre class="brush:php;toolbar:false;">// 伪代码，展示回调地狱
makeApiCall1(function($result1) {
    processResult1($result1);
    makeApiCall2(function($result2) {
        processResult2($result2);
        makeApiCall3(function($result3) {
            processResult3($result3);
            // ... 更多层级
            finalProcess($result1, $result2, $result3);
        });
    });
});

<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 "操作成功，结果是: " . $value . "\n";
    },
    function ($reason) {
        echo "操作失败，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作成功完成
$promise->resolve('数据已获取'); // 这将触发第一个回调
// 输出: 操作成功，结果是: 数据已获取

// 模拟异步操作失败
// $promise->reject('网络连接超时'); // 这将触发第二个回调
// 输出: 操作失败，原因是: 网络连接超时

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步处理: " . $value . "\n";
        return "处理后的数据 " . $value; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步处理: " . $value . "\n";
        // 你也可以返回一个新的 Promise，下一个 then 会等待这个 Promise 完成
        return new Promise(function () use (&$nextPromise) {
            $nextPromise->resolve('最终数据');
        });
    })
    ->then(function ($value) {
        echo "第三步处理 (接收到嵌套 Promise 的结果): " . $value . "\n";
    });

$nextPromise = new Promise(); // 用于演示嵌套 Promise

// 解决初始 Promise，启动链式调用
$promise->resolve('原始数据');
// 输出:
// 第一步处理: 原始数据
// 第二步处理: 处理后的数据 原始数据
// 第三步处理 (接收到嵌套 Promise 的结果): 最终数据

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功处理: " . $value . "\n";
        throw new Exception('处理中发生错误！'); // 抛出异常
    })
    ->then(
        function ($value) {
            echo "这条成功回调不会被执行。\n";
        },
        function ($reason) {
            echo "捕获到错误: " . $reason->getMessage() . "\n";
            return new RejectedPromise('错误已处理，但仍需拒绝！'); // 返回 RejectedPromise 继续传递拒绝状态
        }
    )
    ->then(
        null, // 忽略成功回调
        function ($reason) {
            echo "再次捕获错误: " . $reason . "\n";
            return "从错误中恢复！"; // 返回非 RejectedPromise，将链条转为成功状态
        }
    )
    ->then(function ($value) {
        echo "最终状态: " . $value . "\n";
    });

$promise->resolve('初始值');
// 输出:
// 成功处理: 初始值
// 捕获到错误: 处理中发生错误！
// 再次捕获错误: 错误已处理，但仍需拒绝！
// 最终状态: 从错误中恢复！

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个异步操作
    usleep(10000); // 10ms
    $promise->resolve('同步等待的结果');
});

echo "等待 Promise 完成...\n";
$result = $promise->wait(); // 阻塞直到 Promise 完成
echo "得到结果: " . $result . "\n";
// 输出:
// 等待 Promise 完成...
// 得到结果: 同步等待的结果