Deutsch
Deutsch
<span><span><span class="hljs-meta"><?php</span></span><span>
</span><span><span class="hljs-comment">// Dieser Teil des Codes hat nichts mit dem Inhalt des Artikels zu tun，Nur zur Demonstration</span></span><span>
</span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"Initialisierung der Verbindung...\n"</span></span><span>;
</span><span><span class="hljs-meta">?></span></span><span>
---
</span><span><span class="hljs-comment"># pfsockopen So verarbeiten und empfangen Sie Big Data Streams nach der Verbindung effizient？</span></span><span>
existierenPHPMitte，`pfsockopen` ist eine Funktion zum Herstellen anhaltender Verbindungen，Geeignet für die Handhabungsszenarien, die eine langfristige Verbindung erfordern。尤其existieren处理大数据流时，Angemessene Verwendung `pfsockopen` Kann die Leistung und Stabilität des Programms erheblich verbessern。Dieser Artikel wird aus der Verbindung hergestellt、Daten lesen、Pufferkontrolle und Ausnahmebehandlung，Besprechen Sie, wie Sie Big -Data -Streams effizient verarbeiten und empfangen können。
</span><span><span class="hljs-comment">## 1. verwenden pfsockopen Eine anhaltende Verbindung herstellen</span></span><span>
Der Vorteil einer anhaltenden Verbindung besteht darin, dass die Verbindung einmal hergestellt wird，Anfordern von Multiplexed -Verbindungen，reduzierenTCPHandschlag über Kopf。Die Anrufmethode lautet wie folgt：
```php
</span><span><span class="hljs-variable">$fp</span></span><span> = </span><span><span class="hljs-title function_ invoke__">pfsockopen</span></span><span>(</span><span><span class="hljs-variable">$host</span></span><span>, </span><span><span class="hljs-variable">$port</span></span><span>, </span><span><span class="hljs-variable">$errno</span></span><span>, </span><span><span class="hljs-variable">$errstr</span></span><span>, </span><span><span class="hljs-variable">$timeout</span></span><span>);
</span><span><span class="hljs-keyword">if</span></span><span> (!</span><span><span class="hljs-variable">$fp</span></span><span>) {
</span><span><span class="hljs-keyword">die</span></span><span>(</span><span><span class="hljs-string">"Verbindung ist fehlgeschlagen: <span class="hljs-subst">$errstr</span></span></span><span> (</span><span><span class="hljs-subst">$errno</span></span><span>)\n");
}
</span><span><span class="hljs-comment">// Setzen Sie den Nichtblockierungsmodus，Verbesserung der Reaktionsgeschwindigkeit</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_set_blocking</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>, </span><span><span class="hljs-literal">false</span></span><span>);
</span></span>Dies wird hier besonders betont, da der Blockierungsmodus das Programm beim Lesen des Big -Data -Streams hängt und andere Aufgaben beeinflusst.
Wenn Sie Big Data empfangen, kann das Lesen aller Daten leicht zu Speicherxplosion führen. Der vernünftige Ansatz ist das Lesen in Stücken:
<span><span><span class="hljs-variable">$bufferSize</span></span><span> = </span><span><span class="hljs-number">8192</span></span><span>; </span><span><span class="hljs-comment">// 8KBPuffergröße</span></span><span>
</span><span><span class="hljs-variable">$data</span></span><span> = </span><span><span class="hljs-string">''</span></span><span>;
</span><span><span class="hljs-keyword">while</span></span><span> (!</span><span><span class="hljs-title function_ invoke__">feof</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>)) {
</span><span><span class="hljs-variable">$chunk</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>, </span><span><span class="hljs-variable">$bufferSize</span></span><span>);
</span><span><span class="hljs-keyword">if</span></span><span> (</span><span><span class="hljs-variable">$chunk</span></span><span> === </span><span><span class="hljs-literal">false</span></span><span>) {
</span><span><span class="hljs-comment">// Fehlerbehandlung lesen</span></span><span>
</span><span><span class="hljs-keyword">break</span></span><span>;
}
</span><span><span class="hljs-variable">$data</span></span><span> .= </span><span><span class="hljs-variable">$chunk</span></span><span>;
</span><span><span class="hljs-comment">// Verarbeiten Sie jeden Datenblock，Zum Beispiel in eine Datei schreiben、Block nach Blockanalyse usw.</span></span><span>
}
</span></span>Dies ermöglicht die Verarbeitung beim Lesen von Daten und die Reduzierung des Speicherverbrauchs.
Die Standardpuffergröße und die Zeitlimit sind möglicherweise nicht für große Datenströmen geeignet. Ein geeignetes Zeitlimit kann über stream_set_timeout eingestellt werden:
<span><span><span class="hljs-title function_ invoke__">stream_set_timeout</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>, </span><span><span class="hljs-number">10</span></span><span>); </span><span><span class="hljs-comment">// aufstellen10Zweites Timeout</span></span><span>
</span></span>Und balancieren Sie den Geschwindigkeits- und Speicherverbrauch durch Einstellen der Puffergröße (z. B. Erhöhen der Leselänge von Fread ).
Wenn der Datenstrom Text oder strukturierte Daten ist, sollten Sie einen Stream -Filter für Datendecodierung oder Dekompression, Speichern der Übertragungszeit und Bandbreite verwenden. Zum Beispiel:
<span><span><span class="hljs-title function_ invoke__">stream_filter_append</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>, </span><span><span class="hljs-string">"zlib.inflate"</span></span><span>, STREAM_FILTER_READ);
</span></span>Auf diese Weise können Sie die dekomprimierten Daten direkt lesen.
Schließen Sie nach der Verwendung die Verbindung korrekt, um Ressourcenleckage zu vermeiden:
<span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$fp</span></span><span>);
</span></span>Insbesondere in anhaltenden Verbindungsszenarien ist es erforderlich, die rechtzeitige Freigabe von Ressourcen zu gewährleisten, um zu verhindern, dass der Verbindungspool überfüllt ist.
Bei der Verwendung von PFSoccKopen zur Verarbeitung von Big -Data -Streams sind die wichtigsten Punkte:
Verwenden Sie den nicht blockierenden Modus und eine angemessene Puffergröße.
Lesen Sie Daten in Teilen, um Speicherexplosionen zu vermeiden.
Die Kombination eines Durchflussfilters verbessert die Datenverarbeitungseffizienz;
Stellen Sie eine angemessene Auszeit ein, um zu vermeiden.
Schließen Sie die Verbindung rechtzeitig nach Abschluss.
Durch die obige Methode kann das PHP -Programm große Datenströme effizient und stabil verarbeiten und empfangen.
<span></span>
