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 cruciale dans le chat en ligne, la poussée boursière et d'autres scénarios. Le protocole WebSocket permet aux navigateurs et aux serveurs d'établir des connexions bidirectionnelles continues, permettant un échange de données en temps réel efficace. Cet article présentera comment utiliser le protocole PHP et WebSocket pour terminer la communication en temps réel et le démontrer via des exemples de code.

1. Introduction à l'accord Websocket

Le protocole WebSocket est basé sur le protocole TCP et prend en charge la communication duplex complète. Par rapport au HTTP traditionnel, WebSocket peut permettre aux serveurs de pousser activement les données et les clients peuvent répondre instantanément. Ses principales caractéristiques comprennent:

1. Communication bidirectionnelle en temps réel: aucun sondage client n'est requis, les serveurs et les clients peuvent interagir en temps réel.
2. Faible caisse de communication: l'en-tête des paquets est plus petit, économise des ressources de bande passante.
3. Performances supérieures: maintenir de longues connexions, réduire le nombre de poignées de main et améliorer la vitesse de réponse.

2. Introduction à l'extension PHP WebSocket

Bien que PHP ne prenne pas directement en charge WebSocket, les fonctions connexes peuvent être implémentées via la bibliothèque d'extension. Les extensions couramment utilisées sont:

1. Ratchet: Bibliothèque WebSocket Lightweight, prend en charge le serveur et le client.
2. Swoole: bibliothèque de communication réseau haute performance, prenant en charge plusieurs protocoles.
3. Workerman: Socket Framework multi-thread, prend en charge WebSocket Server et Client.

Cet article utilise une extension cliquet comme exemple pour démontrer le processus d'implémentation de la communication WebSocket.

3. Installez l'extension à cliquet

Installer Ratchet via Composer:

 <span class="fun">Le compositeur nécessite CBODEN / Ratchet</span>

4. Créer un serveur WebSocket

L'exemple suivant montre un serveur simple qui reçoit des messages et diffuser à tous les clients connectés:

 <?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
<p>require 'vendor/autoload.php';</p>
<p>class MyWebSocketServer implements MessageComponentInterface {<br>
protected $clients;</p>
<pre class="overflow-visible!"><div class="contain-inline-size rounded-2xl border-[0.5px] border-token-border-medium relative bg-token-sidebar-surface-primary"><div class="flex items-center text-token-text-secondary px-4 py-2 text-xs font-sans justify-between h-9 bg-token-sidebar-surface-primary dark:bg-token-main-surface-secondary select-none rounded-t-2xl">php</div><div class="sticky top-9"><div class="absolute end-0 bottom-0 flex h-9 items-center pe-2"><div class="bg-token-sidebar-surface-primary text-token-text-secondary dark:bg-token-main-surface-secondary flex items-center gap-4 rounded-sm px-2 font-sans text-xs"><button class="flex gap-1 items-center select-none py-1" aria-label="copie"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path fill-rule="evenodd" clip-rule="evenodd" d="M7 5C7 3.34315 8.34315 2 10 2H19C20.6569 2 22 3.34315 22 5V14C22 15.6569 20.6569 17 19 17H17V19C17 20.6569 15.6569 22 14 22H5C3.34315 22 2 20.6569 2 19V10C2 8.34315 3.34315 7 5 7H7V5ZM9 7H14C15.6569 7 17 8.34315 17 10V15H19C19.5523 15 20 14.5523 20 14V5C20 4.44772 19.5523 4 19 4H10C9.44772 4 9 4.44772 9 5V7ZM5 9C4.44772 9 4 9.44772 4 10V19C4 19.5523 4.44772 20 5 20H14C14.5523 20 15 19.5523 15 19V10C15 9.44772 14.5523 9 14 9H5Z" fill="currentColor"></path></svg>copie</button><button class="flex items-center gap-1 py-1 select-none"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path d="M2.5 5.5C4.3 5.2 5.2 4 5.5 2.5C5.8 4 6.7 5.2 8.5 5.5C6.7 5.8 5.8 7 5.5 8.5C5.2 7 4.3 5.8 2.5 5.5Z" fill="currentColor" stroke="currentColor" stroke-linecap="round" stroke-linejoin="round"></path><path d="M5.66282 16.5231L5.18413 19.3952C5.12203 19.7678 5.09098 19.9541 5.14876 20.0888C5.19933 20.2067 5.29328 20.3007 5.41118 20.3512C5.54589 20.409 5.73218 20.378 6.10476 20.3159L8.97693 19.8372C9.72813 19.712 10.1037 19.6494 10.4542 19.521C10.7652 19.407 11.0608 19.2549 11.3343 19.068C11.6425 18.8575 11.9118 18.5882 12.4503 18.0497L20 10.5C21.3807 9.11929 21.3807 6.88071 20 5.5C18.6193 4.11929 16.3807 4.11929 15 5.5L7.45026 13.0497C6.91175 13.5882 6.6425 13.8575 6.43197 14.1657C6.24513 14.4392 6.09299 14.7348 5.97903 15.0458C5.85062 15.3963 5.78802 15.7719 5.66282 16.5231Z" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path><path d="M14.5 7L18.5 11" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path></svg>modifier</button></div></div></div><div class="overflow-y-auto p-4" dir="ltr">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()}\n";
    $conn->close();
}

}

$ server = new \ ratchet \ server \ ioserver (
new \ ratchet \ http \ httpServer (
new \ ratchet \ Websocket \ wsserver (
NOUVEAU MYWEBSOCKETSERVER ()
)
),
new \ react \ socket \ server ('0.0.0.0:8000', new \ react \ eventloop \ streamselectloop ())
));

$ server-> run ();


5. Créer un client WebSocket

L'exemple client suivant implémente la connexion au serveur, l'envoi de messages et la réception des réponses:

 <?php
use Ratchet\Client\WebSocket;
use Ratchet\Client\Connector;
use React\EventLoop\Factory as EventLoopFactory;
<p>require 'vendor/autoload.php';</p>
<p>$loop = EventLoopFactory::create();<br>
$connector = new Connector($loop);</p>
<p>$connector('ws://localhost:8000')->then(function(WebSocket $conn) {<br>
$conn->on('message', function($msg) use ($conn) {<br>
echo "Received: {$msg}\n";<br>
$conn->close();<br>
});</p>
<pre class="overflow-visible!"><div class="contain-inline-size rounded-2xl border-[0.5px] border-token-border-medium relative bg-token-sidebar-surface-primary"><div class="flex items-center text-token-text-secondary px-4 py-2 text-xs font-sans justify-between h-9 bg-token-sidebar-surface-primary dark:bg-token-main-surface-secondary select-none rounded-t-2xl">perl</div><div class="sticky top-9"><div class="absolute end-0 bottom-0 flex h-9 items-center pe-2"><div class="bg-token-sidebar-surface-primary text-token-text-secondary dark:bg-token-main-surface-secondary flex items-center gap-4 rounded-sm px-2 font-sans text-xs"><button class="flex gap-1 items-center select-none py-1" aria-label="copie"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path fill-rule="evenodd" clip-rule="evenodd" d="M7 5C7 3.34315 8.34315 2 10 2H19C20.6569 2 22 3.34315 22 5V14C22 15.6569 20.6569 17 19 17H17V19C17 20.6569 15.6569 22 14 22H5C3.34315 22 2 20.6569 2 19V10C2 8.34315 3.34315 7 5 7H7V5ZM9 7H14C15.6569 7 17 8.34315 17 10V15H19C19.5523 15 20 14.5523 20 14V5C20 4.44772 19.5523 4 19 4H10C9.44772 4 9 4.44772 9 5V7ZM5 9C4.44772 9 4 9.44772 4 10V19C4 19.5523 4.44772 20 5 20H14C14.5523 20 15 19.5523 15 19V10C15 9.44772 14.5523 9 14 9H5Z" fill="currentColor"></path></svg>copie</button><button class="flex items-center gap-1 py-1 select-none"><svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg" class="icon-xs"><path d="M2.5 5.5C4.3 5.2 5.2 4 5.5 2.5C5.8 4 6.7 5.2 8.5 5.5C6.7 5.8 5.8 7 5.5 8.5C5.2 7 4.3 5.8 2.5 5.5Z" fill="currentColor" stroke="currentColor" stroke-linecap="round" stroke-linejoin="round"></path><path d="M5.66282 16.5231L5.18413 19.3952C5.12203 19.7678 5.09098 19.9541 5.14876 20.0888C5.19933 20.2067 5.29328 20.3007 5.41118 20.3512C5.54589 20.409 5.73218 20.378 6.10476 20.3159L8.97693 19.8372C9.72813 19.712 10.1037 19.6494 10.4542 19.521C10.7652 19.407 11.0608 19.2549 11.3343 19.068C11.6425 18.8575 11.9118 18.5882 12.4503 18.0497L20 10.5C21.3807 9.11929 21.3807 6.88071 20 5.5C18.6193 4.11929 16.3807 4.11929 15 5.5L7.45026 13.0497C6.91175 13.5882 6.6425 13.8575 6.43197 14.1657C6.24513 14.4392 6.09299 14.7348 5.97903 15.0458C5.85062 15.3963 5.78802 15.7719 5.66282 16.5231Z" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path><path d="M14.5 7L18.5 11" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"></path></svg>modifier</button></div></div></div><div class="overflow-y-auto p-4" dir="ltr">$conn->send('Hello, WebSocket Server!');

}, fonction (\ exception $ e) use ($ LOOP) {
echo "n'a pas pu se connecter: {$ e-> getMessage ()} \ n";
$ LOOP-> stop ();
});

$ LOOP-> run ();


6. Démarrer le service WebSocket

Démarrez le serveur et le client sur la ligne de commande:

 php server.php
php client.php

À l'heure actuelle, le client et le serveur peuvent réaliser une communication bidirectionnelle de données en temps réel.

Résumer

Cet article présente la méthode de base de l'utilisation de PHP pour combiner le protocole WebSocket pour une communication en temps réel, en se concentrant sur la démonstration de l'installation et de la mise en œuvre du code des extensions de cliquet. Grâce au protocole WebSocket, les applications PHP peuvent réaliser une poussée efficace de serveur et une réponse client, répondant aux besoins de l'interaction Web moderne en temps réel.