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