PHP使用curl_multi实现并发请求的方法示例

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