如何解决PHP异步操作的阻塞问题？使用Composer与GuzzlePromises轻松实现并发！

<pre class="brush:php;toolbar:false;">// 伪代码，实际会使用curl或Guzzle HTTP客户端
$orderData = fetchApi('order_api/get_details'); // 耗时操作1
$stockData = fetchApi('stock_api/get_info');   // 耗时操作2
$shippingData = fetchApi('shipping_api/get_status'); // 耗时操作3

// 处理所有数据...

fetchapi

curl_multi

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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';

// 你的代码...

guzzlehttp/promises

guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Client;
use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 2.x 版本使用 Utils

// 假设我们有三个模拟的API端点，它们会模拟延迟
$apiEndpoints = [
    'https://jsonplaceholder.typicode.com/posts/1', // 模拟请求1
    'https://jsonplaceholder.typicode.com/todos/1', // 模拟请求2
    'https://jsonplaceholder.typicode.com/users/1'  // 模拟请求3
];

$client = new Client();
$promises = [];

echo "开始并发请求...\n";
$startTime = microtime(true);

foreach ($apiEndpoints as $index => $url) {
    // client->getAsync() 会立即返回一个Promise对象，不会阻塞
    $promises['request_' . ($index + 1)] = $client->getAsync($url);
}

// 使用 Utils::all() 等待所有Promise完成
// Utils::all() 会返回一个新的Promise，当所有内部Promise都 fulfilled 时，它才 fulfilled
// 如果任何一个内部Promise rejected，它就会 rejected
$allPromises = Utils::all($promises);

try {
    // wait() 方法会阻塞当前脚本，直到Promise被解析（fulfilled或rejected）
    // 这里的 wait() 会等待所有的并发请求都完成后才继续执行
    $results = $allPromises->wait();

    echo "所有请求完成！\n";
    foreach ($results as $key => $response) {
        echo "{$key} 响应状态码: " . $response->getStatusCode() . "\n";
        // 你可以进一步处理 $response->getBody()->getContents()
    }
} catch (GuzzleHttp\Promise\Exception\RejectionException $e) {
    echo "请求中发生错误: " . $e->getReason() . "\n";
}

$endTime = microtime(true);
echo "总耗时: " . round($endTime - $startTime, 3) . " 秒\n";

// 对比：如果串行执行，总耗时会是单个请求耗时之和。
// 使用 Promise 后的总耗时会接近最慢的那个请求的耗时。

guzzlehttp/promises

guzzlehttp/promises