PHP - ユーザ登録時のバックサイト処理のためのcronが必要です...（またはフォークプロセス）

Question

新しいユーザーが自分のサイトにサインアップするときはいつでも、後で検索を短縮するためにいくつかの前処理を行いたいと思います。これには、30分から2分の処理時間が必要です。明らかに、サインアップ時に送信ボタンをクリックしたとき、または訪問したPHPページでこれを行うことはできません。しかし、私は5分以内にサインアップする（またはそれ以下）ことを願っています。

クロンルート 私は、これはcronジョブであることが必要であると思うし、もしそうなら、どのように私はセットアップcronジョブをすべきか？もしそうなら、私のcronラインは2分おきに走るように見えますが、私は同じcronジョブが次のものと重なっていないことをどのように保証できますか？

イベント/フォークルート - 優先 私はおそらく私のユーザー体験を中断することなく、自分のサーバーにいくつかのイベントを投げたり（代わりにcronジョブの）ユーザーのサインアップのオフプロセスをフォークすることができた場合はどのように私はこれを行うことができますか？

Answer 1

どちらの解決法も推奨しません。

代わりに、message queueからジョブを取得する長時間実行しているプロセス（デーモン）を使用することをお勧めします。それが望ましい方法であれば、メッセージキュー自体がデータベースから外れる可能性があります。

ジョブの識別子をデータベースにポストし、長時間実行されているプロセスはそれらをしばらくのうちに繰り返し実行し、それらのプロセスを実行します。

これは同じくらい簡単です：

<?php 
while(true) { 
    jobs = getListOfJobsFromDatabase(); // get the jobs from the databbase 
    foreach (jobs as job) { 
     processAJob(job); // do whatever needs to be done for the job 
     deleteJobFromDatabase(job); //remember to delete the job once its done! 
    } 
    sleep(60); // sleep for a while so it doesnt thrash your database when theres nothing to do 
} 
?> 

そして、ちょうどコマンドラインからそのスクリプトを実行します。

これ以上のクーロンジョブの利点は、競合状態に陥ることがないことです。

ジョブの実際の処理をフォークオフして、順番に処理するのではなく、並列処理できるようにすることもできます。

Answer 2

これは私の考えです。すべてのユーザーのために1つのcronを用意してください。この方法で、キューのように動作するテーブルにそれらを置くことによって、重複がないことを保証することができます。 1時間ごとにcronを実行しますが、キューが空でない場合は最初にキューをチェックしてください。それが時間のためのcronの仕事を飛ばしていないなら次をもう一度試みてください。

Answer 3

次のクラスを使用して、背景のPHPタスクを呼び出すことができます。

class BackgroundProcess { 
    static function open($exec, $cwd = null) { 
     if (!is_string($cwd)) { 
      $cwd = @getcwd(); 
     } 

     @chdir($cwd); 

     if (strtoupper(substr(PHP_OS, 0, 3)) == 'WIN') { 
      $WshShell = new COM("WScript.Shell"); 
      $WshShell->CurrentDirectory = str_replace('/', '\\', $cwd); 
      $WshShell->Run($exec, 0, false); 
     } else { 
      exec($exec . " > /dev/null 2>&1 &"); 
     } 
    } 

    static function fork($phpScript, $phpExec = null) { 
     $cwd = dirname($phpScript); 

     if (!is_string($phpExec) || !file_exists($phpExec)) { 
      if (strtoupper(substr(PHP_OS, 0, 3)) == 'WIN') { 
       $phpExec = str_replace('/', '\\', dirname(ini_get('extension_dir'))) . '\php.exe'; 

       if (@file_exists($phpExec)) { 
        BackgroundProcess::open(escapeshellarg($phpExec) . " " . escapeshellarg($phpScript), $cwd); 
       } 
      } else { 
       $phpExec = exec("which php-cli"); 

       if ($phpExec[0] != '/') { 
        $phpExec = exec("which php"); 
       } 

       if ($phpExec[0] == '/') { 
        BackgroundProcess::open(escapeshellarg($phpExec) . " " . escapeshellarg($phpScript), $cwd); 
       } 
      } 
     } else { 
      if (strtoupper(substr(PHP_OS, 0, 3)) == 'WIN') { 
       $phpExec = str_replace('/', '\\', $phpExec); 
      } 

      BackgroundProcess::open(escapeshellarg($phpExec) . " " . escapeshellarg($phpScript), $cwd); 
     } 
    } 
} 

のような使用：

BackgroundProcess::fork('process_user.php');