PHP マルチスレッド_PHP チュートリアル

PHP 5.3 以降では、pthreads PHP 拡張機能を使用して、PHP でマルチスレッドを真にサポートできるようになります。マルチスレッドにより、繰り返しの周期的なタスクを処理する際のプログラムの実行時間を大幅に短縮できます。

前回の記事で、ほとんどの Web サイトのパフォーマンスのボトルネックは PHP サーバーにあるわけではないと言いました。サーバーまたは CPU コアの数を水平方向に増やすだけで簡単に対処できます (さまざまなクラウド ホストの場合、VPS を増やすなど)。コアの数があれば、バックアップ イメージを使用して VPS を直接追加でき、オペレーティング システムや環境をインストールして構成する必要さえありません。) 代わりに、それは MySQL データベース内にあります。 MySQL データベースと結合クエリ SQL を使用する場合は、ビジネス ロジックを処理できる可能性がありますが、大量の同時リクエストが発生すると、作業が停止します。 NoSQL データベースを使用する場合、同じビジネス ロジックを処理するのに 10 個のクエリが必要になる可能性がありますが、各クエリは MySQL よりも高速です。10 ループの NoSQL クエリは、1 秒あたり数万回処理できる MySQL 結合クエリよりも高速である可能性があります。 . クエリはまったく問題ありません。 PHP マルチスレッドを追加し、同時に 10 個のスレッドで NoSQL をクエリし、結果の概要出力を返すと、速度が速くなります。実際の APP 製品では、ユーザーの好みに基づいてリアルタイムで製品を推奨する PHP インターフェイスを呼び出します。PHP は、ユーザーのパーソナライズされた製品データをリアルタイムで計算するために、BigSea NoSQL データベースに対して 500 ～ 1,000 のクエリを開始する必要があります。 PHP のマルチスレッドは非常に明白です。

PHP拡張機能のダウンロード: https://github.com/krakjoe/pthreads
PHPマニュアル文書: http://php.net/manual/zh/book.pthreads.php

1.拡張機能コンパイルしてインストール (Linux)、編集パラメータ --enable-maintainer-zts は必須オプションです:

cd /Data/tgz/php-5.5.1
./configure --prefix=/Data/apps/php --with-config-file-path=/Data/apps/php/etc --with-mysql=/ Data/apps/mysql --with-mysqli=/Data/apps/mysql/bin/mysql_config --with-iconv-dir --with-freetype-dir=/Data/apps/libs --with-jpeg-dir= /Data/apps/libs --with-png-dir=/Data/apps/libs --with-zlib --with-libxml-dir=/usr --enable-xml --disable-rpath --enable-bcmath --enable-shmop --enable-sysvsem --enable-inline-optimization --with-curl --enable-mbregex --enable-fpm --enable-mbstring --with-mcrypt=/Data/apps/libs - -with-gd --enable-gd-native-ttf --with-openssl --with-mhash --enable-pcntl --enable-sockets --with-xmlrpc --enable-zip --enable-soap -- Enable-opcache --with-pdo-mysql --enable-maintainer-zts
make clean
make
make install

unzip pthreads-master.zip
cd pthreads-master
/Data/apps/php/bin/phpize
./configure --with-php-config=/Data/apps/php/bin/php-config
make
make install

vi /Data/apps/php/etc/php.ini

追加:

拡張子 = "pthreads.so"

2. PHP マルチスレッドと For ループを与えて、Baidu 検索ページの PHP コード例をキャプチャします:

 

2. class test_thread_run extends スレッド
3. {
4. 公開 $url;  
5. 公開 $data;  
7. public function __construct($url)
8. {
9. $this->url = $url;  
10. }
12. public function run()
13. {
14. if(($url = $this->url))
15. {
16. $this->data = model_http_curl_get($url);  
17. }
18. }
19. }
21. 関数 model_thread_result_get($urls_array)
22. {
23. foreach ($urls_array as $key => $value)
24. {
25. $thread_array[$key] = new test_thread_run($value["url"]);  
26. $thread_array[$key]->start();  
27. }
29. foreach ($thread_array as $thread_array_key => $thread_array_value)
30. {
31. while($thread_array[$thread_array_key]->isRunning())
32. {
33. usleep(10);  
34. }  
35. if($thread_array[$thread_array_key]->join())
36. {
37. $variable_data[$thread_array_key] = $thread_array[$thread_array_key]->データ;  
38. }
39. }
40. return $variable_data;  
41. }
43. function model_http_curl_get($url,$userAgent="")
44. {
45. $userAgent = $userAgent ? $userAgent: 'Mozilla/4.0 (互換性; MSIE 7.0; Windows NT 5.2)';   
46. $curl = curl_init();  
47. curl_setopt($curl, CURLOPT_URL, $url);  
48. curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);  
49. curl_setopt($curl, CURLOPT_TIMEOUT, 5);  
50. curl_setopt($curl, CURLOPT_USERAGENT, $userAgent);  
51. $result = curl_exec($curl);  
52. curl_close($curl);  
53. return $result;  
54. }
56. for ($i=0; $i $i++)
57. {
58. $urls_array[] = array("name" => "baidu", "url" => "http://www.baidu.com/s?wd =".mt_rand(10000,20000));  
59. }  
61. $t = マイクロタイム(true);  
62. $result = model_thread_result_get($urls_array);  
63. $e = マイクロタイム(true);  
64. echo "多線程：".($e-$t)."n";  
66. $t = マイクロタイム(true);  
67. foreach ($urls_array as $key => $value)
68. {
69. $result_new[$key] = model_http_curl_get($value["url"]);  
70. }
71. $e = マイクロタイム(true);  
72. echo "Forcycle:".($e-$t)."n";  
73. ?>  

http://www.bkjia.com/PHPjc/626581.htmlwww.bkjia.comtru​​ehttp://www.bkjia.com/PHPjc/626581.html技術記事 PHP 5.3 以上のバージョンでは、pthreads PHP 拡張を使用して、PHP でマルチ プロセスを真にサポートすることができます。