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>//創(chuàng)建管道<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>//創(chuàng)建進(jìn)程,子進(jìn)程寫(xiě)管道，父進(jìn)程讀管道<br>$pid?=?pcntl_fork();<br><br>if(?$pid?==?0?){<br>????//子進(jìn)程寫(xiě)管道<br>????$file?=?fopen(?$pipePath,?'w'?);<br>????fwrite(?$file,?'hello?world'?);<br>????sleep(1);<br>????exit();<br>}else{<br>????//父進(jìn)程讀管道<br>????$file?=?fopen(?$pipePath,?'r'?);<br>????//stream_set_blocking(?$file,?False?);??//設(shè)置成讀取非阻塞<br>????echo?fread(?$file,?20?)?.?PHP_EOL;<br><br>????pcntl_wait($status);??//回收子進(jìn)程<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>