php使用curl模擬多線程發送請求

每一個PHP文件的執行是單線程的,可是php自己也能夠用一些別的技術實現多線程併發好比用php-fpm進程,這裏用curl模擬多線程發送請求。php的curl多線程是經過不斷調用curl_multi_exec來獲取內容,這裏舉一個demo來模擬一次curl多線程併發操做。php

//設置緩衝爲0(也能夠去php.ini設置)
ini_set('output_buffering', 0);
//打開輸出緩衝區
ob_start();
//設置一個空數組
$curl_Arr=[];
//這裏模擬20次請求
for($i=0;$i<20;$i++){
    //開啓curl鏈接
    $curl_Arr[$i]=curl_init("http://XXXX/test.php");
    //CURLOPT_RETURNTRANSFER 設置爲1表示稍後執行的curl_exec函數的返回是URL的返回字符串,而不是把返回字符串定向到標準輸出並返回TRUE;
    curl_setopt($curl_Arr[$i],CURLOPT_RETURNTRANSFER,1);
}

//建立批處理cURL句柄
$mh = curl_multi_init();

foreach($curl_Arr as $k => $ch){
    //curl句柄入棧增長
    curl_multi_add_handle($mh,$ch);
}
$active = null;
while(count($curl_Arr)>0){
    //發起curl_multi請求
    @curl_multi_exec($mh,$active);
    foreach($curl_Arr as $k => $ch){
        //獲取句柄的返回值
        if($result[$k]= curl_multi_getcontent($ch)){
            //輸出結果
            echo "$result[$k]\n";
            ob_flush();
            //把被釋放的數據發送到瀏覽器
            flush();
            //關閉該句柄
            curl_multi_remove_handle($mh,$ch);
            unset($curl_Arr[$k]);
        }
    }
}
//關閉ouput_buffering機制
ob_end_flush();
//關閉"curl_mulit"句柄
curl_multi_close($mh);

我再服務器上創建一塊兒請求的php頁面命名爲test.php,內容以下html

1 sleep(10);
2 echo 'seccess';exit;

表示等待十秒後數據下面語句。數組

 

而後我在命令行執行該程序結果以下:瀏覽器

上面代碼中經過循環$curl_Arr數組來調用curl_multi_getcontent來查詢是否有數據。有數據就輸出並刪除元素,直到$curl_Arr數組元素個數爲0。服務器

該模擬多線程實現是經過使用curl的curl_multi系列函數能實現此功能的。至於該系列函數使用介紹,百度一搜一大把。這裏就不作說明了。多線程

 

本文屬原創內容,爲了尊重他人勞動,轉載請註明本文地址:併發

http://www.javashuo.com/article/p-urhtnhxm-ht.htmlcurl

相關文章
相關標籤/搜索