PHP之curl_multi并发详解方法-php教程

资源魔 2020-07-08 22:28:21 30 0

PHP中curl_multi并发详解

PHP中的curl_multi系列函数能够完成同时申请多个URL来完成并发，而没有是像一般curl函数那样申请后会梗阻，直到后果前往才进行下一个申请。因而正在批量申请URL时可经过curl_multi系列函数晋升顺序的运转效率。

curl一般申请

$startTime = microtime(true);
$chArr = [];
$optArr = [
    CURLOPT_URL => 'http://www.httpbin.org/ip',
    CURLOPT_HEADER => 0,
    CURLOPT_RETURNTRANSFER => 1,
];
$result = [];
//创立多个curl资本并执行
for ($i=0; $i<10; $i++) {
    $chArr[$i] = curl_init();
    curl_setopt_array($chArr[$i], $optArr);
    $result[$i] = curl_exec($chArr[$i]);
    curl_close($chArr[$i]);
}
$endTime = microtime(true);
echo sprintf("use time: %.3f s".PHP_EOL, $endTime - $startTime);use time: 6.080 s

use time: 6.080 s

curl_multi并发申请

$startTime = microtime(true);
$chArr = [];
$optArr = [
    CURLOPT_URL => 'http://www.httpbin.org/ip',
    CURLOPT_HEADER => 0,
    CURLOPT_RETURNTRANSFER => 1,
];
$result = [];
//创立多个curl资本
for ($i=0; $i<10; $i++) {
    $chArr[$i] = curl_init();
    curl_setopt_array($chArr[$i], $optArr);
}
//创立批解决curl句柄
$mh = curl_multi_init();
//将单个curl句柄增加到批解决curl句柄中
foreach ($chArr as $ch) {
    curl_multi_add_handle($mh, $ch);
}
//判别操作能否仍正在执行的标识的援用
$active = null;
/**
 * 本次轮回第一次解决 $mh 批解决中的 $ch 句柄，并将 $mh 批解决的执行状态写入 $active，
 * 当状态值等于 CURLM_CALL_MULTI_PERFORM 时，标明数据还正在写入或读取中，执行轮回，
 * 当第一次 $ch 句柄的数据写入或读取胜利后，状态值变成 CURLM_OK ，跳出本次轮回，进入上面的年夜轮回中。
 */
do {
    //解决正在批解决栈中的每个句柄
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);
/**
 * 下面这段代码中，是能够间接应用 $active > 0 来作为 while 的前提，以下：
 * do {
 *   $mrc = curl_multi_exec($mh, $active);
 * } while ($active > 0);
 * 此时假如整个批解决句柄不全副执行终了时，零碎会不绝的执行 curl_multi_exec 函数，从而招致零碎CPU占用会很高，
 * 因而普通没有采纳这类计划，能够经过 curl_multi_select 函数来达到不需求读取的顺序就梗阻住的目的。
 */
/**
 * $active 为 true 时，即 $mh 批解决之中另有 $ch 句柄期待解决，
 * $mrc == CURLM_OK，即上一次 $ch 句柄的读取或写入曾经执行终了。
 */
while ($active && $mrc == CURLM_OK) {
    /** 
     * 顺序进入梗阻状态，直到批解决中有流动衔接（即 $mh 批解决中另有可执行的 $ch 句柄），
     * 这样执行的益处是 $mh 批解决中的 $ch 句柄会正在读取或写入数据完结后（$mrc == CURLM_OK）进入梗阻阶段，
     * 而没有会正在整个 $mh 批解决执行时不绝地执行 curl_multi_exec 函数，白白糜费CPU资本。
     */
     if (curl_multi_select($mh) != -1) {
        //顺序加入梗阻状态持续执行需求解决的 $ch 句柄
        do {
            $mrc = curl_multi_exec($mh, $active);
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    }
}
foreach ($chArr as $i=>$ch) {
    //猎取某个curl句柄的前往值
    $result[$i] = curl_multi_getcontent($ch);
    //移除了批解决句柄中的某个句柄资本
    curl_multi_remove_handle($mh, $ch);
}
//封闭一组curl句柄
curl_multi_close($mh);
$endTime = microtime(true);
echo sprintf("use time: %.3f s".PHP_EOL, $endTime - $startTime);