Comment utiliser Workererman pour envoyer et recevoir des messages en temps réel

Comment utiliser Workererman pour envoyer et recevoir des messages en temps réel

Avec le développement rapide d'Internet, l'envoi de messages en temps réel est devenu une exigence pour de nombreuses applications. Dans les implémentations précédentes, le serveur était généralement interrogé pour vérifier s'il y avait de nouveaux messages, puis envoyé. Cette méthode est non seulement inefficace, mais augmente également la charge sur le serveur. Il existe désormais un moyen plus efficace de le mettre en œuvre, qui consiste à utiliser le framework Workerman pour obtenir la transmission et la réception de messages en temps réel.

Workerman est un framework PHP événementiel hautes performances conçu pour résoudre le problème selon lequel PHP ne peut pas maintenir de longues connexions. Il utilise l'implémentation d'E/S asynchrone non bloquante de PHP et peut gérer un grand nombre de connexions simultanées pour permettre l'envoi et la réception de messages en temps réel.

Voici les étapes et les exemples de code pour utiliser Workererman pour implémenter l'envoi et la réception de messages en temps réel :

1. Installer Workererman

Tout d'abord, Workererman doit être installé sur le serveur. Vous pouvez utiliser composer pour l'installer avec la commande suivante :

composer require workerman/workerman

2. Créer un serveur push de messages

Ensuite, créez un fichier PHP nommé push_server.php comme serveur push de messages.

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

use WorkermanWorker;

$pusher = new Worker();
$pusher->count = 4;

$pusher->onWorkerStart = function ($pusher) {
    $inner_ws = new Worker('websocket://127.0.0.1:8000');
    
    $inner_ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $inner_ws->onMessage = function ($connection, $data) use ($pusher) {
        echo "Received message: $data
";
        
        // 接收到消息后，将消息推送给所有在线客户端
        foreach ($pusher->connections as $client) {
            $client->send($data);
        }
    };
    
    $inner_ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

3. Créez un serveur de réception de messages

Ensuite, créez un fichier PHP nommé recevoir_server.php comme serveur de réception de messages.

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

use WorkermanWorker;

$receiver = new Worker();
$receiver->count = 4;

$receiver->onWorkerStart = function ($receiver) {
    $ws = new Worker('websocket://127.0.0.1:8001');
    
    $ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $ws->onMessage = function ($connection, $data) {
        echo "Received message: $data
";
        
        // 处理接收到的消息
        // ...
    };
    
    $ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

4. Démarrez le serveur

Enfin, démarrez respectivement le serveur de transmission de messages et le serveur de réception de messages via la ligne de commande.

php push_server.php start

php receive_server.php start

À ce stade, la transmission et la réception des messages en temps réel sont terminées.

Dans les applications réelles, l'extension et l'optimisation des fonctions correspondantes peuvent être effectuées en fonction des besoins. Par exemple, vous pouvez ajouter des mécanismes d'authentification et d'autorisation pour restreindre uniquement les utilisateurs authentifiés à envoyer et recevoir des messages ; vous pouvez également conserver les messages dans une base de données afin que les utilisateurs hors ligne puissent recevoir leurs messages non lus après s'être connectés, etc.

Pour résumer, en utilisant le framework Workerman, nous pouvons obtenir une transmission et une réception efficaces de messages en temps réel. Ses caractéristiques asynchrones et non bloquantes permettent au serveur de gérer un grand nombre de connexions simultanées, améliorant ainsi l'efficacité de la transmission des messages. J'espère que cet article vous aidera à comprendre et à appliquer Workerman pour obtenir des messages push et recevoir des messages en temps réel.

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!