如何解决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(
    // 当Promise成功时调用
    function ($value) {
        echo "商品信息获取成功: " . $value . "\n";
    },
    // 当Promise失败时调用
    function ($reason) {
        echo "商品信息获取失败: " . $reason . "\n";
    }
);

// 模拟异步操作，假设100毫秒后获取到数据
// 实际应用中，这里会是HTTP请求、数据库查询等
$data = 'Apple iPhone 15';
$promise->resolve($data); // 成功解析Promise
// $promise->reject('API服务无响应'); // 失败解析Promise

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

$promise = new Promise();

$promise
    ->then(function ($productId) {
        echo "获取商品ID: {$productId}\n";
        // 假设这里发起第一个异步请求，获取商品名称
        return "商品名称: iPhone 15";
    })
    ->then(function ($productName) {
        echo "获取商品名称成功: {$productName}\n";
        // 假设这里发起第二个异步请求，获取库存
        return "库存数量: 100";
    })
    ->then(function ($stock) {
        echo "获取库存成功: {$stock}\n";
        // 最终返回一个合并的结果
        return "所有数据已获取！";
    })
    ->then(function ($finalResult) {
        echo $finalResult . "\n";
    });

// 触发Promise链
$promise->resolve('P12345'); // 从商品ID开始

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功: " . $value . "\n";
        // 模拟一个后续操作失败
        throw new \Exception('库存服务连接失败');
    })
    ->then(null, function ($reason) { // 捕获上一个then中的异常
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        // 你可以选择继续抛出，或者返回一个正常值来恢复链条
        // return new RejectedPromise('更严重的错误'); // 继续向下传递拒绝状态
        return "库存错误已处理，返回默认值"; // 恢复链条，后续then将收到此值
    })
    ->then(function ($value) {
        echo "链条继续: " . $value . "\n"; // 如果上一个then返回了正常值，这里会执行
    });

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

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终会解析Promise
    sleep(1);
    $promise->resolve('这是等待后的结果');
});

echo "开始等待...\n";
$result = $promise->wait(); // 阻塞直到Promise完成
echo "等待结束，结果是: " . $result . "\n"; // 输出 "等待结束，结果是: 这是等待后的结果"