使用 curl_multi_init 執行并發請求

PHP 語言不像 JavaScript 那樣具備異步回調的特性，實現并發也就有些棘手。不過對于服務器之間進行連接和通訊，PHP 良好支持了 libcurl 庫，要執行一批并發請求，依靠 curl_multi_init 方法就可以輕松搞定。

通常，一個簡單的 CURL 請求是這樣被組裝和發送的：

$ch = curl_init();
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
$data = curl_exec($ch);
curl_close($ch);
一旦 curl_exec 被執行，我們就可以捕獲到 $data 變量，也就是所需要的響應結果。

換做 curl_multi_exec 同樣有效，原生 PHP 允許并行地處理批處理 CURL 句柄。那么如何實現一批并發的 CURL 句柄呢？我們可以通過建立一個 CURL 批處理會話，來控制兩個獨立的 CURL 句柄。當會話需要執行時，通過 curl_multi_exec 去處理在棧中的一個句柄。封裝成一個函數，基本是這樣的：

function curl_multi ($query_arr) {
$ch = curl_multi_init();
$count = count($query_arr);
$ch_arr = array();
for ($i = 0; $i < $count; $i++) {
$query_string = $query_arr[$i];
$ch_arr[$i] = curl_init($query_string);
curl_setopt($ch_arr[$i], CURLOPT_RETURNTRANSFER, true);
curl_multi_add_handle($ch, $ch_arr[$i]);
}
$running = null;
do {
curl_multi_exec($ch, $running);
} while ($running > 0);
for ($i = 0; $i < $count; $i++) {
$results[$i] = curl_multi_getcontent($ch_arr[$i]);
curl_multi_remove_handle($ch, $ch_arr[$i]);
}
curl_multi_close($ch);
return $results;
}

最終所返回的數據是一個由單獨 CURL 句柄響應組成的結果集數組。和單獨請求相比，基本可以節約一半的時間。

生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈