Un tutoriel complet sur la mise en œuvre de la communication en temps réel à l'aide de PHP et Swoole

Avec le développement rapide d'Internet et des technologies de communication mobile, la communication en temps réel attire de plus en plus d'attention. La communication en temps réel peut réaliser une messagerie instantanée entre les utilisateurs, des appels audio et vidéo en ligne, des combats de jeu et d'autres fonctions, offrant ainsi plus de possibilités aux applications Internet.

Cet article expliquera comment utiliser PHP et Swoole pour établir une communication en temps réel. À partir d'une simple application WebSocket, nous présenterons progressivement les connaissances de base de la programmation Socket et la pratique applicative de Swoole. La lecture de cet article nécessite des connaissances de base sur les bases de PHP et la programmation réseau.

1. Bases de WebSocket

WebSocket est un protocole de communication bidirectionnel basé sur le protocole HTTP. Il utilise un protocole appelé « handshake » pour permettre une communication bidirectionnelle. L'avantage de la connexion WebSocket est que sa surcharge est très faible, la communication en temps réel est très bonne et une communication bidirectionnelle en temps réel peut être établie entre le client et le serveur.

La création de WebSocket nécessite les étapes suivantes :

1. Le navigateur initie une demande de prise de contact WebSocket auprès du serveur. L'en-tête de la demande contient certains champs clés, tels que Mise à niveau, Connexion, Sec-WebSocket-Key, etc.

2. Le serveur traite la demande WebSocket du client et, si elle répond aux spécifications, renvoie un message de réponse avec des champs tels que Upgrade, Connection et Sec-WebSocket-Accept dans l'en-tête de réponse.

3. Le client reçoit le message de réponse du serveur, vérifie le champ Sec-WebSocket-Accept et confirme que la négociation WebSocket est établie avec succès.

4. Les deux parties peuvent démarrer la communication de données et envoyer des messages texte, binaires, Ping, Pong et autres.

En utilisant WebSocket en PHP, nous pouvons l'implémenter via le service WebSocket fourni par Swoole. Ce qui suit présente l'application de base de Swoole.

2. Bases de Swoole

1. Installer Swoole

Avant de commencer à utiliser Swoole, nous devons installer l'extension Swoole sur le serveur. Il peut être installé via la commande suivante :

pecl install swoole

ou via l'installation du code source :

$ wget https://github.com/swoole/swoole-src/archive/v4.3.3.tar.gz
$ tar zxvf v4.3.3.tar.gz
$ cd swoole-src-4.3.3
$ phpize
$ ./configure
$ make && make install --with-swoole

2. Service Swoole WebSocket

Implémentons un Un simple service WebSocket qui écoute le port 9501 et envoie un message bonjour au client lorsque celui-ci établit une connexion avec le serveur.

<?php

$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    $server->push($request->fd, "hello");
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
});

$server->start();

Dans ce code, nous créons un nouveau serveur WebSocket et écoutons sur le port 9501. Lorsque le client établit une connexion avec le serveur, l'événement open est déclenché et un message bonjour est envoyé au client. Lorsque le client envoie un message au serveur, l'événement de message est déclenché et nous pouvons afficher les informations envoyées par le client via echo.

Après avoir démarré le code ci-dessus, nous pouvons utiliser le navigateur ou le client WebSocket pour nous connecter au serveur :

let ws = new WebSocket('ws://127.0.0.1:9501');
ws.onopen = function(event) {
    console.log('WebSocket connected');
};
ws.onmessage = function(event) {
    console.log('Received:', event.data);
};
ws.send('Hello, Server');

Une fois la connexion réussie du client, la console affichera les informations suivantes :

WebSocket connected
Received: hello

Indique que le client a reçu avec succès le bonjour message envoyé par le serveur.

3. Implémenter une application de chat en temps réel

Ensuite, implémentons une application de chat en temps réel qui permet à plusieurs utilisateurs de communiquer en temps réel dans une salle de discussion. Cela nous oblige à continuer à développer le serveur WebSocket ci-dessus pour implémenter les fonctions de base du salon de discussion.

<?php

$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->set([
    'worker_num' => 2,    //启动2个Worker进程
]);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    foreach($server->connections as $fd) {
        $server->push($fd, "{$request->fd} joined the room");
    }
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    foreach($server->connections as $fd) {
        if ($fd != $frame->fd) {
            $server->push($fd, "user {$frame->fd}: {$frame->data}");
        }
    }
});

$server->on('close', function ($server, $fd) {
    echo "client {$fd} closed
";
    foreach($server->connections as $fds) {
        $server->push($fds, "{$fd} quited the room");
    }
});

$server->start();

Dans le code ci-dessus, nous avons ajouté la gestion des événements d'ouverture et de fermeture. Lorsqu'un utilisateur se connecte ou ferme la connexion, les messages pour rejoindre ou quitter la salle de discussion seront envoyés aux autres utilisateurs connectés. Lorsqu'un utilisateur envoie un message dans une salle de discussion, le message est diffusé aux autres utilisateurs en ligne.

Après avoir démarré le code ci-dessus, nous pouvons utiliser plusieurs fenêtres de navigateur pour nous connecter au serveur séparément et accéder à la même salle de discussion. Lorsqu'un utilisateur envoie un message, les autres utilisateurs peuvent recevoir le message en temps réel.

Cet article explique comment utiliser PHP et Swoole pour établir une communication en temps réel, des applications WebSocket de base aux applications de salle de discussion en temps réel. Swoole fournit une méthode de programmation asynchrone plus flexible, facilitant l'écriture d'applications hautes performances, à haute concurrence et à faible latence.

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!