So verwenden Sie Swoole zum Implementieren der WebSocket-Server- und Datenbankinteraktion

So verwenden Sie Swoole zum Implementieren der WebSocket-Server- und Datenbankinteraktion

Einführung:
WebSocket ist ein Vollduplex-Kommunikationsprotokoll, das auf dem TCP-Protokoll basiert und eine bidirektionale Echtzeitkommunikation zwischen dem Client und dem Server herstellen kann . Swoole ist eine PHP-Erweiterung, die problemlos leistungsstarke asynchrone und gleichzeitige Programmierung implementieren kann. In diesem Artikel stellen wir detailliert vor, wie man mit Swoole einen WebSocket-Server erstellt und mit der Datenbank interagiert.

Schritt 1: Installieren Sie die Swoole-Erweiterung

Zuerst müssen wir die Swoole-Erweiterung installieren. Es kann über den folgenden Befehl installiert werden:

pecl install swoole

Schritt 2: Erstellen Sie einen WebSocket-Server

Als nächstes erstellen wir einen WebSocket-Server, überwachen den angegebenen Port und stellen eine Verbindung mit dem Client her. Dies kann mit dem folgenden Code erreicht werden:

<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new connection open: {$request->fd}
";
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
    
    // 处理数据库交互
    $db = new mysqli('localhost', 'username', 'password', 'database');
    $result = $db->query("SELECT * FROM users");
    while ($row = $result->fetch_assoc()) {
        $server->push($frame->fd, json_encode($row));
    }
    $db->close();
});

$server->on('close', function ($ser, $fd) {
    echo "connection close: {$fd}
";
});

$server->start();
?>

Im obigen Code erstellen wir einen WebSocket-Server und fügen drei Ereignis-Callback-Funktionen hinzu. Wenn eine Verbindung hergestellt wird, wird das Ereignis open ausgelöst; wenn eine Nachricht empfangen wird, wird das Ereignis message ausgelöst, wenn die Verbindung geschlossen wird; close Ereignis wird ausgelöst >Das Ereignis wird ausgelöst. Im message-Ereignis können wir interaktive Datenbankoperationen durchführen. open事件将被触发；当收到消息时，message事件将被触发；当连接关闭时，close事件将被触发。在message事件中，我们可以进行数据库的交互操作。

步骤三：与数据库交互

在message事件回调函数中，我们使用了MySQLi扩展来与数据库进行交互。首先，我们创建了一个$db对象，并使用mysqli的构造函数连接到数据库。接着，我们执行了一条查询语句，并通过while循环将查询结果发送给客户端。最后，我们关闭了数据库连接。

需要注意的是，为了安全起见，我们应该将数据库的相关信息（如用户名和密码）设置为环境变量，并通过getenv()函数来获取这些值，以避免直接暴露在代码中。

步骤四：运行服务器

最后，我们使用命令行来运行上述代码。在命令行中切换到代码所在的目录，并执行以下命令：

php server.php

如果一切正常，你将看到WebSocket服务器成功启动，并等待客户端的连接。当有客户端连接到服务器时，open事件将被触发，并在命令行中显示连接的ID。当收到客户端发来的消息时，message事件将被触发，并在命令行中显示收到的消息。当连接关闭时，close事件将被触发，同样在命令行中显示连接的关闭。

总结：
本文详细介绍了如何使用Swoole实现WebSocket服务器与数据库的交互。通过创建WebSocket服务器，并在message

Schritt 3: Mit der Datenbank interagieren 🎜🎜In der Ereignisrückruffunktion message verwenden wir die MySQLi-Erweiterung, um mit der Datenbank zu interagieren. Zuerst erstellen wir ein $db-Objekt und verwenden den Konstruktor von mysqli, um eine Verbindung zur Datenbank herzustellen. Als Nächstes haben wir eine Abfrageanweisung ausgeführt und die Abfrageergebnisse über eine while-Schleife an den Client gesendet. Abschließend schließen wir die Datenbankverbindung. 🎜🎜Es ist zu beachten, dass wir aus Sicherheitsgründen die datenbankbezogenen Informationen (wie Benutzername und Passwort) als Umgebungsvariablen festlegen und diese Werte über die Funktion getenv() erhalten sollten, um dies zu vermeiden direkt im Code verfügbar gemacht. 🎜🎜Schritt 4: Starten Sie den Server🎜🎜Abschließend verwenden wir die Befehlszeile, um den obigen Code auszuführen. Wechseln Sie in der Befehlszeile in das Verzeichnis, in dem sich der Code befindet, und führen Sie den folgenden Befehl aus: 🎜rrreee🎜 Wenn alles gut geht, werden Sie sehen, dass der WebSocket-Server erfolgreich gestartet ist und auf die Verbindung des Clients wartet. Wenn ein Client eine Verbindung zum Server herstellt, wird das Ereignis open ausgelöst und die Verbindungs-ID wird in der Befehlszeile angezeigt. Wenn eine Nachricht vom Client empfangen wird, wird das Ereignis message ausgelöst und die empfangene Nachricht wird in der Befehlszeile angezeigt. Beim Schließen der Verbindung wird das Ereignis close ausgelöst und das Schließen der Verbindung auch in der Kommandozeile angezeigt. 🎜🎜Zusammenfassung: 🎜Dieser Artikel beschreibt, wie Swoole verwendet wird, um die Interaktion zwischen dem WebSocket-Server und der Datenbank zu implementieren. Durch die Erstellung eines WebSocket-Servers und die Durchführung einer Datenbankinteraktion in der Ereignisrückruffunktion message können wir eine bidirektionale Kommunikation in Echtzeit erreichen. Mit Swoole-Erweiterungen können wir problemlos asynchrone und gleichzeitige Hochleistungsprogrammierung durchführen. Ich hoffe, dieser Artikel wird Ihnen bei der Verwendung von Swoole für die Interaktion mit der Datenbank hilfreich sein. 🎜

Das obige ist der detaillierte Inhalt vonSo verwenden Sie Swoole zum Implementieren der WebSocket-Server- und Datenbankinteraktion. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!