Comment utiliser WebSocket en PHP

Avec le développement de la technologie réseau, WebSocket (Web Socket) est devenu un protocole populaire, capable d'établir un canal de communication en temps réel entre le navigateur et le serveur pour maintenir une connexion. Ce protocole joue un rôle important en permettant les capacités de communication en temps réel dans les applications Web.

Dans le domaine du développement PHP, WebSocket est de plus en plus utilisé. Dans cet article, nous présenterons comment utiliser WebSocket en PHP.

1. Installer la bibliothèque WebSocket

Tout d'abord, nous devons utiliser une bibliothèque PHP WebSocket pour implémenter facilement les fonctions WebSocket en PHP. Actuellement, les bibliothèques PHP WebSocket les plus populaires sont Ratchet et PHP WebSocket.

Ici, nous utilisons Ratchet, qui utilise la bibliothèque ReactPHP pour implémenter du PHP asynchrone basé sur les événements, et est parfaitement compatible avec d'autres frameworks et offre flexibilité et évolutivité.

Avant de commencer, nous devons d'abord installer Composer, car Ratchet est installé et géré à l'aide de Composer.

Composer peut être téléchargé ici : https://getcomposer.org/

Installer Ratchet à l'aide de Composer :

composer require cboden/ratchet

2. Écrire un serveur PHP WebSocket

Dans cet exemple, nous allons implémenter une salle de discussion simple, en utilisant Ratchet écrit un serveur WebSocket. Voici les étapes à mettre en œuvre :

a. Créer un serveur WebSocket

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

Ici, la bibliothèque Ratchet est d'abord introduite, puis un serveur WebSocket est créé, en utilisant HttpServer et WsServer pour spécifier respectivement la prise en charge des protocoles HTTP et WebSocket, et passer vers la classe Chat (il sera montré plus tard que la classe Chat est utilisée pour gérer les demandes de connexion des clients).

Ici, nous écoutons le port 8080.

b. Créer une salle de discussion

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class Chat implements MessageComponentInterface
{
    public $clients;

    public function __construct()
    {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($msg);
            }
        }
    }

    public function onClose(ConnectionInterface $conn)
    {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        $conn->close();
    }
}

Ici, nous créons une classe nommée Chat, qui implémente l'interface MessageComponentInterface. Cette interface définit les opérations effectuées par le serveur WebSocket dans différents états de connexion.

Plus précisément, nous avons déclaré une variable clients dans le constructeur, qui est l'objet SplObjectStorage qui stocke le client connecté. Dans la méthode onOpen, l'objet de connexion est affecté à cette variable.

Lorsqu'il y a un message d'un client, nous diffusons le message via la méthode onMessage, qui sera reçu à chaque connexion.

Dans la méthode onClose, l'objet de connexion sera supprimé de la variable. Si une erreur se produit et que la connexion client ne peut pas être gérée, alors notre fonction onError sera appelée.

3. Écrire du code JavaScript côté client

Ensuite, nous avons besoin de code JavaScript côté client pour nous connecter au serveur WebSocket.

let socket = new WebSocket('ws://localhost:8080');
socket.onopen = function(event) {
  console.log('WebSocket连接已建立');
};

socket.onmessage = function(event) {
  console.log('收到消息：' + event.data);
};

Ici, nous utilisons directement l'API de l'objet WebSocket pour nous connecter et envoyer et recevoir des messages au serveur.

4. Exécutez le serveur WebSocket

Lorsque vous avez terminé les étapes ci-dessus, vous avez écrit avec succès un serveur WebSocket. Exécutez maintenant votre serveur, soit via la ligne de commande :

php server.php

Lors du démarrage du serveur à partir de la ligne de commande, vous devriez voir des résultats similaires à ce qui suit :

2019-03-22 11:46:55 WebSocketServer: Listening on 0.0.0.0:8080
2019-03-22 11:52:50 WebSocketServer: Opened connection to http://localhost:54616

signifie que le service WebSocket a été démarré avec succès et écoute sur le port 8080.

5. Testez la connexion WebSocket

Enfin, ouvrez le navigateur et visitez http://localhost/chat.html Vous pouvez voir la connexion du navigateur et rejoindre le serveur WebSocket.

let socket = new WebSocket('ws://localhost:8080');
socket.onopen = function(event) {
  console.log('WebSocket连接已建立');
  socket.send('欢迎加入聊天室');
};

socket.onmessage = function(event) {
  console.log('收到消息：' + event.data);
};

Ici, nous envoyons un message au serveur et l'enregistrons dans la console lorsque le message du serveur est reçu.

Lorsque vous exécutez la page Web de test, vous verrez un résultat similaire à celui-ci dans la console :

WebSocket已连接
WebSocket收到消息：欢迎加入聊天室

Maintenant, vous avez utilisé avec succès WebSocket en PHP et créé une simple salle de discussion. J'espère que ce tutoriel pourra vous être utile.

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!