PHP-Kommunikation zwischen Prozessen – Named Pipe

PHP-Pipeline-Kommunikation
Mein Blog: http://www.cnblogs.com/nickbai/
Mein GitHub: https://github.com/nick-bai

PHP für die Kommunikation zwischen Prozessen Es gibt verschiedene Möglichkeiten: Nachrichtenwarteschlange, Pipe, gemeinsam genutzter Speicher, Socket, Signal. In diesem Artikel wird die Methode anhand berühmter Pipes vorgestellt.　　

　PIPE

　 Pipes werden verwendet, um Kommunikationsdaten zwischen Abkürzungen zu übertragen. Zum besseren Verständnis kann eine Pipe mit einer Datei verglichen werden, die Daten in Pipe P schreibt und Prozess B dann Daten aus Pipe P liest. Die von PHP bereitgestellte Pipeline-Operations-API ist grundsätzlich dieselbe wie die API zum Betreiben von Dateien, außer dass die Funktion posix_mkfifo zum Erstellen einer Pipeline verwendet wird. Die Lese- und Schreibvorgänge sind dieselben wie die Dateioperationsfunktionen. Natürlich können Sie Dateien direkt zum Simulieren von Pipelines verwenden, aber dann können Sie die Funktionen von Pipelines nicht nutzen.

Die allgemeine Idee der Kommunikation über eine Pipe besteht darin, zuerst eine Pipe zu erstellen, dann schreibt der untergeordnete Prozess Informationen in die Pipe und der übergeordnete Prozess liest die Informationen aus der Pipe und untergeordnete Prozesse können direkt kommunizieren. <?php<br>/**<br> * author: NickBai<br> * createTime: 2016/12/2 0002 上午 11:12<br> */<br>//创建管道<br>$pipePath = "/tmp/test.pipe";<br>if( !file_exists( $pipePath ) ){<br>    if( !posix_mkfifo( $pipePath, 0666 ) ){<br>        exit('make pipe false!' . PHP_EOL);<br>    }<br>}<br><br>//创建进程,子进程写管道，父进程读管道<br>$pid = pcntl_fork();<br><br>if( $pid == 0 ){<br>    //子进程写管道<br>    $file = fopen( $pipePath, 'w' );<br>    fwrite( $file, 'hello world' );<br>    sleep(1);<br>    exit();<br>}else{<br>    //父进程读管道<br>    $file = fopen( $pipePath, 'r' );<br>    //stream_set_blocking( $file, False );  //设置成读取非阻塞<br>    echo fread( $file, 20 ) . PHP_EOL;<br><br>    pcntl_wait($status);  //回收子进程<br>}/** * Autor: NickBai
* createTime: 2.12.2016 0002 11:12 Uhr
*/
//Pipe erstellen
$pipePath = "/tmp/test.pipe";
if( !file_exists( $pipePath ). Prozess, der untergeordnete Prozess schreibt die Pipe, der übergeordnete Prozess liest die Pipe
$pid = pcntl_fork();

if( $pid == 0 ){
//Der untergeordnete Prozess schreibt die pipe
$file = fopen( $pipePath, 'w' );
fwrite( $file, 'hello world' );
sleep(1);
exit();
} else{ / /Übergeordneter Prozess liest Pipe
$file = fopen( $pipePath, 'r' );
//stream_set_blocking( $file, False ); //Auf nicht blockierendes Lesen setzen
echo fread( $file , 20 ) . und kann nur im PHP-CLI-Modus ausgeführt werden.
Zeile 7: Geben Sie den Pfad einer Pipeline an, der sich nicht von einer gewöhnlichen Datei unterscheidet.

Zeile 9: Erstellen Sie eine Pipe über die Funktion posix_mkfifo und setzen Sie die Lese- und Schreibberechtigungen auf 0666.
Zeile 15: Erstellen Sie einen untergeordneten Prozess über die Funktion pcntl_fork. Beachten Sie, dass das Programm von nun an zur Ausführung in zwei Prozesse unterteilt wird. Die Funktion pcntl_fork ist etwas ganz Besonderes. Sie hat nach dem Aufruf mehrere Rückgabewerte. Im übergeordneten Prozess: Es wird die ID des untergeordneten Prozesses zurückgegeben. Dieser Wert ist größer als 0. Im untergeordneten Prozess wird 0 zurückgegeben. Wenn -1 zurückgegeben wird, bedeutet dies, dass der Erstellungsprozess fehlgeschlagen ist. <br><br> Zeile 17: Die beiden Prozesse betreten unterschiedliche Zweige basierend auf den unterschiedlichen $pid-Werten, die der aktuelle Prozess erhält. <br><br>Zeilen 18–22: Der untergeordnete Prozess öffnet die Pipe, schreibt „Hallo Welt“ hinein, geht dann in den Ruhezustand über und wird nach Ende des Ruhezustands beendet. <br><br> Zeilen 25–29: Der übergeordnete Prozess öffnet die Pipe, liest sie und führt schließlich Zeile 29 des Codes aus, um den untergeordneten Prozess wiederzuverwenden. Hier sind zwei Stellen blockiert. Die erste ist die Standard-Lesestelle. Sie müssen warten, bis der untergeordnete Prozess einen Exit-Befehl ausgibt, bevor die Daten zurückgegeben werden können. Es gibt auch die Methode pcntl_wait, um den Prozess wiederzuverwenden. Warten Sie, bis der Prozess beendet wird. <br>Führen Sie diesen Code unter Linux aus: Sie werden sehen, dass das Programm für 1 Sekunde blockiert und dann „Hallo Welt“ ausgibt. Wenn wir die 26. Codezeile öffnen und die 27. Zeile in var_dump(fread( $file, 20 )) ändern, wenn wir das Programm ausführen: Sie kann sehen Das Programm gibt sofort eine leere Zeichenfolge aus und wartet 1 Sekunde, bevor es beendet wird. Das liegt daran. Wenn das Lesen nicht blockiert ist und der übergeordnete Prozess Informationen liest, wartet er nicht darauf, dass Informationen sofort verfügbar sind. Wenn sich keine Informationen in der Pipeline befinden, werden sie sofort zurückgegeben. Wenn dann Zeile 29 ausgeführt wird, um den untergeordneten Prozess wiederzuverwenden, blockiert sie und wartet darauf, dass der untergeordnete Prozess beendet wird. Schauen wir uns ein einfaches praktisches Beispiel an. Zwei untergeordnete Prozesse schreiben Informationen in eine Datei. Der übergeordnete Prozess ist dafür verantwortlich, zu überwachen und zu erkennen, ob das Schreiben der Datei abgeschlossen ist. Hier kommunizieren die übergeordneten und untergeordneten Prozesse über Pipes, um zu bestätigen, ob der Schreibvorgang abgeschlossen ist. <?php/** * Autor: NickBai * createTime: 2.12.2016 0002 14:00 Uhr*///Pipe erstellen$pipePath = "/tmp/test.pipe";if( !file_exists( $pipePath ) ){<br> if( !posix_mkfifo( $pipePath, 0666 ) ){<br> exit("make pipe fail n");<br> }<br>}<br><br>//Erstelle zwei Unterprozesse zum Schreiben von Dateien<br>for( $i = 0; $i < 2; $i++ ){<br><br> $pid = pcntl_fork();<br> if( $pid == 0 ){<br> file_put_contents( './pipe.log', $i . " write pipen", FILE_APPEND ); //Datei schreiben<br> $file = fopen( $pipePath, 'w' ) ; <br>                                                                                                                          who' who who who who's who's writing, fwrite( $file, $i . "n" ); //Schreiben Sie das Logo in die Pipeline, und das Schreiben des Logos ist abgeschlossen. <br> fclose( $file );<br> exit(); //Den untergeordneten Prozess verlassen <br> }<br>}<br><br>//Was der übergeordnete Prozess tun muss, ist: <br> //1, lesen Sie den Schreibstatus in der Pipe und stellen Sie fest, ob sie vollständig geschrieben ist <br>//3. Löschen Sie die Pipe <br>//4 🎜><br>$file = fopen( $pipePath, 'r' );<br>$line = 0;<br>while(1){<br> $end = fread( $file, 1024);<br> foreach( str_split ( $end ) as $c) {<br> if ( "n" == $c ) {<br> $line++;<br> }<br> }<br><br> if( $ line == 2 ){<br> copy( './pipe.log', './pipe_copy.log' );<br> fclose( $file );<br> unlink( $pipePath );<br> pcntl_wait ( $status ) ;<br> exit("ok n");<br> }<br>}<br><br>