検索

ホームページ  >  記事  >  バックエンド開発  >  (疑似) PHP_PHP のマルチスレッドとマルチプロセッシングのチュートリアル

(疑似) PHP_PHP のマルチスレッドとマルチプロセッシングのチュートリアル

WBOY
WBOYオリジナル
2016-07-20 11:14:241050ブラウズ

(擬似)マルチスレッド:外力の助けを借りて

WEBサーバー自体のマルチスレッドを利用して処理を行う WEBサーバーからマルチスレッドプログラムを複数回実装する必要があります。

引用:

PHP 自体はマルチスレッドをサポートしていないことはわかっていますが、WEB サーバーはマルチスレッドをサポートしています。

つまり、複数の人が同時にアクセスできるということは、私が PHP でマルチスレッドを実装するための基礎でもあります。

今ファイル a.php を実行しているとしますが、プログラム内で別の b.php を実行するように WEB サーバーにリクエストします。

その後、これら 2 つのファイルが同時に実行されます。

(追記: リンクリクエストが送信されると、クライアントが終了したかどうかに関係なく、WEBサーバーはリンクリクエストを実行します)

実行したいのは別のファイルではなく、このファイル内のコードの一部である場合があります。どうすればよいでしょうか?

実際、パラメータを通じて a.php が実行するプログラムを制御できます。

以下の例を見てください:

[php] プレーンコピーを表示

  2. 関数 runThread(){
  3. $fp = fsockopen('localhost', 80, $errno, $errmsg );
  4. fputs($fp, "GET /a.php?act=brnrn");//ここでの 2 番目のパラメーターは、HTTP プロトコルで指定されたリクエスト ヘッダーです。理解できない場合は、RFC の定義を参照してください。​​​​​​​​ fclose($fp
    5. );
  5. } 関数
  6. a(){
  7. $fp = fopen
  8. ('result_a.log', 'w'); fputs($fp,
    9. ' で設定します
  9. . Date('h:i:s', time( )) . )マイクロタイム() ."rn"); fclose($fp); } 関数
    10. b(){
  10. $fp
    11. =
  11. fopen
    12. (
  12. 'result_b.log', 'w'
    13. );
  13. fputs($fp, ' で設定します . Date('h:i:s'
  14. , time( )) . )マイクロタイム() ."rn"); fclose($fp); } if(!isset($_GET['act'])){
  15. $_GET['act'] =
  16. ' ;};
  17. if($_GET['act'] == 'a'){ runThread();
  18. ; }
    19. else
  19. if($_GET['act'] == 'b'){
  20. b();
  21. }; ?>
  22. result_a.log と result_b.log を開いて、2 つのファイルのアクセス時間を比較すると、これら 2 つが実際に異なるスレッドで実行されていることがわかります。 まったく同じ時間もあります。 上記は単なる例であり、他の形式に改良することができます。 PHP でマルチスレッドが使用できるようになったので、問題が発生します。それは、PHP 自体がマルチスレッドをサポートしていないことです。したがって、 のようなものはありません。

    Java の同期メソッドでは、どうすればよいでしょうか。

    1. 競合を避けるために同じリソースにアクセスしないようにしてください。ただし、データベースは同時操作をサポートしているため、マルチスレッド PHP では同時に操作することができます。

    同じファイルにデータを書き込まないでください。書き込む必要がある場合は、flock を呼び出してファイルをロックするなど、他の方法を使用するか、一時ファイルを作成してください。

    そして別のスレッドでこのファイルが消えるのを待ちます while(file_exits('xxx')); これは、この一時ファイルが存在するということは、スレッドが実際に動作していることを意味します

    このファイルがもう存在しない場合は、他のスレッドがそのファイルを解放したことを意味します。

    2. fputs の実行後に runThread が取得するソケットからデータを読み取らないようにします。これは、fgets と同様に、ノンブロッキング モードを使用する必要があるためです。

    そのような関数はすぐに戻ります。そのため、ブロックモードが使用されている場合、プログラムは実行する前に上記の戻りを待つ必要があります

    。

    データを交換する必要がある場合は、最終的に外部ファイルまたはデータを使用してそれを実現します。

    ここまで述べましたが、これには実際的な意味があるのでしょうか?

    この方法を使用する必要があるのはどのような場合ですか?

    答えは「はい」です。ご存知のとおり、ネットワーク リソースを常に読み取るアプリケーションでは、ネットワークの速度がボトルネックになります。この形式を採用すると、複数のスレッドを同時に使用できます。

    別のページを読んでください。

    8848やsoasoなどのショッピングモールサイトから情報を検索できるプログラムを作りました。アリババのウェブサイトからビジネス情報や企業ディレクトリを読み取るプログラムもあります

    このテクノロジー。 どちらのプログラムも、情報を読み取ってデータベースに保存するためにサーバーに継続的に接続する必要があるためです。 このテクニックを利用すると、応答を待っている間にボトルを削除するだけです

    首。

    マルチプロセス: PHPのプロセス制御関数(PCNTL/スレッド制御関数)を使用します

    関数のリファレンスは http://www.php.net/manual/zh/ref.pcntl.php

    にあります。 Unix Like OS でのみ使用でき、Windows では使用できません。

    php をコンパイルするときは、--enable-pcntl を追加する必要があります。これは、WEB サーバー環境ではなく、CLI モードでのみ実行することをお勧めします。

    以下は短いテストコードです:
    [php] プレーンコピーを表示

    1. 宣言(ティック=1);
      2. $bWaitFlag
    2. = FALSE; /// プロセスの終了を待つかどうか
      3. $intNum
    3. = 10; /// プロセスの総数
      4. $pids
    4. = array(); エコー (「スタート」);
    5. for($i = 0; $i
      6. <
    6. $intNum; $i++) { $pids[$i] = pcntl_fork();/// 子プロセスを生成し、現在の行からテスト実行コードを開始します。子プロセスのデータ情報は継承しません。親プロセス
    7. if(!$pids[$i]) {
    8. //サブプロセスプロセスコードsegment_Start $str=
    9. "";
      10. 睡眠(5+
    10. $i); ($j=0;$j
    11. <$i;$j
    12. ++) { $str .= "*" ;} echo "$i -> " . time() . " $str n"; 終了();
    13. //サブプロセスプロセスコードsegment_End } }
    14. if ($bWaitFlag)
    15. {
    16. for(
    17. $i = 0;
    18. $i pcntl_waitpid($pids[
    19. $i],
    20. $status, WUNTRACED ); と } } エコー (「終わります」
    21. ); 実行結果は以下の通りです:

      コード:[クリップボードにコピー][qiao@oicq qiao]$ phptest.php
      スタート
      終了
      [qiao@oicq qiao]$ ps -aux | grep "php"
      喬 32275 0.0 0.5 49668 6148pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32276 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32277 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32278 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32279 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32280 0.0 0.5 49668 6152pts/1 S 14:03 0:00 /usr/local/php4/b
      喬 32281 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32282 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32283 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      喬 32284 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b
      qiao 32286 0.0 0.0 1620 600pts/1 S 14:03 0:00 grep php
      [qiao@oicq qiao]$ 0 -> 1133503401
      1 -> 1133503402 *
      2 -> 1133503403 **
      3 -> 1133503404 ***
      4 -> 1133503405 ****
      5 -> 1133503406 *****
      6 -> 1133503407 ******
      7 -> 1133503408 *******
      8 -> 1133503409 ********
      9 -> 1133503410 *********

      [qiao@oicq qiao]$
      結果$bWaitFlag=TURE、結果は以下の通り：

      コード:[クリップボードにコピー][qiao@oicq qiao]$ phptest.php
      スタート
      0 -> 1133503602
      0 待つ -> 1133503602
      1 -> 1133503603 *
      待つ 1 -> 1133503603
      2 -> 1133503604 **
      2 待ってください -> 1133503604
      3 -> 1133503605 ***
      3 待つ -> 1133503605
      4 -> 1133503606 ****
      4 待つ -> 1133503606
      5 -> 1133503607 *****
      5 待つ -> 1133503607
      6 -> 1133503608 ******
      6 待つ -> 1133503608
      7 -> 1133503609 *******
      7 待つ -> 1133503609
      8 -> 1133503610 ********
      8 待つ -> 1133503610
      9 -> 1133503611 *********
      9 待つ -> 1133503611
      終了
      [qiao@oicq qiao]$
      从 多くのプロセスの例を見ると、pcntl_fork() の使用後に子プロセスが生成され、その子プロセスが実行される代コードが pcntl_fork() の後の代コードから始まります。 プロセスは父プロセスのデータ情報を継承しないため (実際には、父プロセスのデータは完全に新しい記録を作成します)、そのため、 if(!$pids[$i]) を使用して子プロセスの実行のコード セグメントを制御します。

      時間的な関係でのより詳細な研究はまだ行われていないため、私が提示した手の接続を参照してください。

      [文章二] 尝试phpコマンド行脚本多进程并発行実行


      作者：デュラオ5

      来源：http://dulao5.blog.hexun.com/3726837_d.html


      除了フォーク、cli下の公開方式にも一種類、見られる例:

      php はマルチプロセスをサポートしていませんが、この問題を解決するために「マルチプロセス」に変更することができます。php 内の pcntl_fork は unix プラットフォームでのみ使用できるため、ここでは代わりに popen を使用します。


      以下は例です:

      被管理用子プログラム代コード：
      [php] プレーンコピーを表示

      2. if($argc==1){
      3. echo("argvn");  
      4. }
      5. $arg = $argv[1];  
      6. for($i=0; $i<10; $i++)
      7. {
      8. echo($i.".1.".time()." exec $arg n");  
      9. if($arg=='php2'){
      10. 睡眠(1);  
      11. echo($i.".2.".time()." exec $arg n");  
      12. 睡眠(1);  
      13. }else{
      14. 睡眠(1);  
      15. }
      16. }
      17. ?>  

      主调用子程序、他调用子程程、同時に発行された収集子程序の出力

      [php] プレーンコピーを表示
      1. エラー報告(E_ALL);  
      3. $handle1 = popen('php sub.php php1', 'r');  
      4. $handle2 = popen('php sub.php php2', 'r');  
      5. $handle3 = popen('php sub.php php3', 'r');  
      7. echo "'$handle1'; " 。 gettype($handle1) 。 「ん」;  
      8. echo "'$handle2'; " 。 gettype($handle2) 。 「ん」;  
      9. echo "'$handle3'; " 。 gettype($handle3) 。 「ん」;  
      10. //睡眠(20);
      11. ながら(!feof($handle1) || !feof($handle2) || ! feof($ハンドル3 ) )
      12. {
      13. $read = fgets($handle1);  
      14. エコー $read;  
      15. $read = fgets($handle2);  
      16. エコー $read;  
      17. $read = fgets($handle3);  
      18. エコー $read;  
      19. }
      20. pclose($handle1);  
      21. pclose($handle2);  
      22. pclose($handle3);  

      次は我机上の出力：

      C:my_hunter>php exec.php
      'リソースID #4';リソース
      'リソースID #5';リソース
      'リソースID #6';リソース
      0.1.1147935331 php1 を実行
      0.1.1147935331 php2 を実行
      0.1.1147935331 php3 を実行
      1.1.1147935332 php1 を実行
      0.2.1147935332 php2 を実行
      1.1.1147935332 php3 を実行
      2.1.1147935333 php1 を実行
      1.1.1147935333 php2 を実行
      2.1.1147935333 php3 を実行
      3.1.1147935334 php1 を実行
      1.2.1147935334 php2 を実行します
      3.1.1147935334 php3 を実行
      4.1.1147935335 php1 を実行
      2.1.1147935335 php2 を実行
      4.1.1147935335 php3 を実行
      5.1.1147935336 php1 を実行
      2.2.1147935336 php2 を実行
      5.1.1147935336 php3 を実行
      6.1.1147935337 php1 を実行
      3.1.1147935337 php2 を実行
      6.1.1147935337 php3 を実行
      7.1.1147935338 php1 を実行
      3.2.1147935338 php2 を実行
      7.1.1147935338 php3 を実行
      8.1.1147935339 php1 を実行します
      4.1.1147935339 php2 を実行します
      8.1.1147935339 php3 を実行
      9.1.1147935340 php1 を実行
      4.2.1147935340 php2 を実行
      9.1.1147935340 php3 を実行
      5.1.1147935341 php2 を実行します
      5.2.1147935342 php2 を実行
      6.1.1147935343 php2 を実行します
      6.2.1147935344 php2 を実行します
      7.1.1147935345 php2 を実行します
      7.2.1147935346 php2 を実行
      8.1.1147935347 php2 を実行します
      8.2.1147935348 php2 を実行します
      9.1.1147935349 php2 を実行します
      9.2.1147935350 php2 を実行

      **总结：**

      ** メインプログラム循環等の子プロセスを待機し、fgets または fread によって子プロセスの出力が取得され、時間的に確認されて実行されます。**

      ------------------------------------------------------------
      その後の変更点：

      * Popen を開くハンドルは一方向であり、子プロセスのやり取りが必要な場合は、proc_open
      を使用できます。 * 数組和子関数数を使用する代わりに(!feof($handle1)|| !feof($handle2) || !feof($handle3) ) この写法
      * fread を使用すると、1 行ごとではなく、子プロセスによって生成された出力が完了します。

      実行シェルジョブの管理者、本プログラムはタスクファイルを取得し、ここの実行コマンドを取得して実行を実行し、同時に存在する子プロセスの数を設定できます:

      [php] プレーンコピーを表示

      1. /*
      2. メインタスクマネージャー
      3. 同時実行サブタスクリスト
      4. */
      5. include("../common/conf.php");
        6. include
      6. ("../common/function.php"); //開いているプロセスの数
      7. $exec_number
        8. = 40 ;
      8. /***** 主要 ********/
      9. if($argc
      10. ==1){ エコー("argvn"
      11. ); }
      12. $タスクファイル = $argv[1];
        13. //タスクリスト
        14. $タスクリスト
      14. = ファイル($タスクファイル); $tasklist_len =
      15. count($tasklist); $tasklist_pos = 0; $handle_list
      16. = array();
        17. ながら
      17. (1) {
        18. //子プロセスリストが空いている場合は、子プロセスリストに記入します
      20. for($i
        21. =
      21. $tasklist_pos$i<$tasklist_len; ;) M om $コマンド =
      22. $タスクリスト [ $ i]; $ handle_list [] = Popen ( $ commit
      23. , "r"
      24. ); tolog("begin task t ".$tasklist[$i]); ️
      25. ～ }
      26. //子プロセスリストが空の場合は終了します if(0 ==
        27. count
      27. ($handle_list)) ️ 。 }
      28. //子プロセスリストの出力を確認し、停止した子プロセスを閉じて記録します
      29. $end_handle_keys = array();
      30. // $ str 」 ️ pclose($handle); }
        31. //停止した子プロセスをキックアウトします
      32. foreach(
        33. $end_handle_keys
      33. as $key) (設定解除 (n $ hand_list [
        34. $ key
      34. ]); //var_dump($handle_list); //exit;
      35. } } tolog(「ん*************************終わり****************** ******nn "
      36. 、""
      37. 、本当); Socket マルチプロセス受信用のコードを添付します: [php] プレーンコピーを表示
        1. する {
        2. if (($msgsock = socket_accept($sock)) < 0) {
        3. echo "socket_accept() 失敗しました: 理由: " 。 socket_strerror($msgsock) 。 「ん」;  
        4. 休憩;  
        5. }
        6. $pid = pcntl_fork();  
        7. if ($pid == -1) {
        8. 死ぬ(「フォークできませんでした」);  
        9. } else if (!$pid) {
        10. ....
        11. socket_write($msgsock, $msg, strlen($msg));  
        12. do {
        13. ......
        14. } ながら （本当）;  
        15. socket_close($msgsock);  
        16. }
        17. } ながら (本当);  


        翻訳地址：http://www.alixixi.com/program/a/2008050731686.shtml

        www.bkjia.comtru​​ehttp://www.bkjia.com/PHPjc/440281.html技術記事 (専) 多回線: WEB サーバー自体の多回線を外部の力を借りて処理し、WEB サーバーから多回線を実現するために必要なプログラムを何度も使用します。
声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：PHP 面接の質問 1 [リダイレクト]_PHP チュートリアル次の記事：PHP 面接の質問 1 [リダイレクト]_PHP チュートリアル

関連記事

続きを見る