PHP et WebSocket : créer une plateforme de chat en temps réel performante

Avec le développement continu d'Internet, la communication en temps réel est devenue une fonctionnalité essentielle de nombreux sites Web et applications, il est donc devenu particulièrement important de créer une plateforme de chat en temps réel performante. En développement, l'utilisation de PHP et WebSocket peut bien répondre aux besoins de communication en temps réel, et la combinaison de ces deux technologies peut également améliorer considérablement les performances de la plateforme.

WebSocket est un protocole de communication full-duplex grâce auquel une connexion durable peut être établie entre le navigateur et le serveur, afin que le serveur puisse envoyer activement des messages en temps réel au client. Ce protocole se caractérise par une efficacité élevée, une fiabilité et de bonnes performances en temps réel, il est donc très approprié pour créer une plate-forme de communication en temps réel.

PHP est actuellement l'un des langages de développement Web les plus utilisés, et il existe de nombreux frameworks matures disponibles, tels que Laravel, Symfony, etc. Utilisez PHP pour créer une plate-forme de discussion en temps réel, utilisez WebSocket comme protocole de communication et utilisez les outils fournis par le framework pour implémenter rapidement une logique métier afin d'obtenir un développement rapide et des performances élevées.

Ce qui suit va créer un exemple de plate-forme de discussion Web basée sur le framework Laravel et utiliser WebSocket pour envoyer des messages en temps réel. Vous devez d’abord télécharger et installer la bibliothèque Ratchet, qui est une bibliothèque de serveur WebSocket basée sur ReactPHP et très simple à utiliser.

Installez la bibliothèque Ratchet :

composer require cboden/ratchet

Définissez ensuite la route WebSocket dans le fichier routes/web.php : routes/web.php文件中定义WebSocket的路由：

use AppHttpControllersChatController;
use RatchetHttpHttpServer;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

Route::get('/chat', function () {
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new ChatController()
            )
        ),
        8080
    );
    $server->run();
})->name('chat');

ChatController就是WebSocket的控制器，用于处理WebSocket的连接和消息。我们在app/Http/Controllers/ChatController.php中定义：

namespace AppHttpControllers;

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class ChatController implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})
";
    }

    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);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

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

ChatController实现了MessageComponentInterface接口，包含了四个方法：onOpen、onMessage、onClose和onError。其中，onOpen在连接建立时触发，onMessage在接收到消息时触发，onClose在连接关闭时触发，onError在发生错误时触发。在onOpen中，将连接保存到$clients数组中；在onMessage中，将接收到的消息发送给所有其他连接；在onClose中，从$clients数组中删除关闭的连接；在onError

var conn = new WebSocket("ws://localhost:8080/chat");

conn.onmessage = function (event) {
    // 接收到聊天信息后的处理
};

function sendChatMessage(message) {
    conn.send(message);
}

ChatController est le contrôleur de WebSocket, utilisé pour traiter les connexions et les messages WebSocket. Nous définissons dans app/Http/Controllers/ChatController.php :

rrreee

ChatController implémente l'interface MessageComponentInterface, qui contient quatre méthodes : onOpen, onMessage, onClose et onError. Parmi eux, onOpen est déclenché lorsque la connexion est établie, onMessage est déclenché lorsqu'un message est reçu, onClose est déclenché lorsque la connexion est fermée. , et onError Se déclenche lorsqu'une erreur se produit. Dans <code>onOpen, enregistrez la connexion au tableau $clients ; dans onMessage, envoyez le message reçu à toutes les autres connexions dans In  ; onClose, supprimez la connexion fermée du tableau $clients ; dans onError, gérez l'erreur et fermez la connexion.

Ensuite, utilisez JavaScript sur le front-end pour vous connecter à WebSocket, envoyer des informations de discussion au serveur et recevoir des informations de discussion en temps réel. Le code spécifique est le suivant :

rrreee

Grâce à WebSocket, une communication bidirectionnelle en temps réel peut être effectuée entre le front-end et le serveur, et une fonction de chat en temps réel efficace et fiable est réalisée. 🎜🎜Pour résumer, l'utilisation de PHP et WebSocket pour créer une plate-forme de discussion en temps réel peut exploiter pleinement la nature en temps réel de WebSocket ainsi que l'efficacité, la flexibilité et les cadres et outils matures de PHP pour améliorer les performances et l'efficacité de développement du plate-forme. Cet article fournit un exemple basé sur Laravel et Ratchet, dans l'espoir d'aider les lecteurs à créer une plateforme de chat 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!