Могу ли я выполнить несколько параллельных cURL по одному и тому же URL?

Question

Мне нужно выполнить несколько запросов параллельно с помощью cURL, но мне нужно сделать это против того же URL-адреса.

Это потому, что это веб-сервис SOAP, у меня есть уникальный URL-адрес, но я пошлю разные заголовки, чтобы получить несколько ответов, которые мне нужны.

Я попытался сделать curl_multi_exec, но я var_dump массива $ каналов, и я получаю только 1, я думаю, это потому, что завиток повторного использования соединений и поэтому я попытался CURLOPT_FRESH_CONNECT и CURLOPT_FORBID_REUSE без успеха.

Любая идея, как ее достичь?

$url = "http://myURL.com/SOAPWebservice.svc"; 
    $stationIds = array(207,303,305,195,204,205);//5,10); 
    // 207,303,305,195,204,205,206,212,306,196,193,194,307,312,197,198,199,200,201,202,203,302,308,367,304,309,310,311 

    $multi = curl_multi_init(); 
    $channels = array(); 

    // Loop through the URLs, create curl-handles 
    // and attach the handles to our multi-request 
    foreach ($stationIds as $stationId) 
    { 
     $soap_request = 
      '<?xml version="1.0" encoding="UTF-8"?> 
       <SOAP-ENV:Envelope xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/" xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ns6930="http://tempuri.org" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
        <SOAP-ENV:Body> 
         <GetStationById xmlns="http://tempuri.org/"> 
          <StationID>' . $stationId . '</StationID> 
          <CityID>5</CityID> 
         </GetStationById> 
        </SOAP-ENV:Body> 
       </SOAP-ENV:Envelope>'; 

     $header = array(
      "Content-type: text/xml;charset=\"utf-8\"", 
      "Accept: text/xml", 
      "Cache-Control: no-cache", 
      "Pragma: no-cache", 
      "SOAPAction: \"http://tempuri.org/IBLLStation/GetStationById\"", 
      "Content-length: ".strlen($soap_request), 
     ); 


     $ch = curl_init(); 
     curl_setopt($ch, CURLOPT_URL,   $url); 
     curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); 
     curl_setopt($ch, CURLOPT_POST,   true); 
     curl_setopt($ch, CURLOPT_POSTFIELDS,  $soap_request); 
     curl_setopt($ch, CURLOPT_HTTPHEADER,  $header); 
     curl_setopt($ch, CURLOPT_FRESH_CONNECT,  TRUE); 
     curl_setopt($ch, CURLOPT_FORBID_REUSE,  TRUE); 

     curl_multi_add_handle($multi, $ch); 

     $channels[$url] = $ch; 
    } 

    // While we're still active, execute curl 
    $active = null; 
    do { 
     $mrc = curl_multi_exec($multi, $active); 
    } while ($mrc == CURLM_CALL_MULTI_PERFORM); 

    while ($active && $mrc == CURLM_OK) { 
     // Wait for activity on any curl-connection 
     if (curl_multi_select($multi) == -1) { 
      continue; 
     } 

     // Continue to exec until curl is ready to 
     // give us more data 
     do { 
      $mrc = curl_multi_exec($multi, $active); 
     } while ($mrc == CURLM_CALL_MULTI_PERFORM); 
    } 

    // Loop through the channels and retrieve the received 
    // content, then remove the handle from the multi-handle 
    $StationsLastContact = ""; 
    // echo print_r($channels,TRUE); 
    foreach ($channels as $channel) { 
     $response = curl_multi_getcontent($channel); 
     $startsAt   = strpos($response, "StationLastContact>") + strlen("StationLastContact>"); 
     $endsAt    = strpos($response, "<", $startsAt); 
     $StationLastContact = substr($response, $startsAt, $endsAt - $startsAt); 
     $StationLastContact .= "<br />"; 
     $StationsLastContact .= $StationLastContact; 
     curl_multi_remove_handle($multi, $channel); 
    } 

    // Close the multi-handle and return our results 
    curl_multi_close($multi); 

    die($StationsLastContact); 

Answer 1

Проверьте, не работает ли приведенный ниже код. Я просто использовал массив обработчиков.

var_dump($ch); 

array(6) { 
    [207]=> 
    resource(3) of type (curl) 
    [303]=> 
    resource(4) of type (curl) 
    [305]=> 
    resource(5) of type (curl) 
    [195]=> 
    resource(6) of type (curl) 
    [204]=> 
    resource(7) of type (curl) 
    [205]=> 
    resource(8) of type (curl) 
} 


    $url = "http://myURL.com/SOAPWebservice.svc"; 
    $stationIds = array(207,303,305,195,204,205);//5,10); 
    // 207,303,305,195,204,205,206,212,306,196,193,194,307,312,197,198,199,200,201,202,203,302,308,367,304,309,310,311 

    $multi = curl_multi_init(); 
    $channels = array(); 

    // Loop through the URLs, create curl-handles 
    // and attach the handles to our multi-request 
    foreach ($stationIds as $stationId) 
    { 
     $soap_request = 
      '<?xml version="1.0" encoding="UTF-8"?> 
       <SOAP-ENV:Envelope xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/" xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ns6930="http://tempuri.org" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> 
        <SOAP-ENV:Body> 
         <GetStationById xmlns="http://tempuri.org/"> 
          <StationID>' . $stationId . '</StationID> 
          <CityID>5</CityID> 
         </GetStationById> 
        </SOAP-ENV:Body> 
       </SOAP-ENV:Envelope>'; 

     $header = array(
      "Content-type: text/xml;charset=\"utf-8\"", 
      "Accept: text/xml", 
      "Cache-Control: no-cache", 
      "Pragma: no-cache", 
      "SOAPAction: \"http://tempuri.org/IBLLStation/GetStationById\"", 
      "Content-length: ".strlen($soap_request), 
     ); 


     $ch[$stationId] = curl_init(); 
     curl_setopt($ch[$stationId], CURLOPT_URL,   $url); 
     curl_setopt($ch[$stationId], CURLOPT_RETURNTRANSFER, true); 
     curl_setopt($ch[$stationId], CURLOPT_POST,   true); 
     curl_setopt($ch[$stationId], CURLOPT_POSTFIELDS,  $soap_request); 
     curl_setopt($ch[$stationId], CURLOPT_HTTPHEADER,  $header); 
     curl_setopt($ch[$stationId], CURLOPT_FRESH_CONNECT,  TRUE); 
     curl_setopt($ch[$stationId], CURLOPT_FORBID_REUSE,  TRUE); 

     curl_multi_add_handle($multi, $ch[$stationId]); 
    } 

    // While we're still active, execute curl 
    $active = null; 
    do { 
     $mrc = curl_multi_exec($multi, $active); 
    } while ($mrc == CURLM_CALL_MULTI_PERFORM); 

    while ($active && $mrc == CURLM_OK) { 
     // Wait for activity on any curl-connection 
     if (curl_multi_select($multi) == -1) { 
      continue; 
     } 

     // Continue to exec until curl is ready to 
     // give us more data 
     do { 
      $mrc = curl_multi_exec($multi, $active); 
     } while ($mrc == CURLM_CALL_MULTI_PERFORM); 
    } 

    // Loop through the channels and retrieve the received 
    // content, then remove the handle from the multi-handle 
    $StationsLastContact = ""; 
    // echo print_r($channels,TRUE); 
    foreach ($ch as $channel) { 
     $response = curl_multi_getcontent($channel); 
     $startsAt   = strpos($response, "StationLastContact>") + strlen("StationLastContact>"); 
     $endsAt    = strpos($response, "<", $startsAt); 
     $StationLastContact = substr($response, $startsAt, $endsAt - $startsAt); 
     $StationLastContact .= "<br />"; 
     $StationsLastContact .= $StationLastContact; 
     curl_multi_remove_handle($multi, $channel); 
    } 

    // Close the multi-handle and return our results 
    curl_multi_close($multi); 

    die($StationsLastContact);