Die Integration von PHP und WebSocket ermöglicht die Entwicklung eines Echtzeit-Chatrooms

Im Bereich der Webentwicklung erfreuen sich Echtzeit-Chat-Funktionen immer größerer Beliebtheit. Es hilft Benutzern, einfach in Echtzeit zu interagieren und die Kommunikation und das Verständnis zu verbessern. Um Echtzeit-Chat zu implementieren, müssen wir das WebSocket-Protokoll verwenden und benötigen eine Programmiersprache, die WebSocket-Anfragen verarbeiten kann. In diesem Artikel stellen wir vor, wie Sie die Entwicklung von Echtzeit-Chatrooms mithilfe der PHP- und WebSocket-Integration implementieren.

WebSocket ist ein Vollduplex-Kommunikationsprotokoll, das eine Echtzeit-Datenübertragung zwischen dem Browser und dem Server ermöglicht. Im Gegensatz zu HTTP-Anfragen kann der Server Daten an den Browser übertragen, nachdem die WebSocket-Verbindung hergestellt wurde. Daher können wir über WebSocket eine bidirektionale Datenkommunikation zwischen dem Client und dem Server durchführen. Wenn ein Benutzer dem Chatroom beitritt oder ihn verlässt, kann die Nachricht sofort an andere Online-Benutzer weitergeleitet werden. Dies ist das Grundprinzip des Echtzeit-Chats.

Zuerst müssen wir auf der Serverseite ein PHP-Skript erstellen, um WebSocket-Anfragen zu verarbeiten. Die Swoole-Erweiterung von PHP kann uns bei der Entwicklung von WebSocket-Servern helfen. Als nächstes werden wir unsere Chat-Anwendung Schritt für Schritt implementieren.

1. Installieren Sie die Swoole-Erweiterung

Um die Swoole-Erweiterung verwenden zu können, müssen wir sie zuerst installieren. Verwenden Sie den folgenden Befehl, um swoole in einem Linux-System zu installieren:

pecl install swoole

Wenn Sie PHP in einem Windows-System verwenden, können Sie die relevanten DLL-Dateien aus dem GitHub-Repository von swoole herunterladen und manuell installieren.

2. Richten Sie den WebSocket-Server ein

Sobald wir die Swoole-Erweiterung erfolgreich installiert haben, können wir damit beginnen, einen WebSocket-Server zu erstellen. Hier ist der grundlegende Code zum Erstellen eines WebSocket-Servers:

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

In diesem Codeausschnitt erstellen wir einen WebSocket-Server und registrieren die Event-Handler-Funktion. Im „open“-Ereignis geben wir die Meldung aus, dass die WebSocket-Verbindung geöffnet ist. Im „message“-Ereignis drucken wir Informationen über die WebSocket-Sitzung aus und senden eine Nachricht an den Client. Im „close“-Ereignis geben wir die Meldung aus, dass die WebSocket-Verbindung geschlossen ist.

3. Chatroom-Logik einrichten

Jetzt haben wir den WebSocket-Server erfolgreich erstellt und die Ereignisverarbeitungsfunktion eingerichtet. Als Nächstes können wir mit der Implementierung unserer Chatroom-Logik beginnen.

Wir müssen eine Nachrichtenübertragungsfunktion einrichten, um alle Online-Benutzer zu benachrichtigen, wenn ein Benutzer dem Chatroom beitritt oder ihn verlässt. Das Folgende ist der Code der Nachrichten-Broadcast-Funktion:

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

In diesem Codeausschnitt verwenden wir Switch-Anweisungen, um verschiedene Arten von Nachrichten zu verarbeiten. Wenn ein Benutzer dem Chatroom beitritt oder ihn verlässt, aktualisieren wir die Benutzerliste und senden eine Benachrichtigung. Wenn ein Benutzer eine Nachricht sendet, stellen wir der Nachricht den Benutzernamen voran und senden ihn an alle Online-Benutzer.

4. Vollständiger Chatroom-Code

Da wir nun alle notwendigen Komponenten bereit haben, können wir mit dem Schreiben des vollständigen Chatroom-Codes beginnen. Das Folgende ist ein vollständiger Chatroom-Code:

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//定义用户列表
$users = [];

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) use ($users) {
    broadcast($server, $frame, $users);
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) use ($users) {
    unset($users[$fd]);
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

In diesem Codeausschnitt speichern wir die Informationen aller Online-Benutzer im Array $users. Wir aktualisieren dieses Array, wenn ein Benutzer dem Chatroom beitritt oder ihn verlässt. Im WebSocket-Nachrichtenereignis senden wir die Nachricht mithilfe der Funktion „broadcast()“. Beim Schließen der WebSocket-Verbindung entfernen wir den getrennten Benutzer aus dem Array $users.

5. Testen Sie Ihren Chatroom

Jetzt haben wir unsere Chatroom-Anwendung erfolgreich erstellt. Wir können es in allen Browsern testen, die WebSocket unterstützen, wie Google Chrome, Firefox und Safari usw. Hier sind die Schritte zum Testen Ihres Chatrooms:

1. Führen Sie den obigen Code mit dem PHP-Befehl aus
2. Öffnen Sie die Datei index.html in Ihrem Browser
3. Geben Sie den Benutzernamen ein und klicken Sie auf die Schaltfläche „Chatroom betreten“
4. In Geben Sie Ihre Nachricht in das Chat-Feld ein und klicken Sie auf die Schaltfläche „Senden“

Sie sollten Ihre Nachricht im Chat-Feld aller Online-Benutzer sehen können.

Zusammenfassung

In diesem Artikel haben wir vorgestellt, wie die Entwicklung von Echtzeit-Chatrooms mithilfe der PHP- und WebSocket-Integration implementiert wird. Wir haben die Swoole-Erweiterung verwendet, um einen WebSocket-Server zu erstellen und eine einfache Chatroom-Anwendung zu schreiben. In diesem Artikel erfahren Sie, wie Sie mit dem WebSocket-Protokoll eine Echtzeit-Datenübertragungsverbindung herstellen, einen WebSocket-Server in PHP implementieren und damit eine Chatroom-Anwendung implementieren.

Das obige ist der detaillierte Inhalt vonDie Integration von PHP und WebSocket ermöglicht die Entwicklung eines Echtzeit-Chatrooms. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!