Comment communiquer en temps réel avec le protocole WebSocket via PHP

Comment communiquer en temps réel avec le protocole WebSocket via PHP

Avec le développement d'applications Web, la communication en temps réel est devenue très importante dans de nombreux scénarios, comme le chat en ligne, les cotations boursières, etc. Le protocole WebSocket est conçu pour établir une connexion de communication en temps réel entre un navigateur Web et un serveur. Cet article expliquera comment utiliser les protocoles PHP et WebSocket pour la communication en temps réel et fournira des exemples de code pertinents.

1. Introduction au protocole WebSocket
Le protocole WebSocket est un protocole de communication full-duplex construit sur le protocole TCP. Il peut permettre au serveur de transmettre activement des messages au client et de recevoir des messages du client. Par rapport au protocole HTTP traditionnel, le protocole WebSocket présente les caractéristiques suivantes :

1. Communication bidirectionnelle en temps réel : WebSocket peut établir une communication bidirectionnelle en temps réel entre le serveur et le client, sans que le client n'interroge constamment le serveur. .
2. Réduction des frais de communication : par rapport au protocole HTTP, le protocole WebSocket a des en-têtes de communication plus petits, ce qui réduit les frais de communication.
3. Performances plus élevées : étant donné que le protocole WebSocket peut établir de longues connexions, il réduit la surcharge de négociation de chaque requête, améliorant ainsi les performances de communication.

2. Extension PHP WebSocket
PHP ne fournit officiellement pas de support direct pour WebSocket, mais vous pouvez implémenter les fonctions WebSocket en installant et en utilisant des extensions. Actuellement, les extensions PHP WebSocket les plus couramment utilisées sont les suivantes :

1. Ratchet : une bibliothèque PHP WebSocket légère qui prend en charge le serveur et le client WebSocket, est facile à utiliser et possède des fonctions complètes.
2. Swoole : Une bibliothèque de communication réseau PHP hautes performances qui peut implémenter le serveur et le client WebSocket.
3. Workerman : un framework PHP Socket multithread qui prend en charge le serveur et le client WebSocket.

En raison du manque d'espace, cet article utilisera l'extension Ratchet comme exemple de démonstration.

3. Installez l'extension Ratchet
Vous pouvez installer l'extension Ratchet via Composer, exécutez la commande suivante pour l'installer :

composer require cboden/ratchet

4. Créez un serveur WebSocket
Ce qui suit est une simple implémentation de serveur WebSocket, qui peut renvoyer le message reçu tel quel. Au client :

<?php
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class MyWebSocketServer implements MessageComponentInterface {
    protected $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) {
            $client->send($msg);
        }
    }

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

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "Error: {$e->getMessage()}
";
        $conn->close();
    }
}

$server = App::make('RatchetServerIoServer', [
    new AppMyWebSocketServer()
]);

$server->run();

5. Créez un client WebSocket
Ce qui suit est une implémentation simple du client WebSocket qui peut communiquer avec le serveur ci-dessus :

<?php
use RatchetClientWebSocket;
use RatchetClientConnector;
use ReactEventLoopFactory as EventLoopFactory;

require 'vendor/autoload.php';

$loop = EventLoopFactory::create();
$connector = new Connector($loop);

$connector('ws://localhost:8000')->then(function (WebSocket $conn) {
    $conn->on('message', function ($msg) use ($conn) {
        echo "Received: {$msg}
";
        $conn->close();
    });

    $conn->send('Hello, WebSocket Server!');
}, function (Exception $e) use ($loop) {
    echo "Could not connect: {$e->getMessage()}
";
    $loop->stop();
});

$loop->run();

6. Exécutez le service WebSocket
Démarrez le serveur WebSocket via le ligne de commande :

php server.php

Ensuite, exécutez le code client :

php client.php

Ensuite, une communication en temps réel entre le client et le serveur peut être réalisée.

Résumé :
Cet article présente brièvement comment utiliser les protocoles PHP et WebSocket pour la communication en temps réel, et fournit des exemples de code pertinents pour l'extension Ratchet. Grâce au protocole WebSocket, nous pouvons implémenter le serveur pour transmettre activement des messages au client et établir une communication bidirectionnelle en temps réel. En utilisant l'extension PHP WebSocket, nous pouvons facilement créer des serveurs et des clients WebSocket et établir une communication en temps réel via un code simple.

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!