摘要:根據(jù)獲取請(qǐng)求對(duì)象這個(gè)比較簡(jiǎn)單可以看官方文檔將三個(gè)待請(qǐng)求對(duì)象放入下載器中輪詢(xún)一旦有一個(gè)請(qǐng)求完成,找出來(lái),處理因?yàn)榈讓邮?,所以最大受限于從?qǐng)求中獲取信息內(nèi)容錯(cuò)誤把請(qǐng)求已經(jīng)完成了得刪除當(dāng)沒(méi)有數(shù)據(jù)的時(shí)候進(jìn)行堵塞,把使用權(quán)交出來(lái),避免上面死循環(huán)空跑數(shù)
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; } }
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://hztianpu.com/yun/22085.html
摘要:普通請(qǐng)求創(chuàng)建多個(gè)資源并發(fā)創(chuàng)建多個(gè)資源創(chuàng)建批處理句柄增加句柄待優(yōu)化點(diǎn)在執(zhí)行而整個(gè)批處理句柄沒(méi)有全部執(zhí)行完畢時(shí),系統(tǒng)會(huì)不停地執(zhí)行函數(shù)。進(jìn)行改動(dòng)的方式是應(yīng)用函數(shù)庫(kù)中的函數(shù),其函數(shù)原型如下阻塞直到批處理連接中有活動(dòng)連接。 普通請(qǐng)求 curl_normal.php use time:0.830 s curl_multi并發(fā) curl_multi.php use time:0.259 s ...
摘要:不支持多線程模式和回調(diào)處理,因此內(nèi)部腳本都是同步阻塞式的,如果你發(fā)起一個(gè)的請(qǐng)求,那么程序就會(huì)阻塞,直到請(qǐng)求返回結(jié)果,才會(huì)繼續(xù)執(zhí)行代碼。參考資料手冊(cè)手冊(cè)預(yù)定義常量中實(shí)現(xiàn)多線程請(qǐng)求詳解每次使用同時(shí)并發(fā)多少請(qǐng)求合適簡(jiǎn)書(shū)多線程及原理 后端服務(wù)開(kāi)發(fā)中經(jīng)常會(huì)有并發(fā)請(qǐng)求的需求,比如你需要獲取10家供應(yīng)商的帶寬數(shù)據(jù)(每個(gè)都提供不同的url),然后返回一個(gè)整合后的數(shù)據(jù),你會(huì)怎么做呢? 在PHP中,最直觀...
摘要:今天我就來(lái)聊聊我關(guān)于函數(shù)集的使用心得,關(guān)于請(qǐng)求的問(wèn)題。耗時(shí)這是不能容忍的。事實(shí)上內(nèi)部實(shí)現(xiàn)就是用的事件循環(huán)。通過(guò)函數(shù)創(chuàng)建下載器。四復(fù)雜的運(yùn)用這就是用法在上面的例子中。動(dòng)態(tài)的從下載器中取出已經(jīng)完成了的請(qǐng)求。函數(shù)實(shí)現(xiàn)的壓測(cè)工具。 一、引言 這段時(shí)間比較忙,已經(jīng)很久沒(méi)有寫(xiě)博客了。今天我就來(lái)聊聊我關(guān)于curl_multi_*函數(shù)集的使用心得,關(guān)于http請(qǐng)求的問(wèn)題。 當(dāng)我們用戶(hù)php發(fā)起一個(gè)ht...
摘要:最近在維護(hù)一個(gè)三年前的舊代碼,用的是框架。單元測(cè)試和語(yǔ)言并發(fā)控制實(shí)際上是個(gè)蛋疼的問(wèn)題,夸張一點(diǎn)說(shuō),當(dāng)時(shí)的并不能特別輕松地實(shí)現(xiàn)并發(fā),甚至不能實(shí)現(xiàn)并發(fā)。語(yǔ)言的功能之一就是自帶單元測(cè)試。用語(yǔ)言之前,我的習(xí)慣是不寫(xiě)單元測(cè)試。 最近在維護(hù)一個(gè)三年前的舊代碼,用的是laravel框架。 從某些方面來(lái)講,這個(gè)代碼算是比較標(biāo)準(zhǔn)為了實(shí)現(xiàn)在規(guī)定的時(shí)間內(nèi)完成相關(guān)功能,同時(shí)程序員水平不高、經(jīng)過(guò)大量?jī)?yōu)化之后,變...
摘要:編程中的并發(fā)周末去北京面了兩個(gè)公司,認(rèn)識(shí)了幾位技術(shù)牛人,面試中聊了很多,感覺(jué)收獲頗豐。本文大約總結(jié)了編程中的五種并發(fā)方式,最后的的實(shí)現(xiàn)純屬無(wú)聊,可以無(wú)視。生成的可以中斷函數(shù),并用向發(fā)送消息。 PHP編程中的并發(fā) 周末去北京面了兩個(gè)公司,認(rèn)識(shí)了幾位技術(shù)牛人,面試中聊了很多,感覺(jué)收獲頗豐。認(rèn)識(shí)到了自己的不足之處,也堅(jiān)定了自己對(duì)計(jì)算機(jī)學(xué)習(xí)的信心。本文是對(duì)其中一道面試題的總結(jié)。 面試中有一個(gè)問(wèn)...
閱讀 1823·2021-09-22 15:21
閱讀 3004·2021-09-09 09:32
閱讀 2892·2021-09-02 09:52
閱讀 3448·2019-08-30 14:02
閱讀 2364·2019-08-26 13:25
閱讀 1617·2019-08-26 13:24
閱讀 1758·2019-08-26 10:31
閱讀 1700·2019-08-26 10:16