Deutsch
Deutsch
In PHP ist Socket_export_Stream () eine sehr praktische Funktion, mit der wir eine Socket -Ressource mit niedriger Ebene in eine fortschrittlichere, streambasierte Stream- Ressource exportieren können, sodass wir Sockets verarbeiten können, wie wir Dateien oder Standardeingabe und Ausgabe manipulieren. Dies vereinfacht den Entwicklungsprozess erheblich, insbesondere in der Zusammenarbeit mit vorhandenen Streaming -APIs wie Stream_Select () , Fread () , FWrite () usw.
Nach der Umwandlung von Steckdosen in Streams stoßen viele Entwickler jedoch auf ein häufiges Problem: Konflikte treten bei der Durchführung von Lese- und Schreibvorgängen auf, die im selben Strom verschoben sind, was zu Datenausnahmen, Blockaden oder Verlust führt . Der Kern dieser Art von Problem liegt darin, wie man den Lese- und Schreibprozess vernünftigerweise anordnet, um die Stabilität und Konsistenz des Datenflusss zu gewährleisten.
Wenn Sie Socket_export_Stream () anrufen, um Socket in Stream zu konvertieren, gibt PHP dem Stream lesbare und beschreibbare Funktionen. Theoretisch können Sie es direkt mit Fread () und fWrite () manipulieren. Wenn jedoch nicht die Lese- und Schreibvorgänge geplant sind, können die folgenden Probleme auftreten:
Schreiben Sie die Operation Blocking : Wenn die andere Partei keine Daten liest, blockiert FWrite (), wenn der Puffer voll ist.
Operation Blockierung
Datenverwirrung : Die gleichzeitige Lesen und Schreibensynchronisation erfolgt nicht, was zu inkonsistenten Protokollen und zu einem Versagen bei der Analyse führt.
Um die oben genannten Probleme zu vermeiden, können wir die folgenden Aspekte aus starten, um den sicheren und effizienten Fluss während der Verwendung zu gewährleisten:
Stellen Sie den Stream in den Nicht-Blocking-Modus fest und verwenden Sie Stream_Select () , um zu bestimmen, wann Sie lesen und schreiben sollen, um zu vermeiden.
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, 'm66.net', 80);
$stream = socket_export_stream($socket);
stream_set_blocking($stream, false); // Setzen Sie den Nichtblockierungsmodus
$read = [$stream];
$write = [$stream];
$except = null;
if (stream_select($read, $write, $except, 5)) {
if (!empty($write)) {
fwrite($stream, "GET / HTTP/1.1\r\nHost: m66.net\r\n\r\n");
}
if (!empty($read)) {
$response = fread($stream, 8192);
echo $response;
}
}
Auf diese Weise können Sie das Schreiben nur dann kontrollieren, wenn der Stream schriftlich ist und nur dann, wenn er lesbar ist, wodurch Blockierung und Ressourcenabfälle vermieden werden.
Obwohl Socket_export_Stream () einen bidirektionalen Strom zurückgibt, kann in einigen Protokollen oder Anwendungen die Trennung von Lesen und Schreiblogik Konflikte reduzieren. Sie können Lesen und Schreiben von Vorgängen trennen und schreiben, indem Sie Layer -Protokollsteuerung anwenden oder Coroutinen/Multiprozesse/Threads einführen.
Verwenden Sie beispielsweise Stream_Socket_Pair () , um zwei lokale Socket -Streams zu erstellen. Einer ist für das Lesen verantwortlich und der andere für das Schreiben verantwortlich und erstellt einen Datenverkehrskanal.
In Szenarien, in denen Stream_Select () nicht verwendet wird, können Sie auch explizit Sperren im Programm hinzufügen oder asynchrone Frameworks (wie SWOOLE, ReactPhp) verwenden, um die Les- und Schreibreihenfolge zu steuern.
$lock = fopen(__FILE__, 'r');
flock($lock, LOCK_EX);
// Daten schreiben
fwrite($stream, $data);
// Lesen Sie Daten nach dem Entsperren
flock($lock, LOCK_UN);
$response = fread($stream, 8192);
Obwohl diese Methode relativ primitiv ist, kann sie effektiv gleichzeitige Ressourcenkonflikte in Skriptanwendungen vermeiden.
Wenn Sie einen Stream verwenden, um den Schreibvorgang abzuschließen, rufen Sie Fflush () auf, um den Puffer zu aktualisieren. Bevor Sie die Verbindung schließen, sollten Sie auch darauf achten, zuerst das Schreibende zu schließen, auf das abgeschlossene Lesen zu warten und dann zu trennen.
fwrite($stream, $data);
fflush($stream);
fclose($stream);
Mit Socket_export_Stream () wird die Betriebsfähigkeit des Streams verbessert, wird jedoch auch die Herausforderung der synchronen Steuerung einführen. Um Lesen und Schreiben von Konflikten zu vermeiden, können Sie:
Verwenden Sie Stream_Select () , um genau zu planen.
Verwendet in Verbindung mit dem Nicht-Blocking-Modus;
Einführung von Schlössern, Coroutinen oder asynchronen Verarbeitungsmechanismen;
Verwalten Sie den Puffer -Aktualisierung und Schließzeiten.
Durch diese Methoden können die Zuverlässigkeit und Wartbarkeit von Socket -Conversion -Streams in der PHP -Netzwerkprogrammierung effektiv verbessert werden.
