Echtzeitkommunikation mit PHP und WebSocket

Mit der Entwicklung der Internettechnologie konzentrieren sich immer mehr Websites und Anwendungen auf die Realisierung von Echtzeitkommunikation. Das WebSocket-Protokoll gilt als effektive Möglichkeit, Echtzeitkommunikation zu erreichen. In diesem Artikel wird erläutert, wie Sie mithilfe von PHP und WebSocket Echtzeit-Kommunikationsfunktionen implementieren.

Was ist WebSocket? WebSocket ist ein TCP-basiertes Protokoll, das eine dauerhafte Verbindung zwischen dem Browser und dem Server herstellen kann, um eine bidirektionale Echtzeitkommunikation zu erreichen. Im Gegensatz zum HTTP-Protokoll ist das WebSocket-Protokoll ein Vollduplex-Protokoll. Es erfordert nicht, dass der Browser eine Anfrage sendet, um die Antwort des Servers zu empfangen, sondern kann direkt in beide Richtungen kommunizieren.

Da WebSocket eine lange Verbindungsmethode verwendet, kann es die Effizienz der Datenübertragung erheblich verbessern und die Belastung des Servers verringern. In Echtzeit-Kommunikationsszenarien ist WebSocket zu einer unverzichtbaren Technologie geworden.

PHP und WebSocket

PHP verfügt als serverseitige Sprache auch über einige Frameworks, die WebSocket unterstützen. Zu den bekannteren gehören das Rachet-Framework, das Swoole-Framework usw.

In diesem Artikel verwenden wir das Rachet-Framework, um Echtzeit-Kommunikationsfunktionen zu implementieren. Das Rachet-Framework ist ein Open-Source-Framework für PHP. Es bietet eine serverseitige Implementierung von WebSocket und kann eine Vielzahl von Webservern wie Apache, Nginx usw. unterstützen.

Implementierungsschritte

1. Installieren Sie das Rachet-Framework

Verwenden Sie Composer, um das Rachet-Framework zu installieren:

composer require cboden/ratchet

2. Schreiben Sie PHP-Code

Das Folgende ist ein einfacher PHP-Code, der das Rachet-Framework verwendet, um Echtzeitkommunikation zu erreichen :

<?php
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

require 'vendor/autoload.php';

class MyChat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new MyChat()
        )
    ),
    8080
);

$server->run();

Im Code ist eine Klasse namens MyChat definiert, die die MessageComponentInterface-Schnittstelle im Ratchet-Framework implementiert. Es enthält die folgenden 4 Methoden:

onMessage() Wird aufgerufen, wenn der Code eine Nachricht empfängt.
• onClose() Wird aufgerufen, wenn die Verbindung geschlossen wird.
onOpen() 当有新的连接建立时被调用。
• onMessage() 当代码接收到消息时被调用。
• onClose() 当连接被关闭时被调用。
• onError() 当出现错误时被调用。

其中，onOpen() 方法记录了新连接建立的信息，onMessage() 方法将接收到的消息广播给所有连接的客户端，而onClose() 方法记录连接关闭的信息。

最后，代码通过IoServer::factory()onError() Wird aufgerufen, wenn ein Fehler auftritt.

php chat-server.php

Das obige ist der detaillierte Inhalt vonEchtzeitkommunikation mit PHP und WebSocket. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!