PHP使用curl_multi實(shí)現(xiàn)并發(fā)請(qǐng)求的方法示例
本文實(shí)例講述了PHP使用curl_multi實(shí)現(xiàn)并發(fā)請(qǐng)求的方法。分享給大家供大家參考,具體如下:
class CurlMultiUtil {
/**
* 根據(jù)url,postData獲取curl請(qǐng)求對(duì)象,這個(gè)比較簡(jiǎn)單,可以看官方文檔
*/
private static function getCurlObject($url,$postData=array(),$header=array()){
$options = array();
$url = trim($url);
$options[CURLOPT_URL] = $url;
$options[CURLOPT_TIMEOUT] = 3;
$options[CURLOPT_RETURNTRANSFER] = true;
foreach($header as $key=>$value){
$options[$key] =$value;
}
if(!empty($postData) && is_array($postData)){
$options[CURLOPT_POST] = true;
$options[CURLOPT_POSTFIELDS] = http_build_query($postData);
}
if(stripos($url,'https') === 0){
$options[CURLOPT_SSL_VERIFYPEER] = false;
}
$ch = curl_init();
curl_setopt_array($ch,$options);
return $ch;
}
/**
* [request description]
* @param [type] $chList
* @return [type]
*/
private static function request($chList){
$downloader = curl_multi_init();
// 將三個(gè)待請(qǐng)求對(duì)象放入下載器中
foreach ($chList as $ch){
curl_multi_add_handle($downloader,$ch);
}
$res = array();
// 輪詢(xún)
do {
while (($execrun = curl_multi_exec($downloader, $running)) == CURLM_CALL_MULTI_PERFORM);
if ($execrun != CURLM_OK) {
break;
}
// 一旦有一個(gè)請(qǐng)求完成,找出來(lái),處理,因?yàn)閏url底層是select,所以最大受限于1024
while ($done = curl_multi_info_read($downloader)){
// 從請(qǐng)求中獲取信息、內(nèi)容、錯(cuò)誤
// $info = curl_getinfo($done['handle']);
$output = curl_multi_getcontent($done['handle']);
// $error = curl_error($done['handle']);
$res[] = $output;
// 把請(qǐng)求已經(jīng)完成了得 curl handle 刪除
curl_multi_remove_handle($downloader, $done['handle']);
}
// 當(dāng)沒(méi)有數(shù)據(jù)的時(shí)候進(jìn)行堵塞,把 CPU 使用權(quán)交出來(lái),避免上面 do 死循環(huán)空跑數(shù)據(jù)導(dǎo)致 CPU 100%
if ($running) {
$rel = curl_multi_select($downloader, 1);
if($rel == -1){
usleep(1000);
}
}
if($running == false){
break;
}
}while(true);
curl_multi_close($downloader);
return $res;
}
/**
* [get description]
* @param [type] $urlArr
* @return [type]
*/
public static function get($urlArr){
$data = array();
if (!empty($urlArr)) {
$chList = array();
foreach ($urlArr as $key => $url) {
$chList[] = self::getCurlObject($url);
}
$data = self::request($chList);
}
return $data;
}
}
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專(zhuān)題:《php curl用法總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》、《php程序設(shè)計(jì)算法總結(jié)》、《PHP運(yùn)算與運(yùn)算符用法總結(jié)》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
- php多進(jìn)程并發(fā)編程防止出現(xiàn)僵尸進(jìn)程的方法分析
- PHP高并發(fā)和大流量解決方案整理
- PHP 并發(fā)場(chǎng)景的幾種解決方案
- PHP下用Swoole實(shí)現(xiàn)Actor并發(fā)模型的方法
- php多進(jìn)程模擬并發(fā)事務(wù)產(chǎn)生的問(wèn)題小結(jié)
- PHP利用Mysql鎖解決高并發(fā)的方法
- PHP curl批處理及多請(qǐng)求并發(fā)實(shí)現(xiàn)方法分析
- php curl批處理實(shí)現(xiàn)可控并發(fā)異步操作示例
- 詳解PHP服務(wù)器如何在有限的資源里最大提升并發(fā)能力
相關(guān)文章
PHP實(shí)現(xiàn)二維數(shù)組中的查找算法小結(jié)
這篇文章主要介紹了PHP實(shí)現(xiàn)二維數(shù)組中的查找算法,涉及PHP數(shù)組遍歷、判斷、計(jì)算等相關(guān)操作技巧,需要的朋友可以參考下2018-06-06
PHP向?yàn)g覽器輸出內(nèi)容的4個(gè)函數(shù)總結(jié)
這篇文章主要介紹了PHP向?yàn)g覽器輸出內(nèi)容的4個(gè)函數(shù)總結(jié),本文總結(jié)的就是print()、echo()、printf()、sprintf()這4個(gè)輸出函數(shù),需要的朋友可以參考下2014-11-11
實(shí)現(xiàn)PHP多線(xiàn)程異步請(qǐng)求的3種方法
實(shí)現(xiàn)PHP多線(xiàn)程異步請(qǐng)求的方法有很多,在本文整理了3種不多的常用方法,大家可以參考下2014-01-01
PHP內(nèi)置的Math函數(shù)效率測(cè)試
這篇文章主要介紹了PHP內(nèi)置的Math函數(shù)效率測(cè)試,以實(shí)例形式測(cè)試了相關(guān)的PHP內(nèi)置數(shù)學(xué)運(yùn)算函數(shù)的執(zhí)行時(shí)間,分析其運(yùn)行效率,需要的朋友可以參考下2014-12-12
php7連接MySQL實(shí)現(xiàn)簡(jiǎn)易查詢(xún)程序的方法
這篇文章主要給大家介紹了關(guān)于php7連接MySQL實(shí)現(xiàn)簡(jiǎn)易查詢(xún)程序的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-10-10
php+mysql開(kāi)發(fā)的最簡(jiǎn)單在線(xiàn)題庫(kù)(在線(xiàn)做題系統(tǒng))完整案例
這篇文章主要介紹了php+mysql開(kāi)發(fā)的最簡(jiǎn)單在線(xiàn)題庫(kù)(在線(xiàn)做題系統(tǒng))案例,結(jié)合完整實(shí)例形式分析了PHP結(jié)合MySQL數(shù)據(jù)庫(kù)查詢(xún)、判斷實(shí)現(xiàn)的在線(xiàn)題庫(kù)功能相關(guān)操作技巧,需要的朋友可以參考下2019-03-03

