PHP Curl多線程實現原理與實例詳解

2024-05-04 21:47:30

字體：大中小

來源：轉載

供稿：網友

因為工作中我們經常會需要使用到Curl多線程來處理一些事情,不得己就深入了對Curl多線程研究了,下面小編來給各位同學介紹一下Curl多線程實例與原理吧.

相信許多人對php手冊中語焉不詳的curl_multi一族的函數頭疼不已,它們文檔少,給的例子更是簡單的讓你無從借鑒,我也曾經找了許多網頁,都沒見一個完整的應用例子。

curl_multi_add_handle

curl_multi_close

curl_multi_exec

curl_multi_getcontent

curl_multi_info_read

curl_multi_init

curl_multi_remove_handle

curl_multi_select

一般來說,想到要用這些函數時,目的顯然應該是要同時請求多個url,而不是一個一個依次請求,否則不如自己循環去調curl_exec好了.

步驟總結如下：

第一步：調用curl_multi_init

第二步：循環調用curl_multi_add_handle,這一步需要注意的是，curl_multi_add_handle的第二個參數是由curl_init而來的子handle。

第三步：持續調用curl_multi_exec

第四步：根據需要循環調用curl_multi_getcontent獲取結果

第五步：調用curl_multi_remove_handle，并為每個字handle調用curl_close

第六步：調用curl_multi_close

這里有PHP手冊上的例子,代碼如下:

<?php

// 創建一對cURL資源

$ch1 = curl_init();

$ch2 = curl_init();



// 設置URL和相應的選項

curl_setopt($ch1, CURLOPT_URL, "http://lxr.php.net/");

curl_setopt($ch1, CURLOPT_HEADER, 0);

curl_setopt($ch2, CURLOPT_URL, "http://www.php.net/");

curl_setopt($ch2, CURLOPT_HEADER, 0);



// 創建批處理cURL句柄

$mh = curl_multi_init();



// 增加2個句柄

curl_multi_add_handle($mh,$ch1);

curl_multi_add_handle($mh,$ch2);



$active = null;

// 執行批處理句柄

do {

    $mrc = curl_multi_exec($mh, $active);

} while ($mrc == CURLM_CALL_MULTI_PERFORM);



while ($active && $mrc == CURLM_OK) {

    if (curl_multi_select($mh) != -1) {

        do {

            $mrc = curl_multi_exec($mh, $active);

        } while ($mrc == CURLM_CALL_MULTI_PERFORM);

    }

}

// 關閉全部句柄

curl_multi_remove_handle($mh, $ch1);

curl_multi_remove_handle($mh, $ch2);

curl_multi_close($mh);

?>

整個使用過程差不多就是這樣,但是,這個簡單代碼有個致命弱點,就是在do循環的那段,在整個url請求期間是個死循環,它會輕易導致CPU占用100%。

現在我們來改進它,這里要用到一個幾乎沒有任何文檔的函數curl_multi_select了,雖然C的curl庫對select有說明,但是,php里的接口和用法確與C中有不同。

把上面do的那段改成下面這樣,實例代碼如下:

do {

                        $mrc = curl_multi_exec($mh,$active);

                 } while ($mrc == CURLM_CALL_MULTI_PERFORM);

                while ($active and $mrc == CURLM_OK) {

                        if (curl_multi_select($mh) != -1) {

                                do {

                                        $mrc = curl_multi_exec($mh, $active);

                                 } while ($mrc == CURLM_CALL_MULTI_PERFORM);

                         }

                 }