浅谈php使用curl模拟多线程发送请求

当我们需要向一个接口发送大量请求时，使用curl模拟多线程发送请求是一个非常实用的方法。以下是浅谈php使用curl模拟多线程发送请求的完整攻略。

准备工作

在开始之前，我们需要确认服务器是否已安装curl，以及我们是否在PHP的配置文件中启用了curl扩展。可以使用以下命令检查curl是否已安装：

curl --version

如果返回了curl的版本信息，则表示已安装curl。否则，需要使用适合操作系统的命令安装curl：

sudo apt-get install curl

实现流程

使用curl模拟多线程发送请求的基本流程如下：

1. 创建一个curl句柄：使用curl_init()函数创建一个新的句柄，句柄用于执行curl操作。

2. 设置curl句柄的选项：使用curl_setopt()函数设置句柄的选项，例如发送请求的方式、URL地址、请求头等信息。

3. 发送curl请求并获取响应：使用curl_exec()函数发送请求并获取响应内容。

4. 关闭curl句柄：使用curl_close()函数关闭curl句柄。

重复执行上述流程可以模拟多线程发送请求。

示例

以下是两个使用curl模拟多线程发送请求的示例。

示例1：批量获取天气信息

我们使用PHP的天气API接口，获取指定城市的实时天气信息。

$city_list = array('北京', '上海', '广州', '深圳', '杭州');
$mh = curl_multi_init();
$handles = array();
foreach ($city_list as $city) {
  $url = 'http://wthrcdn.etouch.cn/weather_mini?city=' . urlencode($city);
  $ch = curl_init();
  curl_setopt($ch, CURLOPT_URL, $url);
  curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  curl_multi_add_handle($mh, $ch);
  $handles[] = $ch;
}
$active = null;
do {
  $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);
while ($active && $mrc == CURLM_OK) {
  if (curl_multi_select($mh) != -1) {
    do {
      $mrc = curl_multi_exec($mh, $active);
    } while ($mrc == CURLM_CALL_MULTI_PERFORM);
  }
}
$result = array();
foreach ($handles as $ch) {
  $data = curl_multi_getcontent($ch);
  $result[] = json_decode($data, true);
  curl_multi_remove_handle($mh, $ch);
  curl_close($ch);
}
curl_multi_close($mh);
print_r($result);

该示例利用curl模拟多线程发送HTTP请求获取多个城市的天气信息。

示例2：并发上传多个文件

$file_list = array(
  'file1.jpg',
  'file2.jpg',
  'file3.jpg',
  'file4.jpg',
  'file5.jpg'
);
$mh = curl_multi_init();
$handles = array();
foreach ($file_list as $file) {
  $ch = curl_init();
  curl_setopt($ch, CURLOPT_URL, 'http://example.com/upload');
  curl_setopt($ch, CURLOPT_POST, 1);
  curl_setopt($ch, CURLOPT_POSTFIELDS, array('file' => new CURLFile($file)));
  curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  curl_multi_add_handle($mh, $ch);
  $handles[] = $ch;
}
$active = null;
do {
  $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);
while ($active && $mrc == CURLM_OK) {
  if (curl_multi_select($mh) != -1) {
    do {
      $mrc = curl_multi_exec($mh, $active);
    } while ($mrc == CURLM_CALL_MULTI_PERFORM);
  }
}
$result = array();
foreach ($handles as $ch) {
  $data = curl_multi_getcontent($ch);
  $result[] = json_decode($data, true);
  curl_multi_remove_handle($mh, $ch);
  curl_close($ch);
}
curl_multi_close($mh);
print_r($result);

该示例利用curl模拟多线程并行上传多个文件到服务器的/upload接口。