如何解决PHP应用中I/O瓶颈？使用GuzzlePromises构建高效异步流程

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

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

$promise = new Promise();

$promise->then(
    // $onFulfilled：操作成功时执行
    function ($value) {
        echo 'Promise 已兑现，值为: ' . $value . PHP_EOL;
    },
    // $onRejected：操作失败时执行
    function ($reason) {
        echo 'Promise 已拒绝，原因: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成，兑现Promise
$promise->resolve('订单处理成功！'); // 输出：Promise 已兑现，值为: 订单处理成功！

// 如果操作失败
// $promise->reject('支付失败，请重试。'); // 输出：Promise 已拒绝，原因: 支付失败，请重试。

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

$promise = new Promise();
$nextPromise = new Promise();

$promise
    ->then(function ($value) use ($nextPromise) {
        echo "第一步：接收到值 '" . $value . "'" . PHP_EOL;
        // 返回另一个Promise，后续链条将等待它解决
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第二步：接收到值 '" . $value . "'" . PHP_EOL;
    });

// 触发第一个回调
$promise->resolve('开始任务'); // 输出：第一步：接收到值 '开始任务'
// 此时，第二个 then 还没有执行，因为它在等待 $nextPromise 解决

// 触发第二个回调
$nextPromise->resolve('中间步骤完成'); // 输出：第二步：接收到值 '中间步骤完成'

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

$promise = new Promise();
$promise
    ->then(null, function ($reason) {
        echo "捕获到错误1: " . $reason . PHP_EOL;
        // 抛出异常，错误会继续向下传递
        throw new \Exception("处理错误时又出错了: " . $reason);
    })
    ->then(null, function ($reason) {
        echo "捕获到错误2: " . $reason->getMessage() . PHP_EOL;
        // 返回一个正常值，后续链条会转为成功状态
        return "错误已处理并恢复";
    })
    ->then(function ($value) {
        echo "链条恢复正常: " . $value . PHP_EOL;
    });

$promise->reject('原始错误：数据库连接失败');
// 输出：
// 捕获到错误1: 原始错误：数据库连接失败
// 捕获到错误2: 处理错误时又出错了: 原始错误：数据库连接失败
// 链条恢复正常: 错误已处理并恢复

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

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

echo "等待异步操作..." . PHP_EOL;
$result = $promise->wait(); // 此时会阻塞1秒
echo "结果: " . $result . PHP_EOL; // 输出：结果: 异步操作完成！

// 如果Promise被拒绝，wait()会抛出异常
$rejectedPromise = new Promise();
$rejectedPromise->reject('操作失败！');
try {
    $rejectedPromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "捕获到拒绝异常: " . $e->getMessage() . PHP_EOL;
}