Comment mettre en œuvre le transfert de messages en temps réel et le stockage des enregistrements de discussion via Workerman

Comment mettre en œuvre le stockage de messages push et de chat en temps réel via Workerman

Avec le développement rapide d'Internet, les fonctions de push de messages et de chat en temps réel sont devenues des fonctions de base requises par de nombreuses applications. Workerman, en tant que framework de service PHP Socket hautes performances, nous fournit une méthode simple et efficace pour implémenter le push de messages en temps réel et le stockage des enregistrements de discussion. Cet article explique comment implémenter ces fonctions via Workererman.

Tout d'abord, nous devons préciser que notre objectif est de mettre en œuvre un système de transmission de messages en temps réel et un système de stockage des enregistrements de discussion. L'objectif du système de diffusion de messages en temps réel est de transmettre le message à un utilisateur spécifique en temps réel après que l'utilisateur a envoyé le message, tandis que l'objectif du système de stockage des enregistrements de conversation est de stocker de manière persistante les enregistrements de discussion de l'utilisateur pour référence future.

Ensuite, nous devons créer un environnement de travail. Tout d'abord, nous devons installer les dépendances de Workererman, ce qui peut être fait via Composer. Exécutez la commande suivante dans la ligne de commande :

composer require workerman/workerman

Une fois l'installation terminée, nous pouvons créer un fichier de démarrage Workerman, par exemple, nommé start.php. Dans ce fichier, nous devons introduire les classes Workerman's Autoloader et Worker, puis créer un objet Worker. L'exemple de code est le suivant : 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) {
    // 当用户断开时执行的逻辑，比如更新用户在线状态等
};

Dans cet exemple, nous créons un objet Worker et définissons le port d'écoute sur 2346. Le protocole WebSocket est utilisé ici pour la communication, car le protocole WebSocket peut réaliser une communication bidirectionnelle en temps réel. Bien entendu, vous pouvez également choisir d’autres protocoles, tels que la connexion longue HTTP ou le Socket TCP.

Ensuite, nous devons écrire du code de logique métier spécifique. Tout d’abord, nous devons gérer les connexions et déconnexions des utilisateurs. Ceci peut être réalisé en utilisant les méthodes onConnect et onClose de l'objet Worker. L'exemple de code est le suivant :

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

Dans cet exemple, lorsqu'un utilisateur est connecté, la méthode onConnect sera appelée ; lorsque l'utilisateur se déconnectera, la méthode onClose sera appelée. Nous pouvons ici effectuer une certaine logique, comme l'enregistrement des informations sur l'utilisateur ou la mise à jour du statut en ligne de l'utilisateur.

Ensuite, nous devons gérer le push des messages des utilisateurs. Ceci peut être réalisé en utilisant la méthode onMessage de l'objet Worker. L'exemple de code est le suivant :

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

Dans cet exemple, la méthode onMessage est appelée lorsqu'un message de l'utilisateur est reçu. Nous pouvons effectuer une certaine logique ici, comme envoyer des messages à des utilisateurs spécifiques.

Dans le même temps, afin de mettre en œuvre la fonction de stockage des enregistrements de discussion, nous devons utiliser une base de données pour stocker les enregistrements de discussion de l'utilisateur. Vous pouvez choisir MySQL ou d'autres bases de données. Après avoir reçu le message de l'utilisateur, nous stockons le message dans la base de données. L'exemple de code est le suivant :

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

Dans cet exemple, nous utilisons la fonction json_decode pour analyser le message de l'utilisateur dans un tableau, puis stocker le message dans la base de données. L'implémentation spécifique ici doit être codée en conséquence en fonction de la base de données que vous choisissez.

Lorsque nous transmettons des messages à des utilisateurs spécifiques, nous pouvons utiliser l'implémentation de Workererman's Gateway. La passerelle peut transmettre des messages à des connexions ou à des groupes spécifiques. L'exemple de code est le suivant :

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));
}

Dans cet exemple, nous utilisons la méthode Gateway::sendToUid pour transmettre le message à un utilisateur spécifique. Le $uid ici est l'identifiant unique de l'utilisateur, qui peut être généré selon les besoins lorsque l'utilisateur se connecte.

Enfin, afin de permettre au front-end de communiquer avec le serveur, nous devons écrire du code front-end. Vous pouvez utiliser l'API WebSocket pour communiquer avec le serveur. L'exemple de code est le suivant :

rrreee

Dans cet exemple, nous utilisons l'API WebSocket pour créer un objet WebSocket et spécifier l'adresse et le port de connexion. Ensuite, les événements onopen, onmessage et onclose peuvent être utilisés pour gérer le succès de la connexion, la réception des messages et la déconnexion de la connexion. Dans le même temps, des messages peuvent être envoyés au serveur via la méthode socket.send.

Pour résumer, grâce à Workerman, nous pouvons facilement mettre en œuvre les fonctions de transmission de messages en temps réel et de stockage des enregistrements de discussion. Il convient de noter qu'il ne s'agit que d'un exemple simple et que la mise en œuvre réelle peut nécessiter la prise en compte de plus de détails, tels que l'authentification de l'identité de l'utilisateur, la gestion des groupes, les stratégies de transmission de messages, etc. Mais grâce au cadre de service Socket hautes performances fourni par Workerman, nous pouvons facilement mettre en œuvre ces fonctions et les étendre et les optimiser de manière flexible en fonction des besoins. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!