如何解决PHP异步操作中的效率瓶颈？GuzzlePromises与Composer助你构建高性能应用

file_get_contents

curl

curl_multi_exec

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

vendor/autoload.php

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于all()等辅助函数

// 模拟异步API调用
function mockApiCall(string $name, int $delay, $result, bool $shouldFail = false): Promise
{
    return new Promise(function (callable $resolve, callable $reject) use ($name, $delay, $result, $shouldFail) {
        // 在实际应用中，这里会是真正的Guzzle HTTP客户端请求或其他异步操作
        // 为了演示，我们使用一个简单的延迟来模拟异步
        echo "发起 {$name} 请求...\n";
        // 模拟异步执行，实际中可能是通过EventLoop或其他方式
        // 这里为了简单，我们立即resolve/reject，但实际的异步会发生在某个事件循环中
        // 或在wait()被调用时才执行
        if ($shouldFail) {
            $reject(new \Exception("{$name} 请求失败！"));
        } else {
            $resolve($result);
        }
    });
}

// 1. 发起多个异步请求
$promiseA = mockApiCall('商品基本信息', 1, ['name' => '超级T恤', 'price' => 99]);
$promiseB = mockApiCall('库存信息', 2, ['stock' => 100]);
$promiseC = mockApiCall('用户评论', 0.5, ['comments' => ['好评', '非常棒']]);
$promiseD = mockApiCall('推荐商品', 1.5, ['recommended' => ['裤子', '鞋子']]);

// 2. 使用 Utils::all() 等待所有Promise完成
// Utils::all() 会返回一个新的Promise，当所有输入的Promise都成功时，它才成功
// 任何一个Promise失败，它就会立即失败
$allPromises = Utils::all([
    'product' => $promiseA,
    'stock' => $promiseB,
    'reviews' => $promiseC,
    'recommendations' => $promiseD,
]);

echo "所有请求已发起，等待结果...\n";

try {
    // 3. 同步等待所有Promise完成并获取结果
    // wait() 方法会阻塞当前进程直到Promise完成
    $results = $allPromises->wait();

    echo "\n所有数据已获取：\n";
    print_r($results);

    // 示例：Promise链式调用
    $promiseA
        ->then(function ($productInfo) {
            echo "商品名称：{$productInfo['name']}\n";
            return $productInfo['price'] * 0.9; // 返回一个新值，传递给下一个then
        })
        ->then(function ($discountedPrice) {
            echo "打折后价格：{$discountedPrice}\n";
        })
        ->otherwise(function ($reason) { // 捕获链中的任何错误
            echo "处理商品信息时发生错误: " . $reason->getMessage() . "\n";
        })
        ->wait(); // 确保链式调用完成

} catch (\Exception $e) {
    echo "\n处理请求时发生错误: " . $e->getMessage() . "\n";
}

echo "\n程序执行完毕。\n";

?>

mockApiCall

Promise

Utils::all()

wait()

.then()

.then()

.then()

otherwise()

guzzlehttp/promises