社群 學習 工具庫 休閒
搜尋
繁体中文
首頁 > 後端開發 > php教程 > php写守护进程（Daemon）_PHP教程

php写守护进程（Daemon）_PHP教程

WBOY
發布： 2016-07-15 13:21:35
原創
962 人瀏覽過

 守护进程（Daemon）是运行在后台的一种特殊进程。它独立于控制终端并且周期性地执行某种任务或等待处理某些发生的事件。守护进程是一种很有用的进程。php也可以实现守护进程的功能。

 

1、基本概念

    进程

            每个进程都有一个父进程，子进程退出，父进程能得到子进程退出的状态。

    进程组

            每个进程都属于一个进程组，每个进程组都有一个进程组号，该号等于该进程组组长的PID

2、守护编程要点

 守护进程（Daemon）是运行在后台的一种特殊进程。它独立于控制终端并且周期性地执行某种任务或等待处理某些发生的事件。守护进程是一种很有用的进程。php也可以实现守护进程的功能。

 

1、基本概念

    进程

            每个进程都有一个父进程，子进程退出，父进程能得到子进程退出的状态。

    进程组

            每个进程都属于一个进程组，每个进程组都有一个进程组号，该号等于该进程组组长的PID

2、守护编程要点

    1. 在后台运行。    
         为避免挂起控制终端将Daemon放入后台执行。方法是在进程中调用fork使父进程终止，让Daemon在子进程中后台执行。 if($pid=pcntl_fork()) exit(0);//是父进程，结束父进程，子进程继续
    2. 脱离控制终端，登录会话和进程组
       有必要先介绍一下Linux中的进程与控制终端，登录会话和进程组之间的关系：进程属于一个进程组，进程组号（GID）就是进程组长的进程号（PID）。登录会话可以包含多个进程组。这些进程组共享一个控制终端。这个控制终端通常是创建进程的登录终  端。 控制终端，登录会话和进程组通常是从父进程继承下来的。我们的目的就是要摆脱它们，使之不受它们的影响。方法是在第1点的基础上，调用setsid()使进程成为会话组长： posix_setsid();
        说明：当进程是会话组长时setsid()调用失败。但第一点已经保证进程不是会话组长。setsid()调用成功后，进程成为新的会话组长和新的进程组长，并与原来的登录会话和进程组脱离。由于会话过程对控制终端的独占性，进程同时与控制终端脱离。
    3. 禁止进程重新打开控制终端
        现在，进程已经成为无终端的会话组长。但它可以重新申请打开一个控制终端。可以通过使进程不再成为会话组长来禁止进程重新打开控制终端： if($pid=pcntl_fork()) exit(0);//结束第一子进程，第二子进程继续（第二子进程不再是会话组长）
    4. 关闭打开的文件描述符
        进程从创建它的父进程那里继承了打开的文件描述符。如不关闭，将会浪费系统资源，造成进程所在的文件系统无法卸下以及引起无法预料的错误。按如下方法关闭它们：
        fclose(STDIN),fclose(STDOUT),fclose(STDERR)关闭标准输入输出与错误显示。
    5. 改变当前工作目录
        进程活动时，其工作目录所在的文件系统不能卸下。一般需要将工作目录改变到根目录。对于需要转储核心，写运行日志的进程将工作目录改变到特定目录如chdir("/")
    6. 重设文件创建掩模
        进程从创建它的父进程那里继承了文件创建掩模。它可能修改守护进程所创建的文件的存取位。为防止这一点，将文件创建掩模清除：umask(0);
    7. 处理SIGCHLD信号
        处理SIGCHLD信号并不是必须的。但对于某些进程，特别是服务器进程往往在请求到来时生成子进程处理请求。如果父进程不等待子进程结束，子进程将成为僵尸进程（zombie）从而占用系统资源。如果父进程等待子进程结束，将增加父进程的负担，影  响服务器进程的并发性能。在Linux下可以简单地将SIGCHLD信号的操作设为SIG_IGN。 signal(SIGCHLD,SIG_IGN);
        这样，内核在子进程结束时不会产生僵尸进程。这一点与BSD4不同，BSD4下必须显式等待子进程结束才能释放僵尸进程。关于信号的问题请参考Linux 信号说明列表


 

3、实例

 
<?php  
/** 
*@author tengzhaorong@gmail.com 
*@date 2013-07-25 
* 后台脚本控制类 
*/  
class DaemonCommand{  
   
    private $info_dir="/tmp";  
    private $pid_file="";  
    private $terminate=false; //是否中断   
    private $workers_count=0;  
    private $gc_enabled=null;  
    private $workers_max=8; //最多运行8个进程   
   
    public function __construct($is_sington=false,$user=&#39;nobody&#39;,$output="/dev/null"){  
   
            $this->is_sington=$is_sington; //是否单例运行，单例运行会在tmp目录下建立一个唯一的PID   
            $this->user=$user;//设置运行的用户 默认情况下nobody   
            $this->output=$output; //设置输出的地方   
            $this->checkPcntl();  
    }  
    //检查环境是否支持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);  
        }  
        //信号处理   
        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下面运行   
        if (php_sapi_name() != "cli"){  
            die("only run in command line mode\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){ //是父进程，父进程退出   
            exit();  
        }  
   
        posix_setsid();//设置新会话组长，脱离终端   
   
        if (pcntl_fork() != 0){ //是第一子进程，结束第一子进程      
            exit();  
        }  
   
        chdir("/"); //改变工作目录   
   
        $this->setUser($this->user) or die("cannot change owner");  
   
        //关闭打开的文件描述符   
        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();  
        }  
   
    }  
    //--检测pid是否已经存在   
    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);  
   
    }  
    //----创建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);  
    }  
   
    //设置运行的用户   
    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;  
   
    }  
    //信号处理函数   
    public function signalHandler($signo){  
   
        switch($signo){  
   
            //用户自定义信号   
            case SIGUSR1: //busy   
            if ($this->workers_count < $this->workers_max){  
                $pid = pcntl_fork();  
                if ($pid > 0){  
                    $this->workers_count ++;  
                }  
            }  
            break;  
            //子进程结束信号   
            case SIGCHLD:  
                while(($pid=pcntl_waitpid(-1, $status, WNOHANG)) > 0){  
                    $this->workers_count --;  
                }  
            break;  
            //中断进程   
            case SIGTERM:  
            case SIGHUP:  
            case SIGQUIT:  
   
                $this->terminate = true;  
            break;  
            default:  
            return false;  
        }  
   
    }  
    /** 
    *开始开启进程 
    *$count 准备开启的进程数 
    */  
    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){  
   
                // 这个符号表示恢复系统对信号的默认处理   
                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);  
   
    }  
   
    //整个进程退出   
    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);  
    }  
   
    // 添加工作实例，目前只支持单个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("你必须添加运行的函数！");  
        }  
   
        $this->jobs=$jobs;  
   
    }  
    //日志处理   
    private  function _log($message){  
        printf("%s\t%d\t%d\t%s\n", date("c"), posix_getpid(), posix_getppid(), $message);  
    }  
   
}  
   
//调用方法1   
$daemon=new DaemonCommand(true);  
$daemon->daemonize();  
$daemon->start(2);//开启2个子进程工作   
work();  
   
   
   
   
//调用方法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 要运行的函数,argv运行函数的参数，runtime运行的次数   
$daemon->start(2);//开启2个子进程工作   
   
//具体功能的实现   
function work(){  
      echo "测试1";  
}  
?>  

<?php
/**
*@author tengzhaorong@gmail.com
*@date 2013-07-25
* 后台脚本控制类
*/
class DaemonCommand{
 
    private $info_dir="/tmp";
    private $pid_file="";
    private $terminate=false; //是否中断
    private $workers_count=0;
    private $gc_enabled=null;
    private $workers_max=8; //最多运行8个进程
 
    public function __construct($is_sington=false,$user=&#39;nobody&#39;,$output="/dev/null"){
 
            $this->is_sington=$is_sington; //是否单例运行，单例运行会在tmp目录下建立一个唯一的PID
            $this->user=$user;//设置运行的用户 默认情况下nobody
            $this->output=$output; //设置输出的地方
            $this->checkPcntl();
    }
    //检查环境是否支持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);
        }
        //信号处理
        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下面运行
        if (php_sapi_name() != "cli"){
            die("only run in command line mode\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){ //是父进程，父进程退出
            exit();
        }
 
        posix_setsid();//设置新会话组长，脱离终端
 
        if (pcntl_fork() != 0){ //是第一子进程，结束第一子进程   
            exit();
        }
 
        chdir("/"); //改变工作目录
 
        $this->setUser($this->user) or die("cannot change owner");
 
        //关闭打开的文件描述符
        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();
        }
 
    }
    //--检测pid是否已经存在
    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);
 
    }
    //----创建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);
    }
 
    //设置运行的用户
    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;
 
    }
    //信号处理函数
    public function signalHandler($signo){
 
        switch($signo){
 
            //用户自定义信号
            case SIGUSR1: //busy
            if ($this->workers_count < $this->workers_max){
                $pid = pcntl_fork();
                if ($pid > 0){
                    $this->workers_count ++;
                }
            }
            break;
            //子进程结束信号
            case SIGCHLD:
                while(($pid=pcntl_waitpid(-1, $status, WNOHANG)) > 0){
                    $this->workers_count --;
                }
            break;
            //中断进程
            case SIGTERM:
            case SIGHUP:
            case SIGQUIT:
 
                $this->terminate = true;
            break;
            default:
            return false;
        }
 
    }
    /**
    *开始开启进程
    *$count 准备开启的进程数
    */
    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){
 
                // 这个符号表示恢复系统对信号的默认处理
                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);
 
    }
 
    //整个进程退出
    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);
    }
 
    // 添加工作实例，目前只支持单个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("你必须添加运行的函数！");
        }
 
        $this->jobs=$jobs;
 
    }
    //日志处理
    private  function _log($message){
        printf("%s\t%d\t%d\t%s\n", date("c"), posix_getpid(), posix_getppid(), $message);
    }
 
}
 
//调用方法1
$daemon=new DaemonCommand(true);
$daemon->daemonize();
$daemon->start(2);//开启2个子进程工作
work();
 
 
 
 
//调用方法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 要运行的函数,argv运行函数的参数，runtime运行的次数
$daemon->start(2);//开启2个子进程工作
 
//具体功能的实现
function work(){
      echo "测试1";
}
?>
登入後複製


 

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/477175.htmlTechArticle守护进程（Daemon）是运行在后台的一种特殊进程。它独立于控制终端并且周期性地执行某种任务或等待处理某些发生的事件。守护进程是一...
相關標籤：
php 。 寫 後台 控制 是 的 行程
來源：php.cn
上一篇：使用CakePHP框架开发网站_PHP教程 下一篇：PHP进阶篇之53个要点提高PHP编程效率_PHP教程
本網站聲明
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
作者最新文章
最新問題
PHP數組從URL參數中取得的行為不如預期 我有一個包含類別ID的URL參數，我想將其視為一個數組，如下所示：http://example.com?cat[]=3,9,13在PHP中，我使用它從URL參數取得數組：$catI...
來自於 2024-04-06 22:09:02
0
1
1428
我應該在 apache 中哪裡放置 CustomLog 指令 我正在使用php:7.2-apachedocker。我需要禁用運行狀況檢查url登入訪問日誌。基於此鏈接，他們提到了有關修改Customlog指令的資訊。我不是關於需要更改Cust...
來自於 2024-04-06 22:03:59
0
1
990
傳回值中變數的格式是什麼？ 我是php的新學習者。我發現有一段程式碼：if($x<time()){return[false,'error'];}邏輯或變數並不重要，但我不明白[false,'error'...
來自於 2024-04-06 21:55:20
0
1
778
使用opentbs產生odt檔案時遇到的問題：相同key的值顯示在同一行而不是單獨的欄位中。 我正在使用一個名為OpenTbs的庫來使用PHP建立odt，我使用它是因為動態生成列和行。我知道如何建立行和列，但我不知道如何組織它們。讓我加入一個例子：所以首先我會將其添加到我的...
來自於 2024-04-06 20:18:18
0
1
483
依照ID對MySQL結果進行分組以便循環遍歷 我有一個表，其中有mysql中的航班資料。我正在編寫一個php程式碼，它將使用codeigniter3對資料進行分組和顯示journey_idair_idFlightDuratio...
來自於 2024-04-06 17:27:56
0
1
406
相關專題
更多>
熱門推薦
熱門教學
更多>
相關教學
熱門推薦
最新課程
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板