Deutsch
Deutsch
Bei der Verarbeitung von Streams in PHP müssen wir die Daten manchmal im Stream mehr bedienen, z. B. das Lesen von Datenblöcken (Eimer), um eine angepasste Pufferung zu implementieren. Der Stream -Filtermechanismus von PHP bietet eine leistungsstarke Schnittstelle, wobei Stream_Bucket_Make_Writable eine Schlüsselfunktion ist, mit der wir Datenblöcke aus dem Puffer des Streams erhalten, lesen und arbeiten können.
In diesem Artikel wird die Rolle von stream_bucket_make_writable ausführlich vorgestellt, wie Sie Datenblöcke in PHP -Streams lesen und seine spezifische Anwendung anhand eines praktischen Beispiels demonstrieren.
stream_bucket_make_writable ist eine filterbezogene Funktion des PHP-Streams und gehört zur Operationsschnittstelle der Struktur von PHP_STREAM_BUCKET . Seine Funktion besteht darin, einen Datenblock (Bucket) aus dem internen Puffer des Streams zu "herausnehmen" und ein beschreibbares Bucket -Objekt zurückzugeben. Dieser Eimer enthält die aktuell verfügbaren Daten, die wir direkt lesen oder ändern können.
Diese Funktion wird üblicherweise bei der Implementierung von benutzerdefinierten Stream -Filtern verwendet, wodurch Entwickler die Streamed -Daten wie Komprimierung, Verschlüsselung, Decodierung und andere Vorgänge fein steuern können.
Das Lesen eines Datenblocks mit stream_bucket_make_writable erfordert ungefähr die folgenden Schritte:
Erstellen und registrieren Sie einen benutzerdefinierten Flussfilter <br> Die Flussfilterklasse muss PHP_USER_FILTER erben und die Filtermethode überschreiben.
Rufen Sie in der Filtermethode Stream_Bucket_Make_Writable an
Holen Sie sich einen Eimer durch diese Funktion, um die Daten daraus zu lesen.
Verarbeitung des Lesedatenblocks <br> Sie können Daten lesen, ändern oder an den nächsten Filter übergeben.
Geben Sie das Verarbeitungsergebnis zurück und führen Sie den Filtervorgang aus
Das folgende Beispiel zeigt, wie Sie einen einfachen benutzerdefinierten Stream -Filter definieren, den Datenblock über stream_bucket_make_writable in der Filtermethode lesen und den Inhalt ausdrucken:
<?php
class MyReadFilter extends php_user_filter {
public function filter($in, $out, &$consumed, $closing) {
// Alle Datenblöcke schleifen
while ($bucket = stream_bucket_make_writeable($in)) {
// Lesen bucket Daten in
$data = $bucket->data;
// 这里我们简单打印Lesen到的数据
echo "Lesen数据块内容: " . $data . "\n";
// Anzahl der von Markern konsumierten Bytes
$consumed += $bucket->datalen;
// Wille bucket Zum nächsten Filter oder Ausgangsstrom übergeben
stream_bucket_append($out, $bucket);
}
return PSFS_PASS_ON;
}
}
// Registrieren Sie einen benutzerdefinierten Filter
stream_filter_register("myreadfilter", "MyReadFilter") or die("Failed to register filter");
// Beispiel für die Nutzung：从文件流中Lesen数据并应用过滤器
$fp = fopen("gitbox.net/sample.txt", "r");
// Fügen Sie einen benutzerdefinierten Filter am Stream bei
stream_filter_append($fp, "myreadfilter", STREAM_FILTER_READ);
// Lesen文件内容，Löst den Filter aus filter Verfahren
while (!feof($fp)) {
fread($fp, 8192);
}
fclose($fp);
?>
stream_bucket_make_writable ($ in) : Nehmen Sie einen Eimer aus der Eingabebucket -Liste heraus und geben Sie ihn zurück. Das zurückgegebene Bucket -Objekt enthält die Eigenschaftendaten (String -Daten) und Datalen (Datenlänge).
Nach dem Lesen der Daten müssen Sie Stream_bucket_Append ($ out, $ bucket) aufrufen, um den Bucket an die Ausgangskette zu übergeben, um die normale Ausführung der Stream -Verarbeitungskette sicherzustellen.
$ konsumiert wird verwendet, um den Stream -Filter zu mitteilen, wie viele Datenblöcke verzehrt werden, was sich auf die Verwaltung von Stream -Puffern auswirkt.
Der Filterrückgabewert wird im Allgemeinen verwendet, um PSFS_Pass_on zu verwenden, um die normale Datenübertragung anzuzeigen.
stream_bucket_make_writable ist die Kernschnittstelle zum Lesen von Stream -Datenblöcken im PHP -Stream -Filtermechanismus, mit dem Entwickler Daten direkt im Stream -Puffer manipulieren können. Durch benutzerdefinierte Stream-Filter können wir komplexe Datenverarbeitungslogik wie Echtzeitkomprimierung, Verschlüsselung, Protokollüberwachung usw. implementieren.
Durch das Beherrschen der zugrunde liegenden Datenblockabläufe von Streams können Sie bei der Verarbeitung großer Dateien und Netzwerkdaten mehr Flexibilität und Leistung erzielen.
Wenn Sie während der Entwicklung auf Leistungs Engpässe in Stream -Operationen stoßen oder in Streams eine feine Datenverarbeitung durchführen müssen, wird empfohlen, Stream_Bucket_Make_Writable und zugehörige Stream -Filter -APIs in der Tiefe zu lernen und anzuwenden.
