Deutsch
Deutsch
Die Funktion Socket_Set_Blocking in PHP wird verwendet, um den Blockierungsmodus einer Socket -Ressource festzulegen:
Blockierungsmodus: Wenn Sie Socket-bezogene Funktionen aufrufen, warten Sie, bis der Betrieb abgeschlossen ist, und das Programm wird in diesem Zeitraum pausieren.
Nicht-Blocking-Modus: Gibt sofort beim Aufrufen von Socket-bezogenen Funktionen zurück und warten nicht, bis der Vorgang abgeschlossen ist.
Standardmäßig blockiert Socket. Der Blockierungsmodus eignet sich für einfache Synchronisationsszenarien, aber für Hochleistungsserver ist jedoch ein detaillierterer Steuerflussmechanismus erforderlich.
bool socket_set_blocking ( resource $socket , bool $mode )
$ Socket : Socket -Ressource.
$ modus : true bedeutet blockieren, falsch bedeutet nicht blockierend.
Control Flow verwaltet den Senden- und Empfangen -Rhythmus von Nachrichten, um zu verhindern, dass Nachrichten zu schnell gesendet werden, was zu einer Überlastung von Netzwerk, übermäßiger Ressourcenverwendung oder Nachrichtenverlust führt. Entwürfe mit Kontrollfluss können erreichen:
Warteschlangennachrichtenpufferung, Schritt für Schritt senden.
Wechseln Sie dynamisch zwischen Blockierung und nicht blockierenden Modi.
Timeout -Handhabung und Fehlermechanismus.
Sowohl der Server als auch der Client verwenden den Blockierungsmodus, um die Stabilität des Sendens und Empfangens zu gewährleisten.
Warten Sie die Sende und senden Sie sie nur dann, wenn Daten im Sendepuffer vorhanden sind, um zu verhindern, dass Blockierung und Warten verhindern.
Der Empfänger setzt eine angemessene Zeitüberschreitung, um langfristige Hänge zu vermeiden.
Verwenden Sie Socket_Select , um Multiplexing zu erreichen, Lesen und Schreiben von Ereignissen zu überwachen und die Effizienz zu verbessern.
Das Folgende ist ein vereinfachtes TCP-basierter PHP-Socket-Server-Beispiel, in dem zeigt, wie man Socket_Set_Blocking zum Steuerungsblockierungsmodus verwendet, um die Flusssteuerung von Messaging zu realisieren:
<?php
$host = "0.0.0.0";
$port = 12345;
// erstellensocket
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($sock, $host, $port);
socket_listen($sock);
echo "Server started at $host:$port\n";
// Überwachung einrichtensocketIm Blockierungsmodus，Warten auf den Kunden beim Annehmen von Verbindung
socket_set_blocking($sock, true);
$clients = [];
while (true) {
// verwenden socket_select Hören Sie sich aktive Verbindungen an
$read = $clients;
$read[] = $sock; // Schließen Sie sich dem Monitor beisocket
$write = [];
$except = null;
// Blockieren des Wartens auf Aktivitätsocket
if (socket_select($read, $write, $except, 5) < 1) {
continue; // Zeitüberschreitung keine Aktivität
}
// Neue Verbindungen verarbeiten
if (in_array($sock, $read)) {
$newClient = socket_accept($sock);
if ($newClient !== false) {
socket_set_blocking($newClient, true); // Einrichten des KundensocketZum Blockieren，Garantierte vollständige Nachricht
$clients[] = $newClient;
echo "New client connected\n";
}
unset($read[array_search($sock, $read)]);
}
// Verarbeiten Sie vorhandene Clientnachrichten
foreach ($read as $client) {
$data = socket_read($client, 2048, PHP_NORMAL_READ);
if ($data === false || $data === '') {
// Kundenentzündung
echo "Client disconnected\n";
socket_close($client);
unset($clients[array_search($client, $clients)]);
continue;
}
$data = trim($data);
echo "Received: $data\n";
// Einfaches Echo，Mit Flussregelung：Stellen Sie sicher, dass Sie vor dem Senden sicherstellensocketBlockierungsmodus，Verhindern Sie Schreibfehler
socket_set_blocking($client, true);
$sendResult = socket_write($client, "Echo: $data\n");
if ($sendResult === false) {
echo "Failed to send message to client\n";
}
}
}
Schalten des Blockierungsmodus <br> Sowohl der Hörbuchsen als auch der Client-Socket sind auf Blockierung eingestellt, sodass die Integrität der Daten beim Lesen und Schreiben von Daten garantiert werden kann und unvollständige Nachrichten aufgrund kurzer Lesen und Kurzgeschrieben im nicht blockierenden Modus vermeiden kann.
Socket_Select Hören Sie Multiplexing
Socket_Select -Blöcke und wartet darauf, dass ein Sockel lesbar ist, die CPU -Nutzung verbessert und die Verschwendung von Ressourcen in einer toten Schleife vermeidet.
Message Warteschlangesteuerung (extensible)
Obwohl es direkt im Beispiel gelesen und geschrieben wird, kann eine Meldungswarteschlange nach Bedarf hinzugefügt werden, um die Größe und Häufigkeit jeder gesendeten Nachricht zu steuern, um die Stauung des Client -Netzwerks zu vermeiden.
Verwenden Sie den nicht blockierenden Modus, um mit ereignisorientierten Bibliotheken (wie Libvent) zusammenzuarbeiten, um die hohe Parallelitätsleistung zu verbessern.
Führen Sie die Seriennummer und den Bestätigungsmechanismus zur Nachricht ein, um die Integrität der Nachrichtenübertragung sicherzustellen.
Implementieren Sie den Status des Herzschlag -Paket -Erkennung.
Verwenden Sie Socket_Set_Option , um die TCP -Parameter zu optimieren, z. B. das Einstellen von TCP_Nodelay, um die Latenz zu reduzieren.
Durch rationales Gebrauch von PHPs Socket_Set_Blocking -Funktion und Kombination des Socket_Select -Ereignis -Hörmechanismus kann ein effizientes Messaging und ein Empfangssystem mit Steuerfluss erstellt werden. Der Steuerfluss gewährleistet nicht nur die Stabilität der Nachrichtenübertragung, sondern verbessert auch die Reaktionsgeschwindigkeit und die Ressourcenauslastung des Systems. Ich hoffe, die Beispiele und Ideen dieses Artikels werden Ihnen beim Erstellen Ihres eigenen Nachrichtensystems hilfreich sein.
