搜尋
首頁後端開發php教程php 守護程式(Daemon)

php 守護程式(Daemon)

May 28, 2018 pm 03:49 PM
php行程

這篇文章給大家分享的內容是關於php 守護進程(Daemon),有著一定的參考價值,有需要的朋友可以參考一下

 守護程式(Daemon)是運行在後台的一種特殊進程。它獨立於控制終端並且週期性地執行某種任務或等待處理某些發生的事件。守護程式是一種很有用的程式。 php也可以實現守護程式的功能。

 

1、基本概念

    程序

            每個行程有一個父程式,子行程退出,父程式能由子程式退出的狀態。

    進程組

            每個行程都屬於一個進程組,且每個進程組都有一個進程組號,該號等於該進程組組長的PID

2.守護程式要點

    1. 在背景運作。    
         為避免以暫停控制終端將Daemon放入後台執行。方法是在進程中呼叫fork使父進程終止,讓Daemon在子進程中後台執行。 if($pid=pcntl_fork()) exit(0);//是父進程,結束父進程,子進程繼續
    2. 脫離控制終端,登入會話和進程組 
       中的進程與控制終端,登入會話和進程組之間的關係:進程屬於一個進程組,進程組號(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 訊號說明清單

  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";  
    }  
    ?>

相關推薦:

PHP進程間通訊詳解

總結關於PHP進程通訊注意點


#

以上是php 守護程式(Daemon)的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
PHP和Python:解釋了不同的範例PHP和Python:解釋了不同的範例Apr 18, 2025 am 12:26 AM

PHP主要是過程式編程,但也支持面向對象編程(OOP);Python支持多種範式,包括OOP、函數式和過程式編程。 PHP適合web開發,Python適用於多種應用,如數據分析和機器學習。

PHP和Python:深入了解他們的歷史PHP和Python:深入了解他們的歷史Apr 18, 2025 am 12:25 AM

PHP起源於1994年,由RasmusLerdorf開發,最初用於跟踪網站訪問者,逐漸演變為服務器端腳本語言,廣泛應用於網頁開發。 Python由GuidovanRossum於1980年代末開發,1991年首次發布,強調代碼可讀性和簡潔性,適用於科學計算、數據分析等領域。

在PHP和Python之間進行選擇:指南在PHP和Python之間進行選擇:指南Apr 18, 2025 am 12:24 AM

PHP適合網頁開發和快速原型開發,Python適用於數據科學和機器學習。 1.PHP用於動態網頁開發,語法簡單,適合快速開發。 2.Python語法簡潔,適用於多領域,庫生態系統強大。

PHP和框架:現代化語言PHP和框架:現代化語言Apr 18, 2025 am 12:14 AM

PHP在現代化進程中仍然重要,因為它支持大量網站和應用,並通過框架適應開發需求。 1.PHP7提升了性能並引入了新功能。 2.現代框架如Laravel、Symfony和CodeIgniter簡化開發,提高代碼質量。 3.性能優化和最佳實踐進一步提升應用效率。

PHP的影響:網絡開發及以後PHP的影響:網絡開發及以後Apr 18, 2025 am 12:10 AM

PHPhassignificantlyimpactedwebdevelopmentandextendsbeyondit.1)ItpowersmajorplatformslikeWordPressandexcelsindatabaseinteractions.2)PHP'sadaptabilityallowsittoscaleforlargeapplicationsusingframeworkslikeLaravel.3)Beyondweb,PHPisusedincommand-linescrip

PHP類型提示如何起作用,包括標量類型,返回類型,聯合類型和無效類型?PHP類型提示如何起作用,包括標量類型,返回類型,聯合類型和無效類型?Apr 17, 2025 am 12:25 AM

PHP類型提示提升代碼質量和可讀性。 1)標量類型提示:自PHP7.0起,允許在函數參數中指定基本數據類型,如int、float等。 2)返回類型提示:確保函數返回值類型的一致性。 3)聯合類型提示:自PHP8.0起,允許在函數參數或返回值中指定多個類型。 4)可空類型提示:允許包含null值,處理可能返回空值的函數。

PHP如何處理對象克隆(克隆關鍵字)和__clone魔法方法?PHP如何處理對象克隆(克隆關鍵字)和__clone魔法方法?Apr 17, 2025 am 12:24 AM

PHP中使用clone關鍵字創建對象副本,並通過\_\_clone魔法方法定制克隆行為。 1.使用clone關鍵字進行淺拷貝,克隆對象的屬性但不克隆對象屬性內的對象。 2.通過\_\_clone方法可以深拷貝嵌套對象,避免淺拷貝問題。 3.注意避免克隆中的循環引用和性能問題,優化克隆操作以提高效率。

PHP與Python:用例和應用程序PHP與Python:用例和應用程序Apr 17, 2025 am 12:23 AM

PHP適用於Web開發和內容管理系統,Python適合數據科學、機器學習和自動化腳本。 1.PHP在構建快速、可擴展的網站和應用程序方面表現出色,常用於WordPress等CMS。 2.Python在數據科學和機器學習領域表現卓越,擁有豐富的庫如NumPy和TensorFlow。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
1 個月前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
1 個月前By尊渡假赌尊渡假赌尊渡假赌
威爾R.E.P.O.有交叉遊戲嗎?
1 個月前By尊渡假赌尊渡假赌尊渡假赌

熱工具

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

這個專案正在遷移到osdn.net/projects/mingw的過程中,你可以繼續在那裡關注我們。 MinGW:GNU編譯器集合(GCC)的本機Windows移植版本,可自由分發的導入函式庫和用於建置本機Windows應用程式的頭檔;包括對MSVC執行時間的擴展,以支援C99功能。 MinGW的所有軟體都可以在64位元Windows平台上運作。

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

WebStorm Mac版

WebStorm Mac版

好用的JavaScript開發工具

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強大的PHP整合開發環境

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器