検索

ホームページ  >  記事  >  バックエンド開発  >  PHP 同時実行では、curl 同時実行を使用してバックエンドのアクセス時間を短縮します。

PHP 同時実行では、curl 同時実行を使用してバックエンドのアクセス時間を短縮します。

不言
不言オリジナル
2018-04-09 11:26:012206ブラウズ

この記事では、PHP の同時実行でのcurlの使用について説明します。同時実行によりバックエンドのアクセス時間が短縮されます。必要な方は参考にしてください。


まず、curlを理解しましょう。 PHP マルチスレッド関数: 

# curl_multi_add_handle
# curl_multi_close
# curl_multi_exec
# curl_multi_getcontent
# curl_multi_info_read
# curl_multi_init
# curl_multi_remove_handle
# curl_multi_select

一般的に、これらの関数を使用することを考えるとき、目的は明らかに、1 つずつリクエストするのではなく、複数の URL を同時にリクエストすることです。それ以外の場合は、調整する方がよいでしょう。ループ内のcurl_execを自分で実行します。

ステップは次のように要約されます:

ステップ 1:curl_multi_init を呼び出す
ステップ 2:ループ内でcurl_multi_add_handleを呼び出す
このステップでは、curl_multi_add_handle の 2 番目のパラメーターがcurl_init のサブハンドルであることに注意してください。
ステップ 3:curl_multi_exec を継続的に呼び出します
ステップ 4:結果を取得するために、必要に応じてループ内でcurl_multi_getcontentを呼び出します
ステップ 5:curl_multi_remove_handle を呼び出し、単語ハンドルごとにcurl_closeを呼び出します
ステップ 6:curl_multi_closeを呼び出します

オンライン検索は次のとおりです単純な例ですが、作者はこれを汚い例と呼んでいます (なぜ汚いのかは後ほど説明します): 

/*
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 関数を使用する必要がありますが、この関数にはほとんどドキュメントがありませんが、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の戻り値を使ってURLデータが存在するかどうかを判定しています。データがある場合、データがある場合、データがある場合、データがある場合、データがある場合、データがない場合は、curl_multi_exec が呼び出され続けます。当面はデータがありません。新しいデータが到着するとすぐに選択フェーズに入り、起動して実行を続行できます。この場合の利点は、CPU を不必要に消費しないことです。

さらに: 時々発生する可能性のある詳細がいくつかあります:

各リクエストのタイムアウトを制御し、curl_multi_add_handle の前にcurl_setopt を通して実行します:
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);

判断タイムアウトやその他のエラーがある場合は、curl_error($conn[$i]);



ここでは、curl_multi_getcontent の前に、上記の汚い例を単純に使用します (これで十分ですが、CPU が 100% 使用していることはわかりませんでした)。状態）。

「Kandian.com」の特定のインターフェースで同時実行性をシミュレートする機能は、memcache へのデータの読み取りと書き込みです。機密保持のため、関連するデータと結果は掲載されません。

3回シミュレーションしました。1回目は10スレッドが同時に1000回リクエストされました。2回目は100スレッドが同時に1000回リクエストされました。3回目は1000スレッドが同時に100回リクエストされました(これはすでにかなり手間がかかります) , マルチスレッドの1000以上はあえて設定しません）。

curl マルチスレッド シミュレーションの同時実行にはまだ特定の制限があるようです。

また、マルチスレッドの遅延により結果に大きな誤差があるのではないかとも思い、データを比較して分かりました。初期化と設定にかかる時間に大きな違いはありません。違いは get メソッドにあるため、これは単純に排除できます~~~

http://log.dongsheng.org/2008 /07/16/curl -multiple-handlers/

通常、PHP の cURL はブロック方式で実行されます。つまり、cURL リクエストを作成した後、それが正常に実行されるまで待つか、次のリクエストを実行する前にタイムアウトする必要があります。 curl_multi_* シリーズの関数により、正常な同時アクセスが可能になります。PHP ドキュメントでは、この関数の詳細は次のように紹介されていません。



源码打印？

$requests = array('http://www.baidu.com', 'http://www.google.com');  
$main    = curl_multi_init();  
$results = array();  
$errors  = array();  
$info = array();  
$count = count($requests);  
for($i = 0; $i < $count; $i++)   
{    
$handles[$i] = curl_init($requests[$i]);    
var_dump($requests[$i]);    
curl_setopt($handles[$i], CURLOPT_URL, $requests[$i]);    
curl_setopt($handles[$i], CURLOPT_RETURNTRANSFER, 1);    
curl_multi_add_handle($main, $handles[$i]);  
}  
$running = 0;   
do {    
curl_multi_exec($main, $running);  
}   
while($running > 0);   
for($i = 0; $i < $count; $i++)  
{  $results[] = curl_multi_getcontent($handles[$i]);    
$errors[]  = curl_error($handles[$i]);    
$info[]    = curl_getinfo($handles[$i]);    
curl_multi_remove_handle($main, $handles[$i]);  
}  
curl_multi_close($main);  
var_dump($results);  
var_dump($errors);  
var_dump($info);

 

 

http://www.searchtb.com/2010/12/using-multicurl-to-improve-performance.html

前言：在我们平时的程序中难免出现同时访问几个接口的情况，平时我们用curl进行访问的时候，一般都是单个、顺序访问，假如有3个接口，每个接口耗时500毫秒那么我们三个接口就要花费1500毫秒了，这个问题太头疼了严重影响了页面访问速度，有没有可能并发访问来提高速度呢？今天就简单的说一下，利用curl并发来提高页面访问速度，希望大家多指导。1、老的curl访问方式以及耗时统计




源码打印？

<?php function curl_fetch($url, $timeout=3){       
$ch = curl_init();       
curl_setopt($ch, CURLOPT_URL, $url);       
curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);       
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);       
$data = curl_exec($ch);       
$errno = curl_errno($ch);       
if ($errno>0) {           
$data = false;       
}       
curl_close($ch);       
return $data;   
}   
function microtime_float()   
{      
list($usec, $sec) = explode(" ", microtime());      
return ((float)$usec + (float)$sec);   
}   
$url_arr=array(        
"taobao"=>"http://www.taobao.com",        
"sohu"=>"http://www.sohu.com",        
"sina"=>"http://www.sina.com.cn",        
);    
$time_start = microtime_float();    
$data=array();    
foreach ($url_arr as $key=>$val)    
{        
$data[$key]=curl_fetch($val);    
}    
$time_end = microtime_float();    
$time = $time_end - $time_start;    
echo "耗时:{$time}";   
?>

耗时:0.614秒 
2、curl并发访问方式以及耗时统计




源码打印？

<?php   
function curl_multi_fetch($urlarr=array()){       
$result=$res=$ch=array();       
$nch = 0;       
$mh = curl_multi_init();       
foreach ($urlarr as $nk => $url) {           
$timeout=2;           
$ch[$nch] = curl_init();           
curl_setopt_array($ch[$nch], array(           
CURLOPT_URL => $url,           
CURLOPT_HEADER => false,           
CURLOPT_RETURNTRANSFER => true,           
CURLOPT_TIMEOUT => $timeout,           
));           
curl_multi_add_handle($mh, $ch[$nch]);           
++$nch;     }       
/* wait for performing request */      
do {           
$mrc = curl_multi_exec($mh, $running);       
} while (CURLM_CALL_MULTI_PERFORM == $mrc);         
while ($running && $mrc == CURLM_OK) {           
// wait for network           
if (curl_multi_select($mh, 0.5) > -1) {               
// pull in new data;               
do {                   
$mrc = curl_multi_exec($mh, $running);               
} while (CURLM_CALL_MULTI_PERFORM == $mrc);           
}       
}         
if ($mrc != CURLM_OK) {           
error_log("CURL Data Error");       
}         
/* get data */      
$nch = 0;       
foreach ($urlarr as $moudle=>$node) {           
if (($err = curl_error($ch[$nch])) == &#39;&#39;) {               
$res[$nch]=curl_multi_getcontent($ch[$nch]);             $result[$moudle]=$res[$nch];         }           
else          
{               
error_log("curl error");           
}           
curl_multi_remove_handle($mh,$ch[$nch]);           
curl_close($ch[$nch]);           
++$nch;       
}       
curl_multi_close($mh);       
return  $result;   
}   
$url_arr=array(        
"taobao"=>"http://www.taobao.com",        
"sohu"=>"http://www.sohu.com",        
"sina"=>"http://www.sina.com.cn",        
);   
function microtime_float()   
{      
list($usec, $sec) = explode(" ", microtime());      
return ((float)$usec + (float)$sec);   
}   
$time_start = microtime_float();   
$data=curl_multi_fetch($url_arr);   
$time_end = microtime_float();   
$time = $time_end - $time_start;   
echo "耗时:{$time}";   
?>

耗时:0.316秒
帅气吧整个页面访问后端接口的时间节省了一半
3、curl相关参数
来自：http://cn2.php.net/manual/en/ref.curl.php
curl_close — Close a cURL session
curl_copy_handle — Copy a cURL handle along with all of its preferences
curl_errno — Return the last error number
curl_error — Return a string containing the last error for the current session
curl_exec — Perform a cURL session
curl_getinfo — Get information regarding a specific transfer
curl_init — Initialize a cURL session
curl_multi_add_handle — Add a normal cURL handle to a cURL multi handle
curl_multi_close — Close a set of cURL handles
curl_multi_exec — Run the sub-connections of the current cURL handle
curl_multi_getcontent — Return the content of a cURL handle if CURLOPT_RETURNTRANSFER is set
curl_multi_info_read — Get information about the current transfers
curl_multi_init — Returns a new cURL multi handle
curl_multi_remove_handle — Remove a multi handle from a set of cURL handles
curl_multi_select — Wait for activity on any curl_multi connection
curl_setopt_array — Set multiple options for a cURL transfer
curl_setopt — Set an option for a cURL transfer
curl_version — Gets cURL version information

前端开发中的性能那点事（三）php的opcode缓存

前端开发中的性能那点事（一）巧用xdebug

 

http://www.oschina.net/question/234345_42245

 相关推荐：

php并发之关于查询MySQL的示例（图）

PHP并发读写文件如何解决

以上がPHP 同時実行では、curl 同時実行を使用してバックエンドのアクセス時間を短縮します。の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

php mysql html String if for select cURL Error 循环 接口 .net using 线程 多线程 copy 并发 memcache http
声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：Dreamweaver CS6 を使用して PHP プログラムを作成し、DW を使用して PHP サイトを作成します次の記事：Dreamweaver CS6 を使用して PHP プログラムを作成し、DW を使用して PHP サイトを作成します

関連記事

続きを見る