参考地址：https://www.php.cn/php-weizijiaocheng-409819.html

PHP 是 单进程同步模型 ，一个请求对应一个进程， I/O 是同步阻塞的。通过 nginx/apache/php-fpm 等服务的扩展，才使得 PHP 提供高并发的服务，原理就是维护一个进程池，每个请求服务时单独起一个新的进程，每个进程独立存在。

PHP 不支持多线程模式和回调处理，因此 PHP 内部脚本都是同步阻塞式的，如果你发起一个 5s 的请求，那么程序就会 I/O 阻塞 5s ，直到请求返回结果，才会继续执行代码。因此做爬虫之类的高并发请求需求很吃力。

PHP 并发请求 - 示例1

demo 

  1. /**
  2. * curl 并发请求示例
  3. * @param array $urls 请求url字符串数组
  4. */
  5. public function multiRequest($urls)
  6. {
  7.     // 初始化一个新的 curl 批处理句柄
  8.     $mh = curl_multi_init();
  9.     // 单个请求的 curl 句柄数组
  10.     $urlHandlers = [];
  11.     // 最终结果整理数组
  12.     $urlData = [];
  14.     // 循环初始化多个请求句柄
  15.     foreach($urls as $value){
  16.         $ch = curl_init();
  17.         curl_setopt($ch, CURLOPT_URL, $value);
  18.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); // 设置请求结果不直接输出，而是将结果交给一个变量
  19.         curl_setopt($ch, CURLOPT_TIMEOUT, 10); // 设置超时时间
  21.         $urlHandlers[] = $ch;
  23.         // 向 curl 批处理会话中添加单独的 curl 句柄
  24.     }
  26.     $active = null;
  28.     do {
  29.         // 返回的 $active 是活跃链接的数量， $mrc 是返回值，正常为0， 异常为 -1
  30.         $mrc = curl_multi_exec($mh, $active);
  31.     }while ($mrc = CURLM_CALL_MULTI_PERFORM);
  33.     // 如果还有活动的请求，同时操作状态为 OK，CURLM_OK 为常量值 0
  34.     while($active && $mrc == CURLM_OK){
  35.         // 持续查询状态并不利于处理任务，每 50ms 检查一次，此时释放 CPU ，降低机器负载
  36.         usleep(50000);
  37.         // 如果批处理句柄OK，重复检查操作状态直至OK。select返回值异常时为-1，正常为1（因为只有一个批处理句柄）
  38.         if(curl_multi_select($mh) != -1){
  39.             do{
  40.                 $mrc = curl_multi_exec($mh, $active);
  41.             }while($mrc == CURLM_CALL_MULTI_PERFORM);
  42.         }
  43.     }
  45.     // 获取返回结果
  46.     foreach($urlHandlers as $index = $ch){
  47.         $urlDatap[$index] = curl_multi_getcontent($ch);
  48.         // 移除单个 curl 句柄
  49.         curl_multi_remove_handle($mh, $ch);
  50.     }
  52.     // 结束批处理句柄
  53.     curl_multi_close($mh);
  55.     // 返回结果
  56.     return $urlData;
  57. }

在该并发请求中，先创建一个批处理句柄，然后将 url 的 CURL 句柄添加到批处理句柄中，并不断查询批处理句柄的执行状态，当执行完成后，获取返回的结果。

PHP 并发请求 - 示例2

class CurlMultiUtil {
  /**
  * 根据url,postData获取curl请求对象,这个比较简单,可以看官方文档
  */
  private static function getCurlObject($url,$postData=array(),$header=array()){
    $options = array();
    $url = trim($url);
    $options[CURLOPT_URL] = $url;
    $options[CURLOPT_TIMEOUT] = 3;
    $options[CURLOPT_RETURNTRANSFER] = true;
    foreach($header as $key=>$value){
      $options[$key] =$value;
    }
    if(!empty($postData) && is_array($postData)){
      $options[CURLOPT_POST] = true;
      $options[CURLOPT_POSTFIELDS] = http_build_query($postData);
    }
    if(stripos($url,'https') === 0){
      $options[CURLOPT_SSL_VERIFYPEER] = false;
    }
    $ch = curl_init();
    curl_setopt_array($ch,$options);
    return $ch;
  }

  /**
   * [request description]
   * @param [type] $chList
   * @return [type]
   */
  private static function request($chList){
    $downloader = curl_multi_init();
    // 将三个待请求对象放入下载器中
    foreach ($chList as $ch){
      curl_multi_add_handle($downloader,$ch);
    }
    $res = array();
    // 轮询
    do {
      while (($execrun = curl_multi_exec($downloader, $running)) == CURLM_CALL_MULTI_PERFORM);
      if ($execrun != CURLM_OK) {
        break;
      }
      // 一旦有一个请求完成，找出来，处理,因为curl底层是select，所以最大受限于1024
      while ($done = curl_multi_info_read($downloader)){
        // 从请求中获取信息、内容、错误
        // $info = curl_getinfo($done['handle']);
        $output = curl_multi_getcontent($done['handle']);
        // $error = curl_error($done['handle']);
        $res[] = $output;
        // 把请求已经完成了得 curl handle 删除
        curl_multi_remove_handle($downloader, $done['handle']);
      }
      // 当没有数据的时候进行堵塞，把 CPU 使用权交出来，避免上面 do 死循环空跑数据导致 CPU 100%
      if ($running) {
        $rel = curl_multi_select($downloader, 1);
        if($rel == -1){
          usleep(1000);
        }
      }
      if($running == false){
        break;
      }
    }while(true);
    curl_multi_close($downloader);
    return $res;
  }

  /**
   * [get description]
   * @param [type] $urlArr
   * @return [type]
   */
  public static function get($urlArr){
    $data = array();
    if (!empty($urlArr)) {
      $chList = array();
      foreach ($urlArr as $key => $url) {
        $chList[] = self::getCurlObject($url);
      }
      $data = self::request($chList);
    }
    return $data;
  }
}

curl_multi 相关函数

/**
* 函数作用：返回一个新 curl 批处理句柄
* @return resource 成功返回 curl 批处理句柄，失败返回false
*/
resource curl_multi_init (void)

/**
* 函数作用：向 curl 批处理绘画中添加单独的 curl 句柄
* @param $mh 由 curl_multi_init() 返回的批处理句柄
* @param $ch 由 curl_init() 返回的 curl 单独句柄
* @return resource 成功返回 curl 批处理句柄，失败返回false
*/
int curl_multi_add_handle (resource $mh, resource $ch)

/**
* 函数作用：运行当前 curl 句柄的子链接
* @param $mh 由 curl_multi_init() 返回的批处理句柄
* @param $still_running 一个用来判断才做是否仍在执行的标识的引用
* @return 一个定义与 curl 预定义常量中的 curl 代码
*/
int curl_multi_exec (resource $mh, int &$still_running)

/**
* 函数作用：等待所有 curl 批处理中的活动链接
* @param $mh 由 curl_multi_init() 返回的批处理句柄
* @param $timeout 以秒为单位，等待响应的时间
* @return 成功时返回描述符集合中描述符的数量。失败时，select 失败时返回 -1， 否则返回超时（从底层的 select 系统调用）
*/
int curl_multi_select (resource $mh [, float $timeout = 1.0])

/**
* 函数作用：移除 curl 批处理句柄资源中的某个句柄资源
* 说明：从给定的批处理句柄 $mh  中移除 $ch 句柄。当 $ch 句柄被移除以后，仍然可以合法的用 curl_exec() 执行这个句柄，如果要移除的句柄正在被使用，则这个句柄涉及的所有传输任务会被终止。
* @param $mh 由 curl_multi_init() 返回的批处理句柄
* @param $ch 由 curl_init() 返回的单个 curl 句柄
* @return 成功时返回0，失败时返回 CURLM_XXX 中的一个
*/
int curl_multi_remove_handle (resource $mh, resource $ch)

/**
* 函数作用：关闭一组cURL句柄
* @param $mh 由curl_multi_init返回的批处理句柄
* @return void
*/
void curl_multi_close (resource $mh)

/**
* 函数作用：如果设置了 CURLOPT_RETURNTRANSFER，则返回获取的输出的文本流
* @param $ch 由 curl_init 返回的 curl 句柄
* @return string 如果设置了 CURLOPT_RETURNTRANSFER，则返回获取的输出的文本流
*/
string curl_multi_getcontent (resource $ch)

注意项

并发数限制

curl_multi 会消耗很多的系统资源，在并发请求时，并发数有一定阈值，一般为 512 ，是由于 curl 内部限制，超过最大并发会导致失败。

超时时间

为了防止慢请求影响整个服务，可以设置 CURLOPT_TIMEOUT 来控制超时时间，防止部分假死的请求无线阻塞进程处理，最后打死机器服务。