PHP 中优化 foreach循环，处理多个异步请求

在 PHP 中优化 foreach 循环以处理多个异步请求，可以使用以下几种方法：

方法一：使用 curl_multi_* 函数

curl_multi_* 函数允许同时执行多个 cURL 请求，从而提高性能和响应速度。以下是使用 curl_multi_* 的示例代码：

$urls = [
    'https://api.example.com/data1',
    'https://api.example.com/data2',
    'https://api.example.com/data3'
];

$multi_handler = curl_multi_init();
$curl_handles = [];

foreach ($urls as $url) {
    $curl_handles[$url] = curl_init($url);
    curl_setopt($curl_handles[$url], CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($multi_handler, $curl_handles[$url]);
}

do {
    curl_multi_exec($multi_handler, $running);
} while ($running > 0);

foreach ($urls as $url) {
    $response = curl_multi_getcontent($curl_handles[$url]);
    // 处理响应
    echo $response . "\n";
    curl_multi_remove_handle($multi_handler, $curl_handles[$url]);
    curl_close($curl_handles[$url]);
}

curl_multi_close($multi_handler);

这个方法使用 curl_multi_* 函数来同时执行多个 cURL 请求，从而提高性能。

方法二：使用 Guzzle 库

Guzzle 是一个功能强大的 PHP HTTP 客户端，支持异步请求。以下是使用 Guzzle 的示例代码：

use GuzzleHttp\Client;
use GuzzleHttp\Promise;

$client = new Client();

$urls = [
    'https://api.example.com/data1',
    'https://api.example.com/data2',
    'https://api.example.com/data3'
];

$promises = [];

foreach ($urls as $url) {
    $promises[] = $client->getAsync($url);
}

$results = Promise\Utils::unwrap($promises);

foreach ($results as $response) {
    // 处理响应
    echo $response->getBody() . "\n";
}

这个方法使用 Guzzle 的 Promise 类来处理异步请求，从而提高性能。

方法三：使用 pcntl_fork

pcntl_fork 可以创建子进程来处理异步任务，从而提高性能。以下是使用 pcntl_fork 的示例代码：

$urls = [
    'https://api.example.com/data1',
    'https://api.example.com/data2',
    'https://api.example.com/data3'
];

foreach ($urls as $url) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        // 错误处理
        die('Could not fork');
    } elseif ($pid) {
        // 父进程
        continue;
    } else {
        // 子进程
        $data = file_get_contents($url);
        // 处理响应
        echo $data . "\n";
        exit(0);
    }
}

// 父进程等待所有子进程完成
pcntl_wait($status);

这个方法使用 pcntl_fork 来创建子进程处理异步任务，从而提高性能。

方法四：使用 PHP Fibers

PHP Fibers 提供了一种轻量级的并发机制，可以用来模拟异步请求。以下是使用 Fibers 的示例代码：

function asyncRequest($url) {
    return new Fiber(function() use ($url) {
        echo "Starting request to $url\n";
        Fiber::suspend();  // 模拟等待请求
        echo "Received response from $url\n";
    });
}

$request1 = asyncRequest("https://example.com/api/1");
$request2 = asyncRequest("https://example.com/api/2");

$request1->start();
$request2->start();

// 模拟其他工作
echo "Doing other work...\n";

$request1->resume();
$request2->resume();

这个方法使用 Fibers 来模拟异步请求，从而提高性能。

选择合适的方法

• 如果需要处理多个 HTTP 请求，curl_multi_* 和 Guzzle 是不错的选择，因为它们专门设计用于处理 HTTP 请求。
• 如果需要处理更复杂的并发任务，pcntl_fork 和 Fibers 可能更适合，因为它们提供了更灵活的并发机制。