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 句柄響應組成的結果集數組。和單獨請求相比,基本可以節約一半的時間。