Screenshot:
Copy
-Unterprozesses implementiert. Ich denke, es wäre sehr nützlich, wenn es in AMQP beim Hinzufügen oder Entfernen von Verbrauchern verwendet würde.
Copy
子进程的功能。如果用在AMQP增减消费者时,我觉得应该会很有用。
1、在主进程循环内启动子进程执行命令
2、在web输入 127.0.0.1:7865 获取子进程状态
3、socket接收请求消息,并且执行相应操作,返回web页面
4、回收子进程,防止称为僵尸进程
不足:无法持续监听错误页面。由于socket得到的响应是通过include
函数加载的,所以在加载的页面内不能出现tail -f
命令,否则stream就会掉入了死循环了~。我想应该有方案解决(写了socket+多进程模式,模仿fpm在接收到请求之后就启动一个子进程去处理的模式,但是执行有问题。因此将代码贴出来希望得到大家的指点)。
延伸:由于对进程可以很好的管理(期望如此),那么就可以定制化自己的一些需求,比如:(1)定制AMQP的消费者进程管理服务。(2)模拟crontab定时服务。
代码实现的过程中,有很多的细节是值得学习的。
1、在while()循环中,启用了stream的非阻塞模式。所以不能在循环中使用sleep(1)
,而是用stream_select($read, $write, $except, 1)
让stream内部阻塞。
关于阻塞非阻塞模式,可以参阅这里
2、能够执行外部程序的函数很多,但是都稍有不同。这里采用的是proc_open
,是一个很强大的函数。在这之前我曾用pcntl_exec
执行过外部程序,但是需要先pcntl_fork
。而用其他的如exec
,shell_exec
无法对子进程进行管理。
3、重启或停止等操作子进程时,只是先更改主进程中该子进程在内存中的的状态,并不是真正的对子进程操作。在统一处init()
3 Anforderungsnachricht, führt den entsprechenden Vorgang aus und kehrt zur Webseite zurückUnzulänglichkeit: Fehlerseiten können nicht kontinuierlich überwacht werden. Da die Antwort vom Socket über die Funktion4. Recyceln Sie untergeordnete Prozesse, um zu verhindern, dass sie als Zombie-Prozesse bezeichnet werden
include
geladen wird, kann der Befehl tail -f
nicht auf der geladenen Seite erscheinen, da der Stream sonst in eine Endlosschleife gerät~ . Ich denke, es sollte eine Lösung geben (ich habe den Socket+Multiprozess-Modus geschrieben, um den Modus zu imitieren, in dem fpm einen Unterprozess startet, um die Anfrage nach dem Empfang zu bearbeiten, aber es gibt Probleme bei der Ausführung. Also habe ich den Code gepostet in der Hoffnung, den Rat aller zu bekommen). Erweiterung: Da der Prozess gut verwaltet werden kann (erwartet), können Sie einige Ihrer eigenen Anforderungen anpassen, z. B.: (1) Anpassen der AMQP-Verbraucherprozessverwaltungsdienste. (2) Simulieren Sie den Crontab-Timing-Dienst.
Wissenspunkte
Im Prozess der Codeimplementierung gibt es viele Details, die es wert sind, gelernt zu werden.
1. In der while()-Schleife ist der nicht blockierende Stream-Modus aktiviert. Sie könnensleep(1)
also nicht in einer Schleife verwenden, sondern stream_select($read, $write, $exclusion, 1)
, um den Stream intern zu blockieren. Informationen zu blockierenden und nicht blockierenden Modi finden Sie hier.
2 Es gibt viele Funktionen, die externe Programme ausführen können, aber sie unterscheiden sich alle geringfügig. Hier wirdproc_open
verwendet, eine sehr leistungsstarke Funktion. Ich habe pcntl_exec
schon früher verwendet, um externe Programme auszuführen, aber ich muss zuerst pcntl_fork
ausführen. Andere Methoden wie exec
und shell_exec
können jedoch keine untergeordneten Prozesse verwalten. 3. Beim Neustarten oder Stoppen eines untergeordneten Prozesses ändert sich zunächst nur der Status des untergeordneten Prozesses im Speicher des Hauptprozesses und es wird nicht wirklich auf den untergeordneten Prozess eingegriffen. init()
verarbeitet untergeordnete Prozesse an derselben Stelle. Dies kann einige seltsame Phänomene verhindern, die durch den Kontext beim Starten des untergeordneten Prozesses verursacht werden.
Code
|- Process.php|- Http.php|- StreamConnection.php
|- Consumer.php🎜|- BaseObject.php🎜|- view/🎜🎜Weitere programmbezogene Informationen Für Wissen, Bitte besuchen Sie: 🎜Programmierunterricht🎜! ! 🎜Das obige ist der detaillierte Inhalt vonPHP simuliert das Prozessmanagement des Supervisors. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!