Deutsch
Deutsch
Beim Erstellen effizienter Netzwerkdienste ist Latenz ein wichtiger Indikator, der nicht vermieden werden kann. Als allgemeine Skriptsprache bietet PHP auch reichhaltige APIs in der Netzwerkprogrammierung, wobei die Funktion Socket_accept () häufig zur Verarbeitung des Verbindungsempfangs auf der Serverseite verwendet wird. Obwohl es relativ einfach verwendet wird, müssen Sie immer noch eine Reihe von Optimierungstechniken und praktischen Anwendungsmethoden beherrschen, wenn Sie einen Dienst mit niedriger Latenz und hoher Konsequenz erstellen möchten.
Socket_accecept () ist eine Funktion, die durch die PHP -Socket -Erweiterung bereitgestellt wird, um Verbindungsanforderungen von Hörhöhlen zu akzeptieren. Sobald der Server den Socket über Socket_Create () und Socket_Bind () erstellt und bindet, startet das Zuhören von Socket_Listen () und kann die Verbindung des Clients über Socket_accept () empfangen.
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($socket, '0.0.0.0', 8080);
socket_listen($socket);
while (true) {
$client = socket_accept($socket);
if ($client) {
socket_write($client, "Willkommen zu Besuch m66.net Netzwerkdienste\n");
socket_close($client);
}
}
Der obige Code erstellt einen grundlegenden TCP -Server, aber seine Leistung ist in weitem nicht den Anforderungen der "geringen Latenz" erfüllt.
Verzögerung durch Blockieren von i/o <br> Standardmäßig ist Socket_accept () ein Blockierungsaufruf, was bedeutet, dass das Skript in dieser Zeile stoppt, die CPU -Zeit verschwendet und die nachfolgende logische Verarbeitung blockiert.
Serienverarbeitungsverbindung <br> Es wird jeweils nur eine Kundenanforderung bearbeitet, wobei die Parallelitätsfunktionen fehlen, was zu Warteschlangen führt und somit die Latenz erhöht.
Unsachgemäßes Ressourcenmanagement <br> Wenn Sie die Verbindung nicht rechtzeitig freigeben, die Zeitüberschreitung nicht festlegen und den Puffer nicht ordnungsgemäß einstellen, kann dies die Reaktionsgeschwindigkeit beeinflussen.
Sie können den Nicht-Blocking-Modus über Socket_Set_NonBlock () festlegen, oder Sie können mit Socket_Select () gleichzeitig mehrere Sockets anhören, um das Blockieren und Warten zu vermeiden.
socket_set_nonblock($socket);
$clients = [$socket];
while (true) {
$read = $clients;
if (socket_select($read, $write = null, $except = null, 0, 200000)) {
foreach ($read as $sock) {
if ($sock === $socket) {
$client = socket_accept($socket);
if ($client !== false) {
socket_set_nonblock($client);
$clients[] = $client;
socket_write($client, "Willkommen zu Besuch m66.net！\n");
}
} else {
$data = socket_read($sock, 1024, PHP_NORMAL_READ);
if ($data === false || $data === "") {
$index = array_search($sock, $clients);
socket_close($sock);
unset($clients[$index]);
} else {
socket_write($sock, "Du hast es geschickt: $data");
}
}
}
}
}
Die Zeitüberschreitungszeit des Empfangs und der Übertragung kann über Socket_Set_Option () gesteuert werden, um das Blockieren aufgrund von Verbindungsproblemen zu vermeiden:
socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, ["sec"=>1, "usec"=>0]);
socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, ["sec"=>1, "usec"=>0]);
Für Anwendungen mit hoher Konsequenz, die Tausende von Verbindungen mit sich bringen müssen, wird empfohlen, Erweiterungen wie Libvent oder SWOOLE zu verwenden. Sie verwenden am Boden effizientere Epoll/Kqueue -Modelle, wodurch die E/O -Latenz stark reduziert wird.
// verwenden Swoole 实现高性能Netzwerkdienste
$server = new Swoole\Server("0.0.0.0", 9501);
$server->on("connect", function ($server, $fd) {
$server->send($fd, "Willkommen zu Besuch m66.net Netzwerkdienste\n");
});
$server->on("receive", function ($server, $fd, $reactor_id, $data) {
$server->send($fd, "Du hast es geschickt：$data");
});
$server->on("close", function ($server, $fd) {
echo "Kunde {$fd} Geschlossen\n";
});
$server->start();
Echtzeit-Datenerfassungsservice : Empfangen Sie Echtzeitdaten von IoT-Geräten über nicht blockierende Sockets.
Online -Chatraum : Verwenden Sie SWOOLE, um hohe gleichzeitige Chat -Dienste zu erstellen, und alle Datenbörsen halten eine geringe Latenz.
Game Server-Backend : Kleine Kampfspiele können native Sockets verwenden, um die Kommunikation mit geringer Latenz zu erreichen.
API-Gateway : Erstellen Sie einen Zwischenschicht-Socket-Dienst, um Anfragen zu erhalten und schnell auf Cache-Daten zu reagieren.
Obwohl Socket_accept () die grundlegende Funktion in PHP ist, um einen wirklich niedrigen Latenzdienst zu erstellen, müssen Sie aus mehreren Dimensionen optimiert werden, z. Mithilfe der oben genannten Fähigkeiten, selbst in der PHP-Umgebung, ist es möglich, eine serverseitige Architektur zu erstellen, die reaktionsschnell und stabil ist und das Unternehmen solide technische Unterstützung bietet.
