この記事で共有する內(nèi)容は PHP デーモンに関するものです。必要な方は參考にしてください。デーモンはバックグラウンドで実行される特別なプロセスです。制御端末から獨(dú)立しており、定期的に何らかのタスクを?qū)g行するか、何らかのイベントが発生するのを待ちます。デーモンは非常に便利なプロセスです。 PHPではデーモンプロセスの機(jī)能も実裝できます。

1. 基本概念

プロセス

すべてのプロセスには親プロセスがあり、子プロセスが終了すると、親プロセスは子プロセスの終了ステータスを取得できます。

プロセスグループ

各プロセスはプロセスグループに屬し、各プロセスグループにはプロセスグループリーダーのPIDに等しいプロセスグループ番號(hào)があります

2. デーモンプログラミングのポイント

1. バックグラウンドで実行します。
制御端末のハングを回避するには、Daemon をバックグラウンドで実行します。方法としては、プロセス內(nèi)で fork を呼び出して親プロセスを終了し、子プロセスのバックグラウンドでデーモンを?qū)g行させる方法です。 if($pid=pcntl_fork()) exit(0);//親プロセスです、親プロセスを終了し、子プロセスは続行します
2. 制御端末を離れ、セッションとプロセスグループにログインします
それLinux では、最初にプロセスとプロセスを?qū)毪工氡匾ⅳ辘蓼埂?制御端末、ログインセッション、プロセスグループの関係: プロセスはプロセスグループに屬し、プロセスグループ番號(hào) (GID) はプロセスのプロセス番號(hào) (PID) です。グループリーダー。ログイン セッションには複數(shù)のプロセス グループを含めることができます。これらのプロセス グループは制御端末を共有します。この制御端末は通常、プロセスが作成されたログイン端末です。 制御端末、ログイン セッション、プロセス グループは通常、親プロセスから継承されます。私たちの目的は、それらを排除し、それらの影響を受けないようにすることです。この方法では、setsid () を呼び出してプロセス リーダーを作成します。 POSIX_SETSID ();
説明: プロセスがセッション チーム リーダーの場(chǎng)合、setsid () 呼び出しは失敗します。ただし、最初のポイントにより、プロセスがセッション リーダーではないことがすでに保証されています。 etsid() 呼び出しが成功すると、プロセスは新しいセッション グループ リーダーおよび新しいプロセス グループ リーダーになり、元のログイン セッションおよびプロセス グループから分離されます。セッションプロセスは制御端末への排他性があるため、同時(shí)にプロセスは制御端末から切り離されます。
3. プロセスが制御端末を再度開(kāi)くことを無(wú)効にします
これで、プロセスは端末のないセッション リーダーになりました。ただし、制御端末を開(kāi)くために再適用することはできます。プロセスをセッション リーダーでなくすることで、プロセスがコントロール ターミナルを再度開(kāi)くのを防ぐことができます: if($pid=pcntl_fork()) exit(0);//最初の子プロセスを終了し、2 番目の子プロセスが続行します ( 2 番目の子プロセスはセッション リーダーではなくなります)
4. 開(kāi)いているファイル記述子を閉じます
プロセスは、開(kāi)いているファイル記述子を、それを作成した親プロセスから継承します。閉じていない場(chǎng)合、システム リソースが無(wú)駄になり、プロセスが存在するファイル システムをアンマウントできなくなり、予期しないエラーが発生します。次のように閉じます:
fclose (STDIN)、fclose (STDOUT)、fclose (STDERR) は、標(biāo)準(zhǔn)入出力とエラー表示を閉じることができます。
5. 現(xiàn)在の作業(yè)ディレクトリの変更
プロセスがアクティブな場(chǎng)合、作業(yè)ディレクトリが配置されているファイルシステムは削除できません。通常、作業(yè)ディレクトリをルート ディレクトリに変更する必要があります。コアをダンプして実行ログを書(shū)き込む必要があるプロセスの場(chǎng)合、作業(yè)ディレクトリを chdir("/") などの特定のディレクトリに変更します
6. ファイル作成マスクをリセットします
プロセスは親からファイル作成マスクを継承しますそれを作成したプロセス。デーモンによって作成されたファイルのアクセス ビットを変更する可能性があります。これを防ぐには、ファイル作成マスクをクリアします: umask(0);
7. SIGCHLD シグナルの処理
SIGCHLD シグナルの処理は必要ありません。ただし、一部のプロセス、特にサーバー プロセスでは、リクエストが到著したときにリクエストを処理するために子プロセスが生成されることがよくあります。親プロセスが子プロセスの終了を待たないと、子プロセスはゾンビプロセス（ゾンビ）となり、システムリソースを占有します。親プロセスが子プロセスの終了を待機(jī)すると、親プロセスの負(fù)擔(dān)が増加し、サーバー プロセスの同時(shí)実行パフォーマンスに影響します。 Linux では、SIGCHLD 信號(hào)の動(dòng)作を SIG_IGN に設(shè)定するだけで済みます。 signal(SIGCHLD,SIG_IGN);
こうすることで、カーネルは子プロセスの終了時(shí)にゾンビプロセスを生成しなくなります。これは BSD4 とは異なります。BSD4 では、ゾンビ プロセスを解放する前に、子プロセスが終了するのを明示的に待つ必要があります。シグナルに関する質(zhì)問(wèn)については、Linux を參照してください。 シグナルの説明の一覧

1. <?php  
   /** 
   *@author tengzhaorong@gmail.com 
   *@date 2013-07-25 
   * 后臺(tái)腳本控制類(lèi) 
   */  
   class DaemonCommand{  
      
       private $info_dir="/tmp";  
       private $pid_file="";  
       private $terminate=false; //是否中斷  
       private $workers_count=0;  
       private $gc_enabled=null;  
       private $workers_max=8; //最多運(yùn)行8個(gè)進(jìn)程  
      
       public function __construct($is_sington=false,$user=&#39;nobody&#39;,$output="/dev/null"){  
      
               $this->is_sington=$is_sington; //是否單例運(yùn)行，單例運(yùn)行會(huì)在tmp目錄下建立一個(gè)唯一的PID  
               $this->user=$user;//設(shè)置運(yùn)行的用戶(hù) 默認(rèn)情況下nobody  
               $this->output=$output; //設(shè)置輸出的地方  
               $this->checkPcntl();  
       }  
       //檢查環(huán)境是否支持pcntl支持  
       public function checkPcntl(){  
           if ( ! function_exists(&#39;pcntl_signal_dispatch&#39;)) {  
               // PHP < 5.3 uses ticks to handle signals instead of pcntl_signal_dispatch  
               // call sighandler only every 10 ticks  
               declare(ticks = 10);  
           }  
      
           // Make sure PHP has support for pcntl  
           if ( ! function_exists(&#39;pcntl_signal&#39;)) {  
               $message = &#39;PHP does not appear to be compiled with the PCNTL extension.  This is neccesary for daemonization&#39;;  
               $this->_log($message);  
               throw new Exception($message);  
           }  
           //信號(hào)處理  
           pcntl_signal(SIGTERM, array(__CLASS__, "signalHandler"),false);  
           pcntl_signal(SIGINT, array(__CLASS__, "signalHandler"),false);  
           pcntl_signal(SIGQUIT, array(__CLASS__, "signalHandler"),false);  
      
           // Enable PHP 5.3 garbage collection  
           if (function_exists(&#39;gc_enable&#39;))  
           {  
               gc_enable();  
               $this->gc_enabled = gc_enabled();  
           }  
       }  
      
       // daemon化程序  
       public function daemonize(){  
      
           global $stdin, $stdout, $stderr;  
           global $argv;  
      
           set_time_limit(0);  
      
           // 只允許在cli下面運(yùn)行  
           if (php_sapi_name() != "cli"){  
               die("only run in command line mode\n");  
           }  
      
           // 只能單例運(yùn)行  
           if ($this->is_sington==true){  
      
               $this->pid_file = $this->info_dir . "/" .__CLASS__ . "_" . substr(basename($argv[0]), 0, -4) . ".pid";  
               $this->checkPidfile();  
           }  
      
           umask(0); //把文件掩碼清0  
      
           if (pcntl_fork() != 0){ //是父進(jìn)程，父進(jìn)程退出  
               exit();  
           }  
      
           posix_setsid();//設(shè)置新會(huì)話(huà)組長(zhǎng)，脫離終端  
      
           if (pcntl_fork() != 0){ //是第一子進(jìn)程，結(jié)束第一子進(jìn)程     
               exit();  
           }  
      
           chdir("/"); //改變工作目錄  
      
           $this->setUser($this->user) or die("cannot change owner");  
      
           //關(guān)閉打開(kāi)的文件描述符  
           fclose(STDIN);  
           fclose(STDOUT);  
           fclose(STDERR);  
      
           $stdin  = fopen($this->output, &#39;r&#39;);  
           $stdout = fopen($this->output, &#39;a&#39;);  
           $stderr = fopen($this->output, &#39;a&#39;);  
      
           if ($this->is_sington==true){  
               $this->createPidfile();  
           }  
      
       }  
       //--檢測(cè)pid是否已經(jīng)存在  
       public function checkPidfile(){  
      
           if (!file_exists($this->pid_file)){  
               return true;  
           }  
           $pid = file_get_contents($this->pid_file);  
           $pid = intval($pid);  
           if ($pid > 0 && posix_kill($pid, 0)){  
               $this->_log("the daemon process is already started");  
           }  
           else {  
               $this->_log("the daemon proces end abnormally, please check pidfile " . $this->pid_file);  
           }  
           exit(1);  
      
       }  
       //----創(chuàng)建pid  
       public function createPidfile(){  
      
           if (!is_dir($this->info_dir)){  
               mkdir($this->info_dir);  
           }  
           $fp = fopen($this->pid_file, &#39;w&#39;) or die("cannot create pid file");  
           fwrite($fp, posix_getpid());  
           fclose($fp);  
           $this->_log("create pid file " . $this->pid_file);  
       }  
      
       //設(shè)置運(yùn)行的用戶(hù)  
       public function setUser($name){  
      
           $result = false;  
           if (empty($name)){  
               return true;  
           }  
           $user = posix_getpwnam($name);  
           if ($user) {  
               $uid = $user[&#39;uid&#39;];  
               $gid = $user[&#39;gid&#39;];  
               $result = posix_setuid($uid);  
               posix_setgid($gid);  
           }  
           return $result;  
      
       }  
       //信號(hào)處理函數(shù)  
       public function signalHandler($signo){  
      
           switch($signo){  
      
               //用戶(hù)自定義信號(hào)  
               case SIGUSR1: //busy  
               if ($this->workers_count < $this->workers_max){  
                   $pid = pcntl_fork();  
                   if ($pid > 0){  
                       $this->workers_count ++;  
                   }  
               }  
               break;  
               //子進(jìn)程結(jié)束信號(hào)  
               case SIGCHLD:  
                   while(($pid=pcntl_waitpid(-1, $status, WNOHANG)) > 0){  
                       $this->workers_count --;  
                   }  
               break;  
               //中斷進(jìn)程  
               case SIGTERM:  
               case SIGHUP:  
               case SIGQUIT:  
      
                   $this->terminate = true;  
               break;  
               default:  
               return false;  
           }  
      
       }  
       /** 
       *開(kāi)始開(kāi)啟進(jìn)程 
       *$count 準(zhǔn)備開(kāi)啟的進(jìn)程數(shù) 
       */  
       public function start($count=1){  
      
           $this->_log("daemon process is running now");  
           pcntl_signal(SIGCHLD, array(__CLASS__, "signalHandler"),false); // if worker die, minus children num  
           while (true) {  
               if (function_exists(&#39;pcntl_signal_dispatch&#39;)){  
      
                   pcntl_signal_dispatch();  
               }  
      
               if ($this->terminate){  
                   break;  
               }  
               $pid=-1;  
               if($this->workers_count<$count){  
      
                   $pid=pcntl_fork();  
               }  
      
               if($pid>0){  
      
                   $this->workers_count++;  
      
               }elseif($pid==0){  
      
                   // 這個(gè)符號(hào)表示恢復(fù)系統(tǒng)對(duì)信號(hào)的默認(rèn)處理  
                   pcntl_signal(SIGTERM, SIG_DFL);  
                   pcntl_signal(SIGCHLD, SIG_DFL);  
                   if(!empty($this->jobs)){  
                       while($this->jobs[&#39;runtime&#39;]){  
                           if(empty($this->jobs[&#39;argv&#39;])){  
                               call_user_func($this->jobs[&#39;function&#39;],$this->jobs[&#39;argv&#39;]);  
                           }else{  
                               call_user_func($this->jobs[&#39;function&#39;]);  
                           }  
                           $this->jobs[&#39;runtime&#39;]--;  
                           sleep(2);  
                       }  
                       exit();  
      
                   }  
                   return;  
      
               }else{  
      
                   sleep(2);  
               }  
      
      
           }  
      
           $this->mainQuit();  
           exit(0);  
      
       }  
      
       //整個(gè)進(jìn)程退出  
       public function mainQuit(){  
      
           if (file_exists($this->pid_file)){  
               unlink($this->pid_file);  
               $this->_log("delete pid file " . $this->pid_file);  
           }  
           $this->_log("daemon process exit now");  
           posix_kill(0, SIGKILL);  
           exit(0);  
       }  
      
       // 添加工作實(shí)例，目前只支持單個(gè)job工作  
       public function setJobs($jobs=array()){  
      
           if(!isset($jobs[&#39;argv&#39;])||empty($jobs[&#39;argv&#39;])){  
      
               $jobs[&#39;argv&#39;]="";  
      
           }  
           if(!isset($jobs[&#39;runtime&#39;])||empty($jobs[&#39;runtime&#39;])){  
      
               $jobs[&#39;runtime&#39;]=1;  
      
           }  
      
           if(!isset($jobs[&#39;function&#39;])||empty($jobs[&#39;function&#39;])){  
      
               $this->log("你必須添加運(yùn)行的函數(shù)！");  
           }  
      
           $this->jobs=$jobs;  
      
       }  
       //日志處理  
       private  function _log($message){  
           printf("%s\t%d\t%d\t%s\n", date("c"), posix_getpid(), posix_getppid(), $message);  
       }  
      
   }  
      
   //調(diào)用方法1  
   $daemon=new DaemonCommand(true);  
   $daemon->daemonize();  
   $daemon->start(2);//開(kāi)啟2個(gè)子進(jìn)程工作  
   work();  
      
      
      
      
   //調(diào)用方法2  
   $daemon=new DaemonCommand(true);  
   $daemon->daemonize();  
   $daemon->addJobs(array(&#39;function&#39;=>&#39;work&#39;,&#39;argv&#39;=>&#39;&#39;,&#39;runtime&#39;=>1000));//function 要運(yùn)行的函數(shù),argv運(yùn)行函數(shù)的參數(shù)，runtime運(yùn)行的次數(shù)  
   $daemon->start(2);//開(kāi)啟2個(gè)子進(jìn)程工作  
      
   //具體功能的實(shí)現(xiàn)  
   function work(){  
         echo "測(cè)試1";  
   }  
   ?>

関連推奨事項(xiàng):

PHPのプロセス間通信の詳細(xì)説明

PHPのプロセス間通信の注意點(diǎn)まとめ

以上がPHPデーモンの詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。