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

ほとんどの Web サイトのパフォーマンスのボトルネックは PHP サーバーにありません。サーバーまたは CPU コアの数を水平方向に増やすだけで簡単に対処できます (さまざまなクラウド ホストの場合、VPS または CPU コアの数を増やす方が便利です)。 、バックアップ イメージ 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

PHPマルチスレッドの実装

拡張コンパイルとインストール (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 --イネーブルメンテナ-zts
きれいにする
作る
インストールを行う

pthreads-master.zip を解凍します
cd pthreads-master
/Data/apps/php/bin/phpize
./configure --with-php-config=/Data/apps/php/bin/php-config
作る
インストールする

vi /Data/apps/php/etc/php.ini
追加:
拡張子 = "pthreads.so"

PHP マルチスレッドと For ループを考慮した、Baidu 検索ページを取得するための PHP コード例

​

2. クラス test_thread_run はスレッドを拡張します
3. {
4. public $url;
public $data;
6. パブリック関数 __construct($url)
7.                                                              
$this->url = $url;
8. }
10. パブリック関数 run()
11.                                                              
If(($url = $this->url))
                                                           
13. $this->data = model_http_curl_get($url);
}
}
}
関数model_thread_result_get($urls_array)
{
foreach ($urls_array as $key => $value)
                                                             
21. $thread_array[$key] = 新しい test_thread_run($value["url"]);
$thread_array[$key]->start();
22. }
24. foreach ($thread_array as $thread_array_key => $thread_array_value)
25.                                                              
while($thread_array[$thread_array_key]->isRunning())
                                                           
27. usleep(10);
}
If($thread_array[$thread_array_key]->join())
                                                           
30. $variable_data[$thread_array_key] = $thread_array[$thread_array_key]->データ;
}
}
戻ってくる
33. }  
34.   
35.   function model_http_curl_get($url,$userAgent="")
36.   {
37.       $userAgent = $userAgent ? $userAgent : 'Mozilla/4.0 (互換性; MSIE 7.0; Windows NT 5.2)';   
38.       $curl = curl_init();  
39.       curl_setopt($curl, CURLOPT_URL, $url);  
40.       curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);  
41.       curl_setopt($curl, CURLOPT_TIMEOUT, 5);  
42.       curl_setopt($curl, CURLOPT_USERAGENT, $userAgent);  
43.       $result = curl_exec($curl);  
44.       curl_close($curl);  
45.       $result を返します。  
46.   }
47.   
48.   for ($i=0; $i
49.   {
50.       $urls_array[] = array("name" => "baidu", "url" => "http://www.baidu.com/s?wd=".mt_rand(10000,20000));  
51.   }
52.   
53.   $t = マイクロタイム(true);  
54.   $result = model_thread_result_get($urls_array);  
55.   $e = マイクロタイム(true);  
56.   echo "多線程：".($e-$t)."n";  
57.   
58.   $t = マイクロタイム(true);  
59.   foreach ($urls_array as $key => $value)
60.   {
61.       $result_new[$key] = model_http_curl_get($value["url"]);  
62.   }
63.   $e = マイクロタイム(true);  
64.   echo "循環の場合：".($e-$t)."n";  
65. ?>  

翻訳：http://blog.s135.com/pthreads/ 张宴

)