Codebeispiel für PHP-Prozessmanagement

Dieser Artikel enthält Codebeispiele zum PHP-Prozessmanagement. Freunde in Not können darauf verweisen.

Dieser Artikel ist eine Ergänzung und Verbesserung zum vorherigen Artikel. Erstellen Sie einen Masterprozess, installieren Sie einen Timer im Masterprozess, ermitteln Sie alle 5 Minuten die Warteschlangenlänge und berechnen Sie ihn basierend auf der Warteschlangenlänge . Der erforderliche Arbeitsprozess

und dann den untergeordneten Prozess erstellen oder beenden. Dies hat den Vorteil, dass sich die Warteschlange nicht anhäuft und Aufgaben nicht rechtzeitig bearbeitet werden. Um den Geschäftscode zu aktualisieren, ist nur der Neuladevorgang erforderlich.

Der gesamte Prozess hat die folgenden Wissenspunkte:

• Schritte zum Erstellen eines Daemons:

1. Einstellungen Standard-Dateiberechtigungen

2. Verzweigung eines Prozesses, der übergeordnete Prozess wird beendet

3. Setsid aufrufen, um eine neue Sitzung zu erstellen

4. Ändern Sie das aktuelle Arbeitsverzeichnis in das Stammverzeichnis

5. Schließen Sie nicht mehr benötigte Dateideskriptoren

• Signalimplementierungs-Timer verwenden

Der Timer des vorherigen Artikels hängt von den geplanten Aufgaben des Systems ab. Diesmal wird er mithilfe des Weckersignals implementiert. Versionen unter PHP 5.3.0 hängen von Ticks ab .0 und Die obige Version kann pcntl_signal_dispatch verwenden

Signal: Bietet eine asynchrone Ereignisverarbeitungsmethode. Wenn ein Signal auftritt, verfügt der Prozess über die folgenden drei Möglichkeiten, das Signal zu verarbeiten

1. Ignorieren Sie dieses Signal

2. Fangen Sie das Signal ab

3. Führen Sie die Standardaktion des Systems aus, um den Prozess zu beenden

• Gemeinsame Signale

SIGKILL, SIGSTOP sind zwei Signale, die von Benutzern nicht ignoriert und erfasst werden können

SIGINT( 2): Programmbeendigungssignal, normalerweise ausgegeben, wenn Strg-C gedrückt wird, wird verwendet, um die Vordergrundprozessgruppe zu benachrichtigen, den Prozess zu beenden

SIGQUIT (3): Ähnlich wie SIGINT, wird aber durch QUIT signalisiert Zeichen (normalerweise Strg+/) Steuerung. Wenn der Prozess diese Nachricht empfängt und beendet, generiert er eine Kerndatei

SIGKILL(9): Beendet den Prozess sofort und kann nicht ignoriert oder blockiert werden

SIGUSR1(10): Benutzerdefiniertes Signal

SIGUSR2(12): reserviert für Benutzer

SIGALRM(14): Weckersignal

SIGTERM(15): Beenden des Prozess und kann vom Programm erfasst werden, sodass der Prozess mit Bereinigungsvorgängen abgeschlossen werden kann.

SIGSTOP(19): Stoppt einen Prozess, der Prozess ist noch nicht beendet, er unterbricht lediglich die Ausführung

• Verhindert die Generierung von Zombie-Prozessen

Alle Prozesse werden beim Beenden zu Zombie-Prozessen. Wenn zu diesem Zeitpunkt der übergeordnete Prozess noch ausgeführt wird und „wait“ oder „waitpid“ nicht aufgerufen wird, werden die vom Zombie-Prozess belegten Ressourcen nicht bereinigt Der übergeordnete Prozess wurde beendet. Der Zombie-Prozess wird vom Init-Prozess zur Bereinigung aufgerufen.

Passen Sie den Geschäftscode an. Der Hauptcode lautet wie folgt

　Eine Sache, die Sie beachten sollten, ist, dass beim Erstellen eines Daemon-Prozesses die Eingabe und Ausgabe geschlossen werden und Fehler auftreten Ausgabestream, wenn sich hinter dem Code ein Echo usw. befindet Ausgabezeichen, tritt ein schwerwiegender Fehler auf und der Ausgabestream muss im PHP-Code nach /dev/null umgeleitet werden. Oder leiten Sie um, wenn das Terminal den Vorgang startet

<?php
define(&#39;PROC_MAX&#39;, 10);
define(&#39;PROC_MIN&#39;, 5);

$cmd = $argv[1];
$aPid = [];
$pidFile = __DIR__ . &#39;/pid.pid&#39;;
$pid = file_get_contents($pidFile);

switch($cmd){
    case &#39;start&#39; :
        if(posix_kill($pid, 0)){
            echo "gamelog process is already exsits!\n";
            return false;
        }
        //设置默认文件权限
        umask(022);
        //fork
        $pid = pcntl_fork();
        if($pid < 0){
            exit(&#39;fork error!&#39;);
        }else if($pid > 0){
            exit;
        }
        //脱离当前终端
        posix_setsid();
        //将当前工作目录更改为根目录
        chdir(&#39;/&#39;);
        //关闭文件描述符
        fclose(STDIN);
        fclose(STDOUT);
        fclose(STDERR);
        //重定向输入输出
        global $STDOUT, $STDERR;
        $STDOUT = fopen(&#39;/dev/null&#39;, &#39;a&#39;);
        $STDERR = fopen(&#39;/dev/null&#39;, &#39;a&#39;);
        
        cli_set_process_title(&#39;gamelog:master&#39;);
        $pid = posix_getpid();
        file_put_contents($pidFile, $pid);
        //闹钟信号
        pcntl_signal(SIGALRM, function() use (&$aPid) {
            pcntl_alarm(300);
            $workerNum = mt_rand(1, 20);//此处检测你需要的进程数
            $daemonNum = count($aPid);
            
            ($workerNum > PROC_MAX) && ($workerNum = PROC_MAX);
            if($daemonNum < $workerNum){
                $procNum = $workerNum - $daemonNum;
                $procNum = max(PROC_MIN, $procNum);
                for($p = 1; $p <= $procNum; $p++){
                    $pid = pcntl_fork();
                    if ($pid < 0) {
                        exit(&#39;fork error!&#39;);
                    } else if ($pid == 0) {
                        cli_set_process_title(&#39;gamelog:worker&#39;);
                        while (true) {
                            //do your work
                            usleep(100);
                        }
                        exit();
                    } else {
                        $aPid[] = $pid;
                    }
                }
            }else if($daemonNum > $workerNum){
                $wokerNum = max($wokerNum, PROC_MIN);
                $killNum = $daemonNum - $workerNum;
                foreach($aPid as $key=>$pid){
                    if(posix_kill($pid, SIGKILL)){
                        unset($aPid[$key]);
                        if(--$killNum <= 0){
                            break;
                        }
                    }
                }
            }
        }, false);
        
        pcntl_signal(SIGUSR1, function() use (&$aPid, $pid){
            foreach($aPid as $key=>$chpid){
                if(!posix_kill($chpid, SIGKILL)){
                    echo "kill child $chpid faild\n";
                }
            }
            posix_kill($pid, SIGKILL);
        }, false);
        
        pcntl_signal(SIGUSR2, function() use (&$aPid, $pid){
           foreach($aPid as $key=>$chpid){
                if(!posix_kill($chpid, SIGKILL)){
                    echo "kill child $chpid faild\n";
                }
            }
            if(!posix_kill($pid, SIGALRM)){
                echo "restart gamelog faild\n";
            }
        }, false);
        
        posix_kill($pid, SIGALRM);
        while (true) {
            pcntl_signal_dispatch();
            $pid = pcntl_wait($status, WUNTRACED);//不阻塞
        }
        break;
    
    case &#39;stop&#39; :
        if(!posix_kill($pid, SIGUSR1)){
            exit(&#39;stop gamelog process error!&#39;);
        }
        break;
    case &#39;reload&#39; :
        if(!posix_kill($pid, SIGUSR2)){
            exit(&#39;restop gamelog process error!&#39;);
        }
        break;
    default :
        echo "Useage php signal.php start|stop|reload\n";
}

Das obige ist der detaillierte Inhalt vonCodebeispiel für PHP-Prozessmanagement. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!