每個(gè)PHP文件的執(zhí)行是單線程的,但是php本身也可以用一些別的技術(shù)實(shí)現(xiàn)多線程并發(fā)比如用php-fpm進(jìn)程,這里用curl模擬多線程發(fā)送請(qǐng)求。php的curl多線程是通過不斷調(diào)用curl_multi_exec來獲取內(nèi)容,這里舉一個(gè)demo來模擬一次curl多線程并發(fā)操作。
//設(shè)置緩沖為0(也可以去php.ini設(shè)置) ini_set('output_buffering', 0); //打開輸出緩沖區(qū) ob_start(); //設(shè)置一個(gè)空數(shù)組 $curl_Arr=[]; //這里模擬20次請(qǐng)求 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請(qǐng)求 @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機(jī)制 ob_end_flush(); //關(guān)閉"curl_mulit"句柄 curl_multi_close($mh);
我再服務(wù)器上建立一起請(qǐng)求的php頁(yè)面命名為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ù)組元素個(gè)數(shù)為0。
該模擬多線程實(shí)現(xiàn)是通過使用curl的curl_multi系列函數(shù)能實(shí)現(xiàn)此功能的。至于該系列函數(shù)使用介紹,百度一搜一大把。這里就不做說明了。
以上所述是小編給大家介紹的php使用curl模擬多線程發(fā)送請(qǐng)求詳解整合,希望對(duì)大家有所幫助,如果大家有任何疑問請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)服務(wù)器之家網(wǎng)站的支持!