Как получить доступ к PHP multi cURL handle response, как только это произойдет - PullRequest
Новая
       40

Как получить доступ к PHP multi cURL handle response, как только это произойдет

0 голосов
/ 05 марта 2019

Я запрашиваю несколько адресов с разным временем ответа: 

$urlList = [
    'https://httpstat.us/200?sleep=3000',
    'https://httpstat.us/200?sleep=1000'
];

$mh = curl_multi_init();

$curlHandlerList = [];
foreach ($urlList as $i => $url) {
    $ch = $curlHandlerList[$i] = curl_init();

    curl_setopt_array($ch, [
        CURLOPT_URL => $url,
        CURLOPT_HEADER => false,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_SSL_VERIFYHOST => false,
        CURLOPT_SSL_VERIFYPEER => false,
    ]);

    curl_multi_add_handle($mh, $ch);
}

while (CURLM_OK == curl_multi_exec($mh, $active) && $active) {
    usleep(10**4); // 10**4 microseconds => 0.01 seconds
    curl_multi_select($mh, .01);
}

foreach ($curlHandlerList as $ch) {
    $html = curl_multi_getcontent($ch);

    echo "$html
";
}

Возможно ли получить доступ к выводу уже завершенных обработчиков скручивания, как только это произойдет?

1 Ответ

0 голосов
/ 05 марта 2019

Отвечая на свой вопрос, так как я нигде не мог найти ответ.Вместо того чтобы создавать один обработчик multi-cURL, я создал один для каждого из адресов, которые необходимо запросить.Смотрите код ниже: 

$urlList = [                                                            
    'https://httpstat.us/200?sleep=3000',                               
    'https://httpstat.us/200?sleep=1000'                                
];                                                                      

processList($urlList, function($key, $output) {                         
    echo "Output from {$key}\n{$output}\n\n";                             
});                                                                     

function processList($urlList, $closure) {                              

    $curlHandlerList = $multiCurlHandlerList = [];                      

    foreach ($urlList as $i => $url) {                                  
        $ch = $curlHandlerList[$i] = curl_init();                       
        $mh = $multiCurlHandlerList[$i] = curl_multi_init();            

        curl_setopt_array($ch, [                                        
            CURLOPT_URL => $url,                                        
            CURLOPT_HEADER => false,                                    
            CURLOPT_RETURNTRANSFER => true,                             
            CURLOPT_SSL_VERIFYHOST => false,                            
            CURLOPT_SSL_VERIFYPEER => false,                            
        ]);                                                             

        curl_multi_add_handle($mh, $ch);                                
    }                                                                   

    while (count($multiCurlHandlerList)) {                              
        foreach ($multiCurlHandlerList as $i => $mh) {                  
            if (CURLM_OK != curl_multi_exec($mh, $active) || !$active) {

                $html = curl_multi_getcontent($curlHandlerList[$i]);    

                $closure($i, $html);                                    

                curl_multi_remove_handle($mh, $curlHandlerList[$i]);    
                unset($multiCurlHandlerList[$i], $curlHandlerList[$i]); 
            }                                                           
        }                                                               
        usleep(10**4); // 10**4 microseconds => 0.01 seconds            
    }                                                                   
}
...