快捷導(dǎo)航

淺談php使用curl模擬多線程發(fā)送請求

更新時間：2019年03月08日 16:11:54 作者：洛卡卡了

這篇文章主要介紹了php使用curl模擬多線程發(fā)送請求，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

每個PHP文件的執(zhí)行是單線程的，但是php本身也可以用一些別的技術(shù)實現(xiàn)多線程并發(fā)比如用php-fpm進(jìn)程，這里用curl模擬多線程發(fā)送請求。php的curl多線程是通過不斷調(diào)用curl_multi_exec來獲取內(nèi)容，這里舉一個demo來模擬一次curl多線程并發(fā)操作。

//設(shè)置緩沖為0(也可以去php.ini設(shè)置)
ini_set('output_buffering', 0);
//打開輸出緩沖區(qū)
ob_start();
//設(shè)置一個空數(shù)組
$curl_Arr=[];
//這里模擬20次請求
for($i=0;$i<20;$i++){
 //開啟curl連接
 $curl_Arr[$i]=curl_init("http://XXXX/test.php");
 //CURLOPT_RETURNTRANSFER 設(shè)置為1表示稍后執(zhí)行的curl_exec函數(shù)的返回是URL的返回字符串，而不是把返回字符串定向到標(biāo)準(zhǔn)輸出并返回TRUE；
 curl_setopt($curl_Arr[$i],CURLOPT_RETURNTRANSFER,1);
}

//創(chuàng)建批處理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){
 //發(fā)起curl_multi請求
 @curl_multi_exec($mh,$active);
 foreach($curl_Arr as $k => $ch){
  //獲取句柄的返回值
  if($result[$k]= curl_multi_getcontent($ch)){
   //輸出結(jié)果
   echo "$result[$k]\n";
   ob_flush();
   //把被釋放的數(shù)據(jù)發(fā)送到瀏覽器
   flush();
   //關(guān)閉該句柄
   curl_multi_remove_handle($mh,$ch);
   unset($curl_Arr[$k]);
  }
 }
}
//關(guān)閉ouput_buffering機制
ob_end_flush();
//關(guān)閉"curl_mulit"句柄
curl_multi_close($mh);

我再服務(wù)器上建立一起請求的php頁面命名為test.php，內(nèi)容如下

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

表示等待十秒后數(shù)據(jù)下面語句。
然后我在命令行執(zhí)行該程序結(jié)果如下：

上面代碼中通過循環(huán)$curl_Arr數(shù)組來調(diào)用curl_multi_getcontent來查詢是否有數(shù)據(jù)。有數(shù)據(jù)就輸出并刪除元素，直到$curl_Arr數(shù)組元素個數(shù)為0。
該模擬多線程實現(xiàn)是通過使用curl的curl_multi系列函數(shù)能實現(xiàn)此功能的。至于該系列函數(shù)使用介紹，百度一搜一大把。這里就不做說明了。

以上所述是小編給大家介紹的php使用curl模擬多線程發(fā)送請求詳解整合，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！

您可能感興趣的文章: