如何解决PHP应用多API请求慢的问题？GuzzlePromises助你实现异步并行处理

<pre class="brush:php;toolbar:false;">// 伪代码，模拟同步API调用
$dataFromApiA = callApiA(); // 等待1000ms
$dataFromApiB = callApiB(); // 等待1500ms
$dataFromApiC = callApiC(); // 等待800ms

// 总耗时：1000 + 1500 + 800 = 3300ms

guzzlehttp/promises

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

fulfilled

rejected

pending

guzzlehttp/promises

Promise

guzzlehttp/promises

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于处理多个Promise

echo "开始执行耗时操作...\n";

// 模拟一个异步操作，例如一个API请求
function fetchUserData(string $userId, int $delayMs): Promise
{
    // 创建一个Promise对象
    $promise = new Promise();

    // 在实际场景中，这里会发起一个非阻塞的HTTP请求，例如 GuzzleHttp\Client 的 async 方法
    // 为了演示，我们用一个模拟的延迟来体现“未来值”的概念
    echo "  >> 发起获取用户 {$userId} 数据的请求...\n";

    // 假设这是后台某个耗时操作，最终会resolve或reject
    // 在真正的异步框架中，这个resolve/reject会被事件循环触发
    // 在本例中，我们会在后面通过一个统一的等待机制来触发它
    // 或者，更直接地，我们可以立即resolve一个值，但那就不“异步”了
    // 这里我们先不直接resolve，而是让它保持pending，等待外部机制来驱动。

    // 更符合实际场景的 Promise 构造方式，包含一个 waitFn
    return new Promise(function () use (&$promise, $userId, $delayMs) {
        // 这是一个“等待函数”，当调用 $promise->wait() 时会被执行
        // 在这里模拟实际的阻塞操作，然后 resolve
        usleep($delayMs * 1000); // 模拟延迟
        echo "  << 完成获取用户 {$userId} 数据。\n";
        $promise->resolve("用户 {$userId} 的数据 (延迟 {$delayMs}ms)");
    });
}

// 同时发起多个“异步”请求
$promise1 = fetchUserData('user_a', 1000); // 模拟1秒延迟
$promise2 = fetchUserData('user_b', 1500); // 模拟1.5秒延迟
$promise3 = fetchUserData('user_c', 800);  // 模拟0.8秒延迟

echo "所有请求已发起，程序继续执行其他逻辑...\n";

// 假设这里有一些不依赖API结果的同步代码
echo "执行一些不相关的同步任务...\n";
usleep(200 * 1000); // 模拟200ms的其他任务

echo "现在需要等待所有API请求的结果...\n";

try {
    // 使用 Utils::all() 等待所有 Promise 完成
    // 这会阻塞当前进程，直到所有 Promise 都被解决或拒绝
    $results = Utils::all([$promise1, $promise2, $promise3])->wait();

    echo "\n所有API请求结果已获取：\n";
    foreach ($results as $index => $result) {
        echo "  结果 " . ($index + 1) . ": " . $result . "\n";
    }

} catch (Exception $e) {
    echo "发生错误：" . $e->getMessage() . "\n";
}

echo "所有操作完成。\n";

?>

guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php
// ... (同上，引入 Composer autoload 和 Promise 类)

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功：接收到 '{$value}'\n";
        return "处理后的 " . $value; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步成功：接收到 '{$value}'\n";
        // 也可以返回一个新的 Promise，实现更复杂的异步链
        $nextPromise = new Promise();
        $nextPromise->resolve("最终结果: " . $value);
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步成功：接收到 '{$value}'\n";
    }, function ($reason) {
        echo "第三步失败：原因 '{$reason}'\n";
    });

// 解决原始 Promise，触发链式调用
$promise->resolve('原始数据');

// 同步等待最终结果（如果需要）
$promise->wait(); // 确保所有链式操作完成
?>

guzzlehttp/promises

guzzlehttp/promises