今日、フォーラムで、PHP がバッチおよびノンブロッキングな方法でデータをサーバーにプッシュする方法を尋ねている人を見かけました。大まかな概要は次のとおりです。
関連する推奨事項: 「PHP チュートリアル 」
1. 最も簡単な方法:
スクリプトを同時に複数回実行し、パラメーターを使用して実行範囲を指定します。 10,000 人のユーザーをプッシュする場合は、100 ユーザーごとにスクリプトを実行できます (スクリプト ロジックは 100 ユーザーをループし、データをシリアルに送信します。コードは省略されています)。複数 (100) のスクリプトを同時に実行できます。時間。
類似:
php task.php 1 100 & php task.php 101 200 & php task.php 201 300 & ........
もちろん、このメソッドはノンブロッキングではありませんが、バッチで操作できるため、処理が大幅に高速化されます。
2. 問題: ノンブロッキングで HTTP プロトコルが必要な場合
次のコードを使用できます
<?php // 创建一对cURL资源 $ch1 = curl_init(); $ch2 = curl_init(); // 设置URL和相应的选项 curl_setopt($ch1, CURLOPT_URL, "http://baidu.com/"); curl_setopt($ch1, CURLOPT_HEADER, 0); curl_setopt($ch2, CURLOPT_URL, "http://baidu.com/"); curl_setopt($ch2, CURLOPT_HEADER, 0); // 创建批处理cURL句柄 $mh = curl_multi_init(); // 增加2个句柄 curl_multi_add_handle($mh,$ch1); curl_multi_add_handle($mh,$ch2); $active = null; // 执行批处理句柄 do { $mrc = curl_multi_exec($mh, $active); } while ($mrc == CURLM_CALL_MULTI_PERFORM); // 轮询Server返回的结果 while ($active && $mrc == CURLM_OK) { if (curl_multi_select($mh) != -1) { do { $mrc = curl_multi_exec($mh, $active); } while ($mrc == CURLM_CALL_MULTI_PERFORM); } } // 汇总结果...... // 关闭全部句柄 curl_multi_remove_handle($mh, $ch1); curl_multi_remove_handle($mh, $ch2); curl_multi_close($mh);
3. ノンブロッキングで HTTP プロトコルではない場合は、次のコードが必要です。 PHPのソケットstream_select
<?php // uid数组,每个uid发送一个链接 $uids = array(1,2,3,4,5,6); // 保存socket的数组 $sockets = array(); // 批量创建链接并发送数据 foreach($uids as $uid) { // tcp://baidu.com 改成你要访问的ip或者域名 if(!$socket = stream_socket_client("tcp://baidu.com:80", $errno, $errstr)) { echo "$errstr\n"; continue; } // 根据自己的协议向服务端写入数据,这里模拟HTTP协议 fwrite($socket, "GET / HTTP/1.1\r\nHost: www.baidu.com\r\n\r\n"); // 设置成非阻塞 stream_set_blocking($socket, 0); // 记录数组 $sockets[(int)$socket] = $socket; } // 批量等待数据返回 while(count($sockets)>0) { $read = $sockets; $write = $e = array(); // 等待数据可读 if(stream_select($read, $write, $e, 10)) { // 循环读数据 foreach($read as $socket) { // 这里是服务端返回的数据,需要的话可以循环读 echo fread($socket, 8192); // 数据读取完毕关闭链接,并删除链接 fclose($socket); unset($sockets[(int)$socket]); } } }
以上がPHP ノンブロッキング バッチ プッシュ データの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。