So implementieren Sie Echtzeit-Nachrichten-Push und Chat-Datensatzspeicherung über Workerman

So implementieren Sie die Echtzeit-Nachrichten-Push- und Chat-Datensatzspeicherung über Workerman

Mit der rasanten Entwicklung des Internets sind Echtzeit-Nachrichten-Push- und Chat-Funktionen zu Grundfunktionen geworden, die von vielen Anwendungen benötigt werden. Workerman bietet uns als leistungsstarkes PHP-Socket-Service-Framework eine einfache und effektive Methode zur Implementierung von Nachrichten-Push und Chat-Datensatzspeicherung in Echtzeit. In diesem Artikel wird erläutert, wie diese Funktionen über Workerman implementiert werden.

Zunächst müssen wir klarstellen, dass unser Ziel darin besteht, ein Echtzeit-Nachrichten-Push-System und ein System zur Speicherung von Chat-Datensätzen zu implementieren. Das Ziel des Echtzeit-Nachrichten-Push-Systems besteht darin, die Nachricht in Echtzeit an einen bestimmten Benutzer zu senden, nachdem der Benutzer die Nachricht gesendet hat, während das Ziel des Chat-Datensatzspeichersystems darin besteht, die Chat-Datensätze des Benutzers zur späteren Bezugnahme dauerhaft zu speichern.

Als nächstes müssen wir eine Arbeitsumgebung aufbauen. Zuerst müssen wir die Abhängigkeiten von workerman installieren, was über Composer erfolgen kann. Führen Sie den folgenden Befehl in der Befehlszeile aus:

composer require workerman/workerman

Nachdem die Installation abgeschlossen ist, können wir eine Workerman-Startdatei erstellen, beispielsweise mit dem Namen start.php. In dieser Datei müssen wir die Autoloader- und Worker-Klassen von Workerman einführen und dann ein Worker-Objekt erstellen. Der Beispielcode lautet wie folgt: start.php。在这个文件中，我们需要引入workerman的Autoloader和Worker类，然后创建一个Worker对象。示例代码如下：

<?php
require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;

$worker = new Worker();
// 设置监听的端口
$worker->listen('websocket://0.0.0.0:2346');

Worker::runAll();

在这个示例中，我们创建了一个Worker对象，并设置监听的端口为2346

$worker->onConnect = function($connection) {
    // 当用户连接时执行的逻辑，比如记录用户信息等
};

$worker->onClose = function($connection) {
    // 当用户断开时执行的逻辑，比如更新用户在线状态等
};

In diesem Beispiel erstellen wir ein Worker-Objekt und setzen den Überwachungsport auf 2346. Für die Kommunikation wird hier das WebSocket-Protokoll verwendet, da das WebSocket-Protokoll eine bidirektionale Echtzeitkommunikation erreichen kann. Natürlich können Sie auch andere Protokolle wählen, z. B. HTTP Long Connection oder TCP Socket.

Als nächstes müssen wir spezifischen Geschäftslogikcode schreiben. Zuerst müssen wir Benutzerverbindungen und -trennungen verwalten. Dies kann mit den Methoden onConnect und onClose des Worker-Objekts erreicht werden. Der Beispielcode lautet wie folgt:

$worker->onMessage = function($connection, $data) {
    // 当收到用户的消息时执行的逻辑，比如向特定用户推送消息等
};

Wenn in diesem Beispiel ein Benutzer verbunden ist, wird die onConnect-Methode aufgerufen. Wenn der Benutzer die Verbindung trennt, wird die onClose-Methode aufgerufen. Wir können hier eine gewisse Logik ausführen, z. B. das Aufzeichnen von Benutzerinformationen oder das Aktualisieren des Online-Status des Benutzers.

Als nächstes müssen wir den Push von Benutzernachrichten verarbeiten. Dies kann mit der onMessage-Methode des Worker-Objekts erreicht werden. Der Beispielcode lautet wie folgt:

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 将消息存储到数据库中
    // ...
    // 向特定用户推送消息
    // ...
};

In diesem Beispiel wird die onMessage-Methode aufgerufen, wenn eine Nachricht vom Benutzer empfangen wird. Wir können hier eine gewisse Logik ausführen, z. B. das Senden von Nachrichten an bestimmte Benutzer.

Gleichzeitig müssen wir zur Implementierung der Chat-Datensatzspeicherfunktion eine Datenbank verwenden, um die Chat-Datensätze des Benutzers zu speichern. Sie können MySQL oder andere Datenbanken wählen. Nachdem wir die Nachricht vom Benutzer erhalten haben, speichern wir die Nachricht in der Datenbank. Der Beispielcode lautet wie folgt:

$worker->onMessage = function($connection, $data) {
    // 解析用户的消息
    $message = json_decode($data, true);
    // 向特定用户推送消息
    $uid = $message['uid'];
    Gateway::sendToUid($uid, $data);
};

In diesem Beispiel verwenden wir die Funktion json_decode, um die Nachricht des Benutzers in ein Array zu analysieren und die Nachricht dann in der Datenbank zu speichern. Die spezifische Implementierung hier muss entsprechend der von Ihnen gewählten Datenbank entsprechend codiert werden.

Beim Senden von Nachrichten an bestimmte Benutzer können wir die Gateway-Implementierung von workererman verwenden. Gateway kann Nachrichten an bestimmte Verbindungen oder Gruppen senden. Der Beispielcode lautet wie folgt:

var socket = new WebSocket('ws://localhost:2346');

socket.onopen = function() {
    // 连接成功时执行的逻辑
};

socket.onmessage = function(event) {
    var data = JSON.parse(event.data);
    // 收到消息时执行的逻辑
};

socket.onclose = function() {
    // 连接断开时执行的逻辑
};

// 发送消息
function sendMsg(message) {
    socket.send(JSON.stringify(message));
}

In diesem Beispiel verwenden wir die Methode Gateway::sendToUid, um die Nachricht an einen bestimmten Benutzer zu senden. Die $uid ist hier die eindeutige Kennung des Benutzers, die bei Bedarf generiert werden kann, wenn der Benutzer eine Verbindung herstellt.

Um dem Front-End die Kommunikation mit dem Server zu ermöglichen, müssen wir schließlich einen Front-End-Code schreiben. Sie können die WebSocket-API verwenden, um mit dem Server zu kommunizieren. Der Beispielcode lautet wie folgt:

rrreee

In diesem Beispiel verwenden wir die WebSocket-API, um ein WebSocket-Objekt zu erstellen und die Verbindungsadresse und den Port anzugeben. Anschließend können die Ereignisse onopen, onmessage und onclose verwendet werden, um den Verbindungserfolg, den Nachrichtenempfang und die Verbindungstrennung zu verwalten. Gleichzeitig können Nachrichten über die Methode socket.send an den Server gesendet werden.

Zusammenfassend lässt sich sagen, dass wir mit Workerman die Funktionen des Echtzeit-Nachrichten-Push und der Speicherung von Chat-Datensätzen problemlos implementieren können. Es ist zu beachten, dass dies nur ein einfaches Beispiel ist und die tatsächliche Implementierung möglicherweise die Berücksichtigung weiterer Details erfordert, wie z. B. Benutzeridentitätsauthentifizierung, Gruppenverwaltung, Nachrichten-Push-Strategien usw. Durch das von Workerman bereitgestellte leistungsstarke Socket-Service-Framework können wir diese Funktionen jedoch problemlos implementieren und je nach Bedarf flexibel erweitern und optimieren. 🎜

Das obige ist der detaillierte Inhalt vonSo implementieren Sie Echtzeit-Nachrichten-Push und Chat-Datensatzspeicherung über Workerman. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!