告别回调地狱：如何使用GuzzlePromises优雅管理PHP异步操作与复杂任务

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

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

// 创建一个 Promise 实例
$promise = new Promise();

$promise->then(
    // $onFulfilled: 当 Promise 成功时执行
    function ($value) {
        echo "Promise 成功： " . $value . PHP_EOL;
    },
    // $onRejected: 当 Promise 失败时执行
    function ($reason) {
        echo "Promise 失败： " . $reason . PHP_EOL;
    }
);

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

// 模拟异步操作完成并失败
// $anotherPromise = new Promise();
// $anotherPromise->then(
//     function ($value) { echo "成功： " . $value . PHP_EOL; },
//     function ($reason) { echo "失败： " . $reason . PHP_EOL; }
// );
// $anotherPromise->reject('网络错误'); // 输出：Promise 失败： 网络错误

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理 " . $value . PHP_EOL;
        return $value . "，并进行下一步处理"; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($newValue) {
        echo "第二步：接收到 " . $newValue . PHP_EOL;
        // 假设这里又是一个异步操作，返回一个新的 Promise
        $nextAsyncOperation = new Promise();
        $nextAsyncOperation->resolve("最终结果");
        return $nextAsyncOperation; // 返回一个 Promise，后续的 then 会等待它完成
    })
    ->then(function ($finalResult) {
        echo "第三步：得到最终结果 " . $finalResult . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 使用 otherwise() 捕获链中任何环节的错误
        echo "操作链中发生错误：" . $reason . PHP_EOL;
    });

// 启动 Promise 链
$promise->resolve('原始数据');
// 输出：
// 第一步：处理 原始数据
// 第二步：接收到 原始数据，并进行下一步处理
// 第三步：得到最终结果 最终结果

<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;
        if ($value === '错误数据') {
            throw new \Exception('数据格式不正确'); // 抛出异常
        }
        return '处理成功';
    })
    ->then(function ($result) {
        echo "第二步成功：" . $result . PHP_EOL;
    })
    ->otherwise(function (\Throwable $e) { // 捕获异常
        echo "捕获到错误：" . $e->getMessage() . PHP_EOL;
        // 你也可以在这里返回一个 RejectedPromise 继续向下转发错误
        // return new RejectedPromise('进一步的错误处理');
    })
    ->then(null, function ($reason) { // 如果上面 otherwise 没有处理，或者返回了 RejectedPromise，这里会继续捕获
        echo "最终错误处理：" . $reason . PHP_EOL;
    });

// 触发成功路径
$promise->resolve('正常数据');
// 输出：
// 尝试处理：正常数据
// 第二步成功：处理成功

echo "---" . PHP_EOL;

// 触发失败路径
$anotherPromise = new Promise();
$anotherPromise->resolve('错误数据'); // 故意传入错误数据
// 输出：
// 尝试处理：错误数据
// 捕获到错误：数据格式不正确

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

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

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞程序执行，直到 Promise 完成
echo "等待结束，结果是：" . $result . PHP_EOL; // 输出：异步操作完成！

// 如果 Promise 最终被拒绝，wait() 会抛出异常
$errorPromise = new Promise(function () use (&$errorPromise) {
    sleep(1);
    $errorPromise->reject('操作失败了！');
});

try {
    echo "开始等待错误 Promise..." . PHP_EOL;
    $errorPromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "捕获到等待时的错误：" . $e->getReason() . PHP_EOL; // 输出：操作失败了！
}