PHP使用curl_Multi同時リクエストを実装する方法の例

3117 ワード

この例では、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;
  }
}


PHPの関連内容についてもっと興味のある読者は、「php curl用法総括」、「PHPネットワークプログラミング技術総括」、「PHP配列(Array)操作技術大全」、「php文字列(string)用法総括」、「PHPデータ構造とアルゴリズムチュートリアル」、「phpプログラム設計アルゴリズム総括」、「PHP演算と演算子用法総括」及び「php一般データベース操作テクニック要約」
ここで述べたことが皆さんのPHPプログラム設計に役立つことを願っています.