今回は、制御可能な同時非同期操作を実現するためのphpcurlバッチ処理のケースについて詳しく説明します。制御可能な同時非同期操作を実現するためにphpcurlバッチ処理で実装できる注意事項は次のとおりです。ケース、見てみましょう。
通常、PHP の cURL はブロック方式で実行されます。つまり、cURL リクエストを作成した後、それが正常に実行されるまで待機するか、次のリクエストを実行する前にタイムアウトする必要があります。CURL は一般に API インターフェース アクセスに優先されます実際のプロジェクトまたは自分で作成したガジェット (ニュース集約、製品価格監視、価格比較など) の開発プロセスでは、通常、URL キューが必要な場合に、サードパーティの Web サイトまたは API インターフェイスからデータを取得する必要があります。パフォーマンスを向上させるために、cURL が提供する ファミリを使用できます。この関数は単純な同時実行を実装します。curl_multi_*
<?php
include 'curl.class.php';
function callback($response, $info, $error, $request)
{
echo 'response:<br>';
print_r($response);
echo '<br>' . date("Y-m-d H:i:s") . ' <br>';
echo '<br>' . str_repeat("-", 100) . '<br>';
}
$USER_COOKIE = (!empty($_REQUEST['cookie'])) ? $_REQUEST['cookie'] : file_get_contents("cookie.txt");
$curl = new Curl ("callback");
$data = array(
array(
'url' => 'http://dyactive2.vip.xunlei.com/com_sign/?game=qmr&type=rec_gametime&referfrom=&rt=0.42521539455332336', //秦美人
'method' => 'POST',
'post_data' => '',
'header' => null,
'options' => array(
CURLOPT_REFERER => "http://niu.xunlei.com/entergame/?gameNo=qmr&fenQuNum=3",
CURLOPT_COOKIE => $USER_COOKIE,
)
),
array(
'url' => 'http://dyactive2.vip.xunlei.com/com_sign/?game=sq&type=rec_gametime&referfrom=&rt=0.42521539455332336', //神曲
'method' => 'POST',
'post_data' => '',
'header' => null,
'options' => array(
CURLOPT_REFERER => "http://niu.xunlei.com/entergame/?gameNo=sq&fenQuNum=41",
CURLOPT_COOKIE => $USER_COOKIE,
)
),
array(
'url' => 'http://dyactive2.vip.xunlei.com/com_sign/?game=frxz&type=rec_gametime&referfrom=&rt=0.42521539455332336', //凡人修真
'method' => 'POST',
'post_data' => '',
'header' => null,
'options' => array(
CURLOPT_REFERER => "http://niu.xunlei.com/entergame/?gameNo=frxz&fenQuNum=3",
CURLOPT_COOKIE => $USER_COOKIE,
)
),
array(
'url' => 'http://dyactive2.vip.xunlei.com/com_sign/?game=smxj&type=rec_gametime&referfrom=&rt=0.42521539455332336', //神魔仙界
'method' => 'POST',
'post_data' => '',
'header' => null,
'options' => array(
CURLOPT_REFERER => "http://niu.xunlei.com/entergame/?gameNo=smxj&fenQuNum=2",
CURLOPT_COOKIE => $USER_COOKIE,
)
),
array(
'url' => 'http://dyactive2.vip.xunlei.com/com_sign/?game=qsqy&type=rec_gametime&referfrom=&rt=0.42521539455332336', //倾世情缘
'method' => 'POST',
'post_data' => '',
'header' => null,
'options' => array(
CURLOPT_REFERER => "http://niu.xunlei.com/entergame/?gameNo=qsqy&fenQuNum=11",
CURLOPT_COOKIE => $USER_COOKIE,
)
),
);
foreach ($data as $val) {
$request = new Curl_request ($val ['url'], $val ['method'], $val ['post_data'], $val ['header'], $val ['options']);
$curl->add($request);
}
$curl->execute();
echo $curl->display_errors(); 使用時の効果は非常に優れており、副作用はなく、同時実行の数は制御可能であり、想像力を働かせてください<?php
/**
* cURL批量处理 工具类
*
* @since Version 1.0
* @author Justmepzy <justmepzy@gmail.com>
* @link http://t.qq.com/JustPzy
*/
/**
*单一的请求对象
*/
class Curl_request {
public $url = '';
public $method = 'GET';
public $post_data = null;
public $headers = null;
public $options = null;
/**
*
* @param string $url
* @param string $method
* @param string $post_data
* @param string $headers
* @param array $options
* @return void
*/
public function construct($url, $method = 'GET', $post_data = null, $headers = null, $options = null) {
$this->url = $url;
$this->method = strtoupper( $method );
$this->post_data = $post_data;
$this->headers = $headers;
$this->options = $options;
}
/**
* @return void
*/
public function destruct() {
unset ( $this->url, $this->method, $this->post_data, $this->headers, $this->options );
}
}
/**
* 包含请求列队处理
*/
class Curl {
/**
* 请求url个数
* @var int
*/
private $size = 5;
/**
* 等待所有cURL批处理中的活动连接等待响应时间
* @var int
*/
private $timeout = 5;
/**
* 完成请求回调函数
* @var string
*/
private $callback = null;
/**
* cRUL配置
* @var array
*/
private $options = array (CURLOPT_SSL_VERIFYPEER => 0,CURLOPT_RETURNTRANSFER => 1,CURLOPT_CONNECTTIMEOUT => 30 );
/**
* 请求头
* @var array
*/
private $headers = array ();
/**
* 请求列队
* @var array
*/
private $requests = array ();
/**
* 请求列队索引
* @var array
*/
private $request_map = array ();
/**
* 错误
* @var array
*/
private $errors = array ();
/**
* @access public
* @param string $callback 回调函数
* 该函数有4个参数($response,$info,$error,$request)
* $response url返回的body
* $info cURL连接资源句柄的信息
* $error 错误
* $request 请求对象
*/
public function construct($callback = null) {
$this->callback = $callback;
}
/**
* 添加一个请求对象到列队
* @access public
* @param object $request
* @return boolean
*/
public function add($request) {
$this->requests [] = $request;
return TRUE;
}
/**
* 创建一个请求对象并添加到列队
* @access public
* @param string $url
* @param string $method
* @param string $post_data
* @param string $headers
* @param array $options
* @return boolean
*/
public function request($url, $method = 'GET', $post_data = null, $headers = null, $options = null) {
$this->requests [] = new Curl_request ( $url, $method, $post_data, $headers, $options );
return TRUE;
}
/**
* 创建GET请求对象
* @access public
* @param string $url
* @param string $headers
* @param array $options
* @return boolean
*/
public function get($url, $headers = null, $options = null) {
return $this->request ( $url, "GET", null, $headers, $options );
}
/**
* 创建一个POST请求对象
* @access public
* @param string $url
* @param string $post_data
* @param string $headers
* @param array $options
* @return boolean
*/
public function post($url, $post_data = null, $headers = null, $options = null) {
return $this->request ( $url, "POST", $post_data, $headers, $options );
}
/**
* 执行cURL
* @access public
* @param int $size 最大连接数
* @return Ambigous <boolean, mixed>|boolean
*/
public function execute($size = null) {
if (sizeof ( $this->requests ) == 1) {
return $this->single_curl ();
} else {
return $this->rolling_curl ( $size );
}
}
/**
* 单个url请求
* @access private
* @return mixed|boolean
*/
private function single_curl() {
$ch = curl_init ();
$request = array_shift ( $this->requests );
$options = $this->get_options ( $request );
curl_setopt_array ( $ch, $options );
$output = curl_exec ( $ch );
$info = curl_getinfo ( $ch );
// it's not neccesary to set a callback for one-off requests
if ($this->callback) {
$callback = $this->callback;
if (is_callable ( $this->callback )) {
call_user_func ( $callback, $output, $info, $request );
}
} else
return $output;
return true;
}
/**
* 多个url请求
* @access private
* @param int $size 最大连接数
* @return boolean
*/
private function rolling_curl($size = null) {
if ($size)
$this->size = $size;
else
$this->size = count($this->requests);
if (sizeof ( $this->requests ) < $this->size)
$this->size = sizeof ( $this->requests );
if ($this->size < 2)
$this->set_error ( 'size must be greater than 1' );
$master = curl_multi_init ();
//添加cURL连接资源句柄到map索引
for($i = 0; $i < $this->size; $i ++) {
$ch = curl_init ();
$options = $this->get_options ( $this->requests [$i] );
curl_setopt_array ( $ch, $options );
curl_multi_add_handle ( $master, $ch );
$key = ( string ) $ch;
$this->request_map [$key] = $i;
}
$active = $done = null;
do {
while ( ($execrun = curl_multi_exec ( $master, $active )) == CURLM_CALL_MULTI_PERFORM )
;
if ($execrun != CURLM_OK)
break;
//有一个请求完成则回调
while ( $done = curl_multi_info_read ( $master ) ) {
//$done 完成的请求句柄
$info = curl_getinfo ( $done ['handle'] );//
$output = curl_multi_getcontent ( $done ['handle'] );//
$error = curl_error ( $done ['handle'] );//
$this->set_error ( $error );
//调用回调函数,如果存在的话
$callback = $this->callback;
if (is_callable ( $callback )) {
$key = ( string ) $done ['handle'];
$request = $this->requests [$this->request_map [$key]];
unset ( $this->request_map [$key] );
call_user_func ( $callback, $output, $info, $error, $request );
}
curl_close ( $done ['handle'] );
//从列队中移除已经完成的request
curl_multi_remove_handle ( $master, $done ['handle'] );
}
//等待所有cURL批处理中的活动连接
if ($active)
curl_multi_select ( $master, $this->timeout );
} while ( $active );
//完成关闭
curl_multi_close ( $master );
return true;
}
/**
* 获取没得请求对象的cURL配置
* @access private
* @param object $request
* @return array
*/
private function get_options($request) {
$options = $this->get ( 'options' );
if (ini_get ( 'safe_mode' ) == 'Off' || ! ini_get ( 'safe_mode' )) {
$options [CURLOPT_FOLLOWLOCATION] = 1;
$options [CURLOPT_MAXREDIRS] = 5;
}
$headers = $this->get ( 'headers' );
if ($request->options) {
$options = $request->options + $options;
}
$options [CURLOPT_URL] = $request->url;
if ($request->post_data && strtolower($request->method) == 'post' ) {
$options [CURLOPT_POST] = 1;
$options [CURLOPT_POSTFIELDS] = $request->post_data;
}
if ($headers) {
$options [CURLOPT_HEADER] = 0;
$options [CURLOPT_HTTPHEADER] = $headers;
}
return $options;
}
/**
* 设置错误信息
* @access public
* @param string $msg
*/
public function set_error($msg) {
if (! empty ( $msg ))
$this->errors [] = $msg;
}
/**
* 获取错误信息
* @access public
* @param string $open
* @param string $close
* @return string
*/
public function display_errors($open = '<p>', $close = '</p>') {
$str = '';
foreach ( $this->errors as $val ) {
$str .= $open . $val . $close;
}
return $str;
}
/**
* @access public
* @param string $name
* @param string $value
* @return boolean
*/
public function set($name, $value) {
if ($name == 'options' || $name == 'headers') {
$this->{$name} = $value + $this->{$name};
} else {
$this->{$name} = $value;
}
return TRUE;
}
/**
*
* @param string $name
* @return mixed
* @access public
*/
public function get($name) {
return (isset ( $this->{$name} )) ? $this->{$name} : null;
}
/**
* @return void
* @access public
*/
public function destruct() {
unset ( $this->size, $this->timeout, $this->callback, $this->options, $this->headers, $this->requests, $this->request_map, $this->errors );
}
}
// END Curl Class
/* End of file curl.class.php */ この記事の事例を読んだ後は、この方法を習得したと思います。さらに興味深い情報を入手してください。php 中国語 Web サイトの他の関連記事にも注目してください。 推奨読書:
WeChat アプレットの製品詳細ページにポップアップ ボックスを追加する方法
React でシングルトン コンポーネントを作成する手順の詳細な説明
以上が制御可能な同時非同期操作を実現するためのphpcurlバッチ処理の事例の詳細説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
トラフィックの高いウェブサイトのPHPパフォーマンスチューニングMay 14, 2025 am 12:13 AMthesecrettokeepingaphp-poweredwebsterunningsmootlyunderheavyloadinvolvesseveralkeystrategies：1）emform opcodecoduceSciptionexecutiontime、2）aatabasequerycachingwithiThing withiThistolessendavasoload、
PHPでの依存関係注射：初心者向けのコード例May 14, 2025 am 12:08 AMコードをより明確かつ維持しやすくするため、依存関係が関心（DI）に注意する必要があります。 1）DIは、クラスを切り離すことにより、よりモジュール化されます。2）テストとコードの柔軟性の利便性を向上させ、3）DIコンテナを使用して複雑な依存関係を管理しますが、パフォーマンスの影響と円形の依存関係に注意してください。
PHPパフォーマンス：アプリケーションを最適化することは可能ですか？May 14, 2025 am 12:04 AMはい、最適化されたAphPossibleandessention.1）CachingingusapCutoredatedAtabaseload.2）最適化、効率的なQueries、およびConnectionPooling.3）EnhcodeCodewithBultinctions、Avoididingglobalbariables、およびUsingopcodeching
PHPパフォーマンスの最適化：究極のガイドMay 14, 2025 am 12:02 AMkeyStrategIestsoSificlyvoostphpappliceperformanceare：1）useopcodecachinglikeToreexecutiontime、2）最適化abaseの相互作用とプロペラインデックス、3）3）構成
PHP依存性噴射コンテナ：クイックスタートMay 13, 2025 am 12:11 AMaphpDependencyInjectionContaineriSATOULTAINATINAGECLASSDEPTINCIES、強化測定性、テスト可能性、および維持可能性。
PHPの依存噴射対サービスロケーターMay 13, 2025 am 12:10 AMSELECT DEPENTENCINGINOFCENT（DI）大規模なアプリケーションの場合、ServicElocatorは小さなプロジェクトまたはプロトタイプに適しています。 1）DIは、コンストラクターインジェクションを通じてコードのテスト可能性とモジュール性を改善します。 2）ServiceLocatorは、センター登録を通じてサービスを取得します。これは便利ですが、コードカップリングの増加につながる可能性があります。
PHPパフォーマンス最適化戦略。May 13, 2025 am 12:06 AMphpapplicationscanbeoptimizedforspeedandEfficiencyby：1）enabingopcacheinphp.ini、2）PreparedStatementswithpordatabasequeriesを使用して、3）LoopswithArray_filterandarray_mapfordataprocessing、4）の構成ngincasaSearverseproxy、5）
PHPメールの検証：電子メールが正しく送信されるようにしますMay 13, 2025 am 12:06 AMPHPemailvalidationinvolvesthreesteps:1)Formatvalidationusingregularexpressionstochecktheemailformat;2)DNSvalidationtoensurethedomainhasavalidMXrecord;3)SMTPvalidation,themostthoroughmethod,whichchecksifthemailboxexistsbyconnectingtotheSMTPserver.Impl
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
Video Face Swap
完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。
人気の記事
<🎜>：バブルガムシミュレーターインフィニティ - ロイヤルキーの取得と使用方法
4週間前By尊渡假赌尊渡假赌尊渡假赌
<🎜>：庭を育てる - 完全な突然変異ガイド
3週間前ByDDD
Nordhold：Fusion System、説明
4週間前By尊渡假赌尊渡假赌尊渡假赌
マンドラゴラ：魔女の木のささやき - グラップリングフックのロックを解除する方法
3週間前By尊渡假赌尊渡假赌尊渡假赌
ホットツール
ZendStudio 13.5.1 Mac
強力な PHP 統合開発環境
メモ帳++7.3.1
使いやすく無料のコードエディター
VSCode Windows 64 ビットのダウンロード
Microsoft によって発売された無料で強力な IDE エディター
SublimeText3 Linux 新バージョン
SublimeText3 Linux 最新バージョン
SublimeText3 英語版
推奨: Win バージョン、コードプロンプトをサポート!
