• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

对PHP中curl_multi相关函数的应用讲解

php 搞代码 3年前 (2022-01-23) 33次浏览 已收录 0个评论

相信许多人对php手册中语焉不详的curl_multi一族的函数头疼不已,它们文档少,给的例子 更是简单的让你无从借鉴,我也曾经找了许多网页,都没见一个完整的应用例子。

curl_multi_add_h/本文来源gao@!dai!ma.com搞$$代^@码5网@搞代gaodaima码andle

curl_multi_close

curl_multi_exec

curl_multi_getcontent

curl_multi_info_read

curl_multi_init

curl_multi_remove_handle

curl_multi_select

一般来说,想到要用这些函数时,目的显然应该是要同时请求多个url,而不是一个一个依次请求,否则不如自己循环去调curl_exec好了。

步骤总结如下:

第一步:调用curl_multi_init
第二步:循环调用curl_multi_add_handle
这一步需要注意的是,curl_multi_add_handle的第二个参数是由curl_init而来的子handle。
第三步:持续调用curl_multi_exec
第四步:根据需要循环调用curl_multi_getcontent获取结果
第五步:调用curl_multi_remove_handle,并为每个字handle调用curl_close
第六步:调用curl_multi_close

这里有一个网上找的简单例子,其作者称为dirty的例子,(稍后我会说明为何dirty):

/*Here's a quick and dirty example for curl-multi from PHP, tested on PHP 5.0.0RC1 CLI / FreeBSD 5.2.1*/$connomains = array("http://www.cnn.com/","http://www.canada.com/","http://www.yahoo.com/");$mh = curl_multi_init();foreach ($connomains as $i => $url) {     $conn[$i]=curl_init($url);      curl_setopt($conn[$i],CURLOPT_RETURNTRANSFER,1);      curl_multi_add_handle ($mh,$conn[$i]);}do { $n=curl_multi_exec($mh,$active); } while ($active);foreach ($connomains as $i => $url) {      $res[$i]=curl_multi_getcontent($conn[$i]);      curl_close($conn[$i]);}print_r($res);

整个使用过程差不多就是这样,但是,这个简单代码有个致命弱点,就是在do循环的那段,在整个url请求期间是个死循环,它会轻易导致CPU占用100%。

现在我们来改进它,这里要用到一个几乎没有任何文档的函数curl_multi_select了,虽然C的curl库对select有说明,但是,php里的接口和用法确与C中有不同。

把上面do的那段改成下面这样:

 do {                        $mrc = curl_multi_exec($mh,$active);                } while ($mrc == CURLM_CALL_MULTI_PERFORM);                while ($active and $mrc == CURLM_OK) {                        if (curl_multi_select($mh) != -1) {                                do {                                        $mrc = curl_multi_exec($mh, $active);                                } while ($mrc == CURLM_CALL_MULTI_PERFORM);                        }                }

因 为$active要等全部url数据接受完毕才变成false,所以这里用到了curl_multi_exec的返回值判断是否还有数据,当有数据的时候 就不停调用curl_multi_exec,暂时没有数据就进入select阶段,新数据一来就可以被唤醒继续执行。这里的好处就是CPU的无谓消耗没有 了。

另外:还有一些细节的地方可能有时候要遇到:

控制每一个请求的超时时间,在curl_multi_add_handle之前通过curl_setopt去做:
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);

判断是否超时了或者其他错误,在curl_multi_getcontent之前用:curl_error($conn[$i])

class MultiCurl{private $mch;private $timeout;private $urls;private $chs;private $errchs;private $content;public function __construct($urls, $timeout=300){ $this->mch = curl_multi_init(); $this->timeout =  $timeout; $this->urls = $urls; $this->chs = array(); $this->errchs = array(); $this->content = array();}public function ctlFlow(){ $this->createhandle(); $this->execurl(); $this->chs = array(); $this->errchs = array(); echo "<pre>"; print_r($this->content); echo "</pre>"; return $this->content;}private function createhandle(){ if(!empty($this->urls)){  foreach($this->urls as $k => $url){   $ch = curl_init();   curl_setopt($ch, CURLOPT_URL, $url);   curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);   curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout);   curl_multi_add_handle($this->mch, $ch);   $this->chs[$k] = $ch;  } }}private function execurl(){ do {  $mrc = curl_multi_exec($this->mch,$active); } while ($mrc == CURLM_CALL_MULTI_PERFORM);  while ($active && $mrc == CURLM_OK) {  if (curl_multi_select($this->mch) != -1) {   usleep(300);   do {    $mrc = curl_multi_exec($this->mch, $active);   } while ($mrc == CURLM_CALL_MULTI_PERFORM);  } }  foreach($this->chs as $k => $c){             if (curl_error($c) == '') {                 $temp = curl_multi_getcontent($c);                 $count = 0;                 while(!$temp){                     if($count > 3) break;                     usleep(100);                     $temp = curl_multi_getcontent($c);                     $count++;                 }                 $this->content[$k] = $temp;                 unset($this->chs[$k]);                 curl_multi_remove_handle($this->mch, $c);                 curl_close($c);             } else {                 $this->errchs[$k] = $this->urls[$k];             } }}}$urlArr = array('baidu'=>'www.baidu.com', 'google'=>'www.google.com.hk', 'sogou'=>'www.sogou.com');$mucurl = new MultiCurl($urlArr);$mucurl->ctlFlow();

以上就是对PHP中curl_multi相关函数的应用讲解的详细内容,更多请关注搞代码gaodaima其它相关文章!


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:对PHP中curl_multi相关函数的应用讲解

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址